cyy298 2021-05-11 16:13 采纳率: 100%
浏览 769
已结题

java websocket通信中多线程问题

java 端作为服务器与多个客户端通讯,使用websocket协议。

创建连接后,客户端发送消息到达服务器,由一个传输服务(transportService)根据消息类型,把消息放入到消息队列(msg queue)。

消息分为两种:

普通消息(core msg):不需要处理,直接响应或转发。

数据请求(data msg):需要服务端处理,返回数据,耗时。

普通消息对应一个单线程的线程池(coreService),消费并处理。将处理结果返回给一个响应的消息队列(core_res)。

数据请求消息对应一个单线程消费者(dataHandler),批量拉去请求数据,每条消息开启一个线程处理(dataService)。将处理结果发送到响应消息队列(data_res)。

传输服务中有一个消费者线程,消费响应数据,找到客户端session并发送。

如图

 

因为第一次使用,有些问题想请教一下。

websocket 中session是每个客户端一个,是否需要为每个客户端都创建一个线程?

消息队列目前是基于内存做的,后期可能替换为kafka、aws等。接消息放到队列者个过程会耗时吗?

  • 写回答

1条回答 默认 最新

  • 记得我雨 2021-05-11 17:04
    关注

    一个连接一个session,链接数量和每个连接发送数据的大小有关系,java线程的创建和销毁是很好资源的,建议使用线程池,基于内存的消息队列是最快的,kafka是面向大数据的可以配置个多消息分区和消费者也很快,aws没有用过。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 12月17日
  • 已采纳回答 12月9日

悬赏问题

  • ¥15 TinyMCE如何去掉自动弹出的“链接…”工具?
  • ¥15 微信支付转账凭证,如何解决
  • ¥15 在win10下使用指纹登录时,界面上的文字最后一个字产生换行现象
  • ¥20 使用AT89C51微控制器和MAX7219驱动器来实现0到99秒的秒表计数,有开始和暂停以及复位功能,请写出C语言程序
  • ¥15 51单片机 双路ad同步采样
  • ¥15 使用xdocreport 生成word
  • ¥15 请教怎么用MATLAB求坐标
  • ¥15 gradle整合es,在创建索引时报错
  • ¥15 关于模型训练的一个问题
  • ¥15 装了几千台服务器从来没遇到这种问题,哎看下哪位帮我解决吧