一对一发消息应该怎样做

[GitBiao]

想用这个做im，刚刚其他人的issuer说主动给client发消息，要接入kafka？

[YeautyYE]

不需要,用以下方法即可
session.sendText("Hello Netty!");

[GitBiao]

不需要,用以下方法即可
session.sendText("Hello Netty!");
这样应该不行的，就是a对b发消息，b对a发消息
a发了给b消息，触发的是a的onmessage，所以session是a的 ，sendText是发回给a了

[YeautyYE]

不需要,用以下方法即可
session.sendText("Hello Netty!");
这样应该不行的，就是a对b发消息，b对a发消息
a发了给b消息，触发的是a的onmessage，所以session是a的 ，sendText是发回给a了

Client对Server发消息,触发@OnMessage事件(Server接收到Client的消息),session是Client的会话实例.
session.sendText("Hello Netty!"); 则是Server主动向Client发消息.

[GitBiao]

现在我的session实例放内存里了
private Session session; private String sid; private static CopyOnWriteArraySet<MyWebSocket> webSocketSet = new CopyOnWriteArraySet<>();
然后发消息的时候循环找出相应的session实例，这样连接数多的时候，程序估计就撑不住了，有没有什么好的方法

[YeautyYE]

现在我的session实例放内存里了
private Session session; private String sid; private static CopyOnWriteArraySet<MyWebSocket> webSocketSet = new CopyOnWriteArraySet<>();
然后发消息的时候循环找出相应的session实例，这样连接数多的时候，程序估计就撑不住了，有没有什么好的方法

用map,通过key去找