udp简单通讯示例---心跳示例

╰半夏微凉° 2021-12-10 01:09 584阅读 0赞

PooledExecutor 依赖包下载地址[http://www.xwood.net/search-jar/?q=concurrent][http_www.xwood.net_search-jar_q_concurrent]

//发送心跳  
new UDPToPointCenter(18056).start();  
  
public class UDPToPointCenter extends Thread \{  
private static Logger logger = Logger.getLogger("com.hintsoft.pubwin.netcafe.socket.UDPToPointCenter");  
  
private int listenPort; //发送的端口号  
private static DatagramSocket sock;  
private Timer timer;  
private PooledExecutor \_processExecutor = new PooledExecutor(new LinkedQueue(), 1); //序列化  
protected static PooledExecutor clientPool;  
  
public UDPToPointCenter(int aListenPort) \{  
try \{  
this.timer = new Timer();  
this.listenPort = aListenPort;  
sock = new DatagramSocket(this.listenPort);  
this.timer.schedule(new ConnSvrTask(),1 \* 10 \* 1000,Global.UDP\_SYNC\_SIGNAL\_INTERVAL);  
  
\_processExecutor.setMaximumPoolSize(5);  
\_processExecutor.setMinimumPoolSize(1);  
\_processExecutor.setKeepAliveTime(10 \* 1000);  
\_processExecutor.waitWhenBlocked();  
\_processExecutor.createThreads(1);  
\}  
catch (SocketException e) \{  
logger.error(e, e);  
\}  
catch (Exception e) \{  
logger.error(e, e);  
\}  
\}  
  
private class ConnSvrTask extends TimerTask \{  
private Logger logger = Logger.getLogger("com.hintsoft.pubwin.netcafe.socket.ConnSvrTask");  
  
public ConnSvrTask() \{  
super();  
\}  
public void run() \{  
try \{  
byte\[\] b = new byte\[21\];  
DatagramPacket packet = new DatagramPacket(b, b.length);  
// 发送心跳  
try \{  
  
byte\[\] desData = new byte\[1024\];  
packet = new DatagramPacket(desData, desData.length, InetAddress.getByName(CachedConfigObject.getServerCenterCfgOtherObj().getPointCenterIP()), 18060);  
  
sock.send(packet);  
\}catch (UnknownHostException e) \{  
logger.error(e, e);  
\}catch (IOException e) \{  
logger.error(e, e);  
\}  
\}  
catch (Exception e) \{  
logger.error(e, e);  
\}  
\}  
\}  
\}  
  
  
//接收心跳  
new UderServerListen(18060).start();  
  
public class UderServerListen extends Thread \{  
private static Logger logger = Logger.getLogger("com.hintsoft.pubwin.netcafe.socket.UdpServerClient");  
  
private static DatagramSocket sock;  
private List iplist;  
private int listenPort;  
private PooledExecutor \_processExecutor = new PooledExecutor(new LinkedQueue(), 1);  
private long udpBarBeg = System.currentTimeMillis();//开始搜索心跳的时间  
  
public UderServerListen(int listenPort)\{  
try \{  
this.iplist = Global.getAllIpAddress();  
this.listenPort = listenPort;  
sock = new DatagramSocket(this.listenPort);  
  
\_processExecutor.setMaximumPoolSize(5);  
\_processExecutor.setMinimumPoolSize(1);  
\_processExecutor.setKeepAliveTime(10 \* 1000);  
\_processExecutor.waitWhenBlocked();  
\_processExecutor.createThreads(1);  
\}  
catch (SocketException e) \{  
logger.error(e, e);  
\}catch (Exception e) \{  
logger.error(e, e);  
\}  
\}  
public void run() \{  
if (sock == null) \{  
return;  
\}  
  
while(true)\{  
try \{  
byte\[\] data = new byte\[1024\];  
DatagramPacket packet = new DatagramPacket(data, data.length);  
  
sock.receive(packet);  
UDPPacketProcessor processor = new UDPPacketProcessor(packet);  
  
\_processExecutor.execute(processor);  
\}  
catch (java.net.SocketException e) \{  
logger.error(e, e);  
\}  
catch (java.net.UnknownHostException e) \{  
logger.error(e, e);  
\}  
catch (java.io.IOException e) \{  
logger.error(e, e);  
\}  
catch (Exception e) \{  
logger.error(e, e);  
\}  
\}  
\}  
private class UDPPacketProcessor implements Runnable \{  
  
private DatagramPacket \_packet;  
  
public UDPPacketProcessor(DatagramPacket packet) \{  
\_packet = packet;  
\}  
  
public void run() \{  
try \{  
List barList = new ArrayList();  
barList.addAll(iplist);  
String clientIP = \_packet.getAddress().getHostAddress();  
if(logger.isDebugEnabled())\{  
logger.debug("接收到的ip "+clientIP);  
\}  
if (iplist.contains(clientIP)) \{  
Global.setBarStatus(Global.BAR\_STATUS\_ONLINE, clientIP);  
for(int index=0;index<barList.size();index++)\{  
if(barList.get(index).equals(clientIP))\{  
barList.remove(index);  
\}  
\}  
\}else\{  
//判断心跳断开时间是否超过1小时，超过1小时则视为不在线  
if (System.currentTimeMillis() - udpBarBeg > 1 \* 60 \* 60 \* 1000L)\{  
if(null!=barList && barList.size()>0)\{  
for(int i=0;i<barList.size();i++)\{  
Global.setBarStatus(Global.BAR\_STATUS\_UNONLINE, barList.get(i).toString());  
\}  
\}  
\}  
\}  
\}catch(Exception e)\{  
logger.error(e,e);  
\}  
\}  
\}  
\}

[http_www.xwood.net_search-jar_q_concurrent]: http://www.xwood.net/search-jar/?q=concurrent