MINA服务端独立线程队列
我的目的是想 每个客户端(长连接),连接上来并 发送命令,然后保存到队列中(队列要独立)。然后从队列中取出命令 慢慢处理。。
public class ServerHandler extends IoHandlerAdapter {
/**
* 日志处理
*/
private static Logger log = Logger.getLogger(ServerHandler.class);
/**
* Socket客户端
*/
private Socket socket = null;
/**
* 双向队列
*/
private ArrayDeque<byte[]> send = new ArrayDeque<byte[]>();
public void messageReceived(IoSession session, Object message)
throws Exception {
//协议处理
IProtocol Protocol = ManufacturerFactory.getFirmObj(Firmid).getProtocolObj(ProtocolType);
byte[] sendby = Protocol.Encoder(commobj);
send.add(sendby);//命令添加到队列
//从队列中取出命令发送到其他服务 代码省略....
}
}
绝地无双
相关分类