客户端连接上之后,不需要发送信息,而是服务端直接将信息发送至客户端,是否可行?? 另外,怎样将已经处理好的数据加入到mina服务端发送,现在好像只能是messageReceived触发操作
[b]问题补充:[/b]
通过public void sessionOpened(IoSession session) throws Exception方法实现。
怎样将记录传递到open方法呢,我以前试过,但是报错
[b]问题补充:[/b]
[code="java"]
public class ChatProtocolHandler extends IoHandlerAdapter {
private Queue msgQueue = new ConcurrentLinkedQueue();
public void sessionOpened(IoSession session) throws Exception {
while (true) {
int size = msgQueue.size();
for (int i = 0; i < size; i++) {
byte[] b = msgQueue.poll();
if (b == null) continue;
session.write(b);
}
}
}
public void add(byte[] args) {
msgQueue.add(args);
}
}
[/code]
在其他应用中将数据通过add方法,加入到msgQueue中,但是一两个客户端连接时,cpu就飙高到100了,该怎么处理??