netty 做 client 怎么把请求和响应映射起来?

This topic created in 4067 days ago, the information mentioned may be changed or developed.

想做一个memcache 的client, 但是netty是异步读写

这里的例子只是把内容打印出来
https://netty.io/4.1/xref/io/netty/example/memcache/binary/MemcacheClientHandler.html

假设我有线程A B同时往这个client写相同add命令, A先B后
怎么保证A得到STORED, B得到NOT_STORED

求指点,先谢谢了

3 replies • 2015-04-28 12:32:13 +08:00

qiyi

Apr 28, 2015 via Android

netty4不是特别确定，但是对于netty3来说，客户端（channel）写实际上是往底层一个缓冲队列里写消息，然后nettyio线程从队列依次取消息发送，所以是不是要保证a确实先写入到缓冲队列才行？

phx13ye

Apr 28, 2015

@qiyi 我目前的做法是增加一个写监听,写完一个请求就往一个inboundhandler(3叫upstream)的BlockingQueue放一个请求, 读响应的时候从这个队列取出请求建立映射.
不知道有没有更好的方法

qiyi

Apr 28, 2015 via Android

@phx13ye memcache 的通信协议里没有对请求进行标识么，没了解协议细节😓