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
提交
取消