1.在项目启动时，要注入UdpServer，提供给其他类去调用

  1. package com.xlwy.fkudp.server;
  3. import cn.hutool.core.util.ReflectUtil;
  4. import org.tio.core.udp.UdpServer;
  5. import org.tio.core.udp.UdpServerConf;
  7. /**
  8.  * UDP启动类
  9.  * @Auther: WHN
  10.  * @Date: 2020/10/22 15:30
  11.  * @Description:
  12.  */
  13. public class PacUdpServerStarter  {
  14.     //新建一个UdpServer类
  15.     private static UdpServer udpServers;
  16.     //无参构造
  17.     public PacUdpServerStarter() {
  19.     }
  20.     //get方法
  21.     public UdpServer getUdpServers() {
  22.         return udpServers;
  23.     }
  24.     //set方法
  25.     public void setUdpServers(UdpServer udpServers) {
  26.         PacUdpServerStarter.udpServers = udpServers;
  27.     }
  28.     //启动方法
  29.     public static void main(String[] args) throws Exception {
  30.         start();
  31.     }
  32.     //main方法
  33.     public static void start() throws Exception {
  34.         //开启UDP服务端，端口9000，超时时间5000毫秒
  35.         PacUdpHandler fpmsUdpHandler = new PacUdpHandler();
  36.         UdpServerConf udpServerConf = new UdpServerConf(9000, fpmsUdpHandler, 5000);
  37.         UdpServer udpServer = new UdpServer(udpServerConf);
  38.         udpServer.start();
  39.         //存储全局udpServer，注入属性
  40.         //ReflectUtil.invoke：反射调用，传参：实体类、方法名、要set的参数
  41.         //ReflectUtil.newInstance：构造实例，等于new PacUdpServerStarter
  42.         //"setUdpServers"：set方法的方法名
  43.         //udpServer：需要传入的参数
  44.         ReflectUtil.invoke(ReflectUtil.newInstance(PacUdpServerStarter.class), "setUdpServers", udpServer);
  45.     }
  46. }

2.调用方法，存储全局上下文参数

  1. public void SendMessage(){
  2.     public void sendHeartMessageStr(String hex, Node remote) {
  3.         String message = hexUtils.spliHeartMessageStr(hex);
  4.         //不用自动注入，直接使用反射调用PacUdpServerStarter类，调用get方法中的send方法
  5.         ReflectUtil.newInstance(PacUdpServerStarter.class).getUdpServers().send(message, remote);
  6.         Console.log("返回数据："+ message + "\n");
  7.     }
  8. }