MINA服務(wù)端獨(dú)立線程隊(duì)列 我的目的是想 每個(gè)客戶端(長連接),連接上來并 發(fā)送命令,然后保存到隊(duì)列中(隊(duì)列要獨(dú)立)。然后從隊(duì)列中取出命令 慢慢處理。。 public class ServerHandler extends IoHandlerAdapter { /** * 日志處理 */ private static Logger log = Logger.getLogger(ServerHandler.class); /** * Socket客戶端 */ private Socket socket = null; /** * 雙向隊(duì)列 */ private ArrayDeque<byte[]> send = new ArrayDeque<byte[]>(); public void messageReceived(IoSession session, Object message) throws Exception { //協(xié)議處理 IProtocol Protocol = ManufacturerFactory.getFirmObj(Firmid).getProtocolObj(ProtocolType); byte[] sendby = Protocol.Encoder(commobj); send.add(sendby);//命令添加到隊(duì)列 //從隊(duì)列中取出命令發(fā)送到其他服務(wù) 代碼省略.... } }
添加回答
舉報(bào)
0/150
提交
取消