CountDownLatch

发表于 2025-11-26 分类于 Java
本文字数： 1.2k 阅读时长 ≈ 4 分钟

CountDownLatch 是 Java 并发工具类（位于 java.util.concurrent 包），核心作用是 让一个或多个线程等待其他线程完成一系列操作后，再继续执行。它基于「计数器」实现，本质是一种「同步屏障」。

阅读全文 »

将异步接口转成同步接口

发表于 2025-11-25
本文字数： 2.1k 阅读时长 ≈ 8 分钟

将短信发送的异步回调接口改为同步接口，核心思路是：发起短信请求后，在后端服务内阻塞等待回调通知，直到超时或收到明确结果。以下是具体实现方案、代码示例和注意事项。

阅读全文 »

Redis远程主机强迫关闭了一个现有的连接

发表于 2025-11-11 分类于 Redis
本文字数： 1.5k 阅读时长 ≈ 6 分钟

现象

025-11-07 13:58:40.051 ERROR [celina-data-center,,] 34880 --- [isson-netty-1-6] o.redisson.client.handler.CommandsQueue  : Exception occured. Channel: [id: 0xdd6f0878, L:/192.168.10.182:60652 - R:dmz-zjj.lanniuh.com/172.16.16.33:7073]

java.io.IOException: 远程主机强迫关闭了一个现有的连接。
    at sun.nio.ch.SocketDispatcher.read0(Native Method)
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
    at sun.nio.ch.IOUtil.read(IOUtil.java:192)
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
    at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:258)
    at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
    at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:350)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496)
    at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
    at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:750)