使用netty自带连接池，异步发送消息，同步获取返回结果

2021-03-17 19:27

阅读：440

标签：rpc locking cond exp ref dem service write 响应

Netty获取异步执行结果

	// 定义个存储响应消息的变量responseMsgCache
    private static Cache> responseMsgCache = CacheBuilder.newBuilder()
            .maximumSize(50000)
            .expireAfterWrite(1000, TimeUnit.SECONDS)
            .build();

步骤：（具体代码参考下面demo）

给消息设置个唯一key
初始化响应消息队列：responseMsgCache.put(key,new LinkedBlockingQueue(1)); 见NettyTools.initReceiveMsg(key);
执行异步IO：future.addListener 见NettyClientService.sendMsg
阻塞等待：responseMsgCache.get(key).poll()见NettyTools.waitReceiveMsg(key);
处理事件：如果监听到事件，responseMsgCache.get(key).add(Response)见NettyTools.setReceiveMsg(key, msgStr);
等待结束，返回response。

demo git地址：https://gitee.com/xjmroot/netty-pool
demo演示结果
技术图片

参考：http://thoreauz.com/2019/01/19/rpc2-netty-handler/

使用netty自带连接池，异步发送消息，同步获取返回结果

标签：rpc locking cond exp ref dem service write 响应

原文地址：https://www.cnblogs.com/JaminXie/p/12781748.html

上一篇：浏览器内核拿到html文件后，渲染流程是怎么样?

下一篇：nginx和Apache的特点与区别

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：使用netty自带连接池，异步发送消息，同步获取返回结果
文章链接：http://soscw.com/index.php/essay/65447.html

亲，登录后才可以留言！

使用netty自带连接池，异步发送消息，同步获取返回结果

评论

热门文章

推荐文章

最新文章

置顶文章