java websocket通信中多线程问题

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

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

消息分为两种:

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

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

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

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

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

如图

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

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

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

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