@jobtesting 因为今天是周六,到时候打算先咨询下社保

有没有办过的小伙伴,帮忙出出主意~

@buruoyanyang future.get()这个会阻塞没错,但是 callback 在 onmessage 里怎么拿到并做返回?这里有点疑问

@buruoyanyang 具体说说,请教下?目前看你描述是在整个 http 请求同步代码中,只是使用 future 做异步请求 mq 拿到结果,如何能应用到他这个案例?

你写这个应该只是演示吧,因为你 http 收到请求后,发送给的是所有 session,然后需求是等待 onmessage 返回结果后响应 http;实际中应该是通过 http 请求给相应 session 发送吧?目前想到的方案是这样:
一.你要把 http 跟 websocket 全用 netty 来写可能灵活性好一些;
二.通过传递响应对象和锁工具:
(1) http 接收到请求后,拿到当前请求 sessionid 或者你根据业务自己生成的随机数,然后分别存储 key 为随机数,value 为 HttpServletResponse 和类似 CountDownLatch 对象存储到两个全局 map 中;并且将该随机数发送给 websocket 接收者;
后面用 CountDownLatch 等工具 hold 住线程;
(2)onmessage 接受到消息后,通过随机数取出 map 中 HttpServletResponse 对象和 CountDownLatch,进行返回数据和释放锁;

server-->长连接-->client;
client 监听 http 请求--->发送到 server 的 channl-->server 请求 http 服务返回数据;
思路是这样?

之前骑了一个月,现在太热改开车,5km 左右,钢架公路,的确比电动车快多了~座椅稍微向下倾斜点,然后软点没问题的~不过安全第一

不知道是什么项目管理工具,可以把业务跟数据库实体分模块,然后共用数据库实体模块的方式,减少不必要的代码量

我去-.-没人的吗