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);//命令添加到队列 //从队列中取出命令发送到其他服务 代码省略.... } }
添加回答
举报
0/150
提交
取消