public static void startListener() throws UDPException{
        try {
            if(tdUdpServerIsStart){
                throw new UDPException("服务已启动");
            }
            hasStartSet = false;
            tdUdpServerIsStart = true;

new Thread(new WorkThread()).start();
            new Thread(new ReceiverThread()).start();
            new Thread(new SenderThread()).start();
           
            datagramSocket = new DatagramSocket(PORT);
            datagramSocket.setSoTimeout(TIME_OUT);
            datagramSocket.setReceiveBufferSize(UDP_RECEIVER_BUFF_SIZE);

} catch (SocketException e) {
            log.error("",e);
            throw new UDPException("UDPServer 启动异常，端口："+PORT,e);
        }
    }

@Overridepublic void run() {log.info("UDP Sender thread started");while(ServerManager.tdUdpServerIsStart) try {UDPMessage reqBody = senderQueue.take();//队列中没有时会一直等待byte[] bodyBit = reqBody.getMsgBits();if(reqBody.getHeader() == null){log.warn("Header is null");continue;}if(reqBody.getHeader().getMessageId() == null){log.warn("MessageId is null!");continue;}//            log.debug("Send head:"+reqBody.getHeader().toString());
//            log.info(String.format("Preprocess messageId:%s,len:%s,sessionId:%s to %s", reqBody.getHeader().getMessageId(),bodyBit.length, reqBody.getHeader().getSessionId(), reqBody.getHeader().getSocketAddress()));
//            byte[] body = ProtMsgData.makeMsgStream(reqBody.getSessionId(), reqBody.getMessageId().getMessageId(), bodyBit);byte[] body = reqBody.getMsgBits();DatagramPacket dataPacket = new DatagramPacket(body, body.length,reqBody.getHeader().getSocketAddress());//测试CODE
//            DatagramPacket dataPacket = new DatagramPacket(body, body.length,
//                    InetAddress.getByName("10.10.10.100"), 6060);//            DatagramSocket dataSocket = new DatagramSocket(reqBody.getHeader().getInetSocketAddress().getPort());
//            DatagramSocket dataSocket = new DatagramSocket(45677);DatagramSocket dataSocket = getSocket(reqBody.getHeader().getInetSocketAddress().getPort());if(dataSocket == null){log.warn(String.format("Send error!Not found socket by port:%s",reqBody.getHeader().getInetSocketAddress().getPort()));continue;}log.info(String.format("Send message to %s,id:%s,len:%s,data:%s",reqBody.getHeader().getSocketAddress().toString(),reqBody.getHeader().getMessageId(),body.length,ProtUtils.getHexByString(body)));dataSocket.send(dataPacket);//如果需要接收消息，先将记录保存起来//            if (reqBody.isNeedReceive()) {
//                UDPSessionManager.add(reqBody);
//            }} catch (Exception e) {log.error("Send message error", e);}}

@Overridepublic void run() {Init();}public void Init() {while(UCSIServerManager.tdUdpServerIsStart){try {byte[] receiveBody = new byte[BUFFER_SIZE];DatagramPacket dataPacketBody = new DatagramPacket(receiveBody, receiveBody.length);if(dataPacketBody == null) continue;ServerManager.receive(dataPacketBody);if(dataPacketBody == null) continue;//添加到工作线程队列ProtRespInfo respInfo = new ProtRespInfo(null,dataPacketBody); UDPWorkThread.push(respInfo);} catch (Exception e) {}}
}

@Overridepublic void run() {while(UCSIServerManager.tdUdpServerIsStart){try {ProtRespInfo packet = workQueue.take();UDPReceiverHandler handler = new UDPReceiverHandler(packet);handler.receive();} catch (InterruptedException e) {e.printStackTrace();continue;}}
}public static void push(ProtRespInfo respInfo){try {workQueue.put(respInfo);} catch (Exception e) {e.printStackTrace();}
}

public void receive(){        log.debug("UDPReceiver receive..."); UDPHeader header = getUDPHeader(respInfo.getDeviceType());if(header == null){log.warn("Not found head by port:"+respInfo.getDataPacket().getPort());return;}header.setSocketAddress(respInfo.getDataPacket().getSocketAddress());header.data = respInfo.getDataPacket().getData();header.len = header.getHeaderSize();header.decode();header.setDeviceType(respInfo.getDeviceType());respInfo.setHeader(header);if(respInfo.getHeader() == null || respInfo.getHeader().getMessageId() == null){log.warn("消息头错误，来自IP:"+respInfo.getHeader().getRemoteAddr()+",端口："+respInfo.getHeader().getRemotePort());return;}try {IReceiverHandler handler = ReceiverHandlerManager.get(respInfo.getHeader().getMessageId().getMessageId());if(handler == null){log.error("没有找到对应的消息Handler,ID:"+respInfo.getHeader().getMessageId());return;}handler.handler(header,respInfo);} catch (Exception e) {log.error("",e);}}