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

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 字符串的比较老是报错
    • ¥15 很简单的c#代码补全
    • ¥15 复杂表达式求值程序里的函数优先级问题
    • ¥15 求密码学的客成社记ji着用
    • ¥35 POI导入树状结构excle
    • ¥15 初学者c语言题目解答
    • ¥15 div editable中的光标问题
    • ¥15 mysql报错1415Not allowed to return a result set from a trigger 不知如何修改
    • ¥60 Python输出Excel数据整理,算法较为复杂
    • ¥15 回答几个问题 关于数据库