package com.hxzkoa.udp;
|
|
import java.io.IOException;
|
import java.lang.Thread.State;
|
import java.net.DatagramPacket;
|
import java.net.DatagramSocket;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Set;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import com.hxzkoa.json.tb_system;
|
import com.hxzkoa.json.tb_tag;
|
import com.hxzkoa.services.SysSettingService;
|
import com.hxzkoa.util.Config;
|
import com.hxzkoa.util.HttpUtil;
|
import com.hxzkoa.util.ModifyConfig;
|
|
import net.sf.json.JSONObject;
|
|
/** 该类用于接收UDP报文 */
|
public class Udp_Receive implements Runnable {
|
static DatagramSocket socket;
|
public static List<String> allMessage = new ArrayList<String>();
|
public static List<String> zhuceMessage = new ArrayList<String>();
|
public static List<String> debugMessage = new ArrayList<String>();
|
public static List<String> mysqlMessage = new ArrayList<String>();
|
public static List<String> hexMessage = new ArrayList<String>();
|
public static List<String> gasMessage = new ArrayList<String>();
|
public static List<String> tcpMessage = new ArrayList<String>();
|
public static List<String> yuanshiMessage = new ArrayList<String>();
|
public static List<String> udpMessage = new ArrayList<String>();
|
DatagramPacket packet;
|
int times = 5;
|
Thread t = new Thread(this);
|
|
|
/**
|
* 初始化对象
|
*
|
* @throws NumberFormatException
|
* @throws IOException
|
*/
|
public Udp_Receive(String udpPort) throws NumberFormatException, IOException {
|
socket = new DatagramSocket(Integer.parseInt(udpPort));
|
byte[] data = new byte[40960]; // 创建byte数组
|
packet = new DatagramPacket(data, data.length);
|
|
}
|
|
/** 启动线程的方法 */
|
public void startThread() {
|
t.start();
|
|
}
|
|
/** 停止线程的方法
|
* @throws InterruptedException */
|
public void stopThread() throws InterruptedException {
|
try {
|
Thread.sleep(2000);
|
t.interrupt();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
|
// /** 查看线程状态的方法 */
|
public State getState() {
|
State state = t.getState();
|
return state;
|
}
|
|
@SuppressWarnings("unused")
|
public void run() {
|
while (true) {
|
try {
|
//udp接收
|
socket.receive(packet); // 接收数据包
|
int lenth = packet.getLength();
|
byte[] byt = subBytes(packet.getData(), 0, lenth);
|
// // 获取发送端的IP地址对象
|
String ip = packet.getAddress().getHostAddress();
|
String datas = Tools.Bytes2HexString(byt);
|
String message = new String(packet.getData(), 0, lenth);
|
Date d = new Date();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
System.out.println(sdf.format(d));
|
System.out.println("message"+message);
|
|
//模拟接收
|
// String message = null;
|
// String datas=null;
|
// Thread.sleep(300);
|
// message = "$GNGGA,102319.60,3413.31707,N,10853.33826,E,2,12,0.97,443.6,M,-27.8,M,0.6,0654*4C,1002,41";
|
// byte[] byt = null;
|
// if ( (System.currentTimeMillis() % 100) == 10) {
|
// message = "display,64,1018,70,2020-12-14 13:08:33.479,0,648,367,150,32,0,0,1";
|
// datas = null;
|
// } else if ((System.currentTimeMillis() % 10) == 1){
|
// message = "$GNGGA,043310.44,3951.73773,N,11615.40420,E,4,12,0.71,53.0,M,-8.9,M,1.4,1935*41,1234,2d";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 2){
|
// message = "anchor_info,2,1000,1,1,1,0,0,1,1,127.0.0.1,v1,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() %10) == 10){
|
// message = "anchor_near,1, 1000, 1,2,3,4, 5, 6, 7,8, 1,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 4){
|
// message = "anchor_tongbu,1,1000,1001,1,0,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 5){
|
// message = "tag_info,1,1001,1,0,0,0,0,v1,0,0,0,0,0,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 6){
|
// message = "hxzk_heart,1,0,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 7){
|
// message = "gas_colector,1,0,0,1,127.1.1.0,0,0,0,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 8){
|
// message = "gas_sensor,0,0,0,0,0,0,0,0,0,0,0";
|
// datas = null;
|
// }else if ((System.currentTimeMillis() % 10) == 9){
|
// message = "01 03 48 00 08 00 00 00 00 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 08 2A";
|
// datas = "01 03 48 00 08 00 00 00 00 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 00 00 00 03 BF 80 00 00 08 2A";
|
// message=message.replace(" ", "");
|
// datas=datas.replace(" ", "");
|
// }else if ((System.currentTimeMillis() % 10) == 0){
|
// message = "55 AA 0A 14 19 98 13 10 05 15 02 01 1E 02 00 0A 00 53 85 94 FC 00 5E FC";
|
// datas = "55 AA 0A 14 19 98 13 10 05 15 02 01 1E 02 00 0A 00 53 85 94 FC 00 5E FC";
|
// message=message.replace(" ", "");
|
// datas=datas.replace(" ", "");
|
// }else if ((System.currentTimeMillis() % 10) == 3){
|
// message = "55 AA 02 0C 18 98 01 0000000000000040FF";
|
// datas = "55 AA 02 0C 18 98 01 0000000000000040FF";
|
// message=message.replace(" ", "");
|
// datas=datas.replace(" ", "");
|
// }
|
// String ip = "127.0.0.1";
|
// System.out.println("message"+message);
|
|
//报文处理
|
String BaowenPath = Config.getBaowenConfig();
|
System.out.println("baowenswitch"+ModifyConfig.readData(BaowenPath, "baowenSwitch"));
|
String baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch");
|
String baowenContent = ModifyConfig.readData(BaowenPath, "allMessage");
|
if(message!=null){
|
//
|
// int lenth = message.length();
|
String messageJson = GetNowTime.timestamp2()+ " 收：" +message;
|
if (baowenStatus.equals("1")){
|
Udp_Receive.allMessage.add(messageJson);
|
}
|
|
// 处理以display开头的数据
|
if (message.startsWith("display")) {
|
// Baowen_Receive.insert(message);
|
// //定位数据转发
|
Transfer_Receive.insert(message);
|
Dell_display.display(message);
|
} else if (message.startsWith("anchor_info")) {
|
// Baowen_Receive.insert(message);
|
// Anchor_info.anchor_info(message);
|
} else if (message.startsWith("anchor_near")) {
|
// Baowen_Receive.insert(message);
|
// Anchor_near.anchor_near(message);
|
} else if (message.startsWith("anchor_tongbu")) {
|
// Baowen_Receive.insert(message);
|
// Anchor_tongbu.anchor_tongbu(message);
|
} else if (message.startsWith("tag_info")) {
|
// Baowen_Receive.insert(message);
|
// Tag_info.tag_info(message);
|
} else if (message.startsWith("hxzk_heart")) {
|
// Baowen_Receive.insert(message);
|
// Hxzk_heart.hxzk_heart(message);
|
} else if (message.startsWith("get_anchor_info")) {
|
// Baowen_Receive.insert(message);
|
// Anchor_info.get_anchor_info(message);
|
} else if (message.startsWith("get_anchor_nearinfo")) {
|
// Baowen_Receive.insert(message);
|
// Anchor_near.get_anchor_nearinfo(message);
|
} else if(message.startsWith("get_taginfo")){
|
// Baowen_Receive.insert(message);
|
// Tag_info.get_tag_info(message);
|
} else if (message.startsWith("gas_colector")) {
|
// Baowen_Receive.insert(message);
|
// gasCollector.collector(message);
|
} else if (message.startsWith("gas_sensor")) {
|
// Baowen_Receive.insert(message);
|
// gasSensor.sensor(message);
|
} else if (message.startsWith("$GNGGA")) {
|
//定位数据转发
|
Transfer_Receive.insert(message);
|
// Gps_Receive.insert(message);
|
Dell_GNGGA.dell_gps(message);
|
} else if (message.startsWith("status2")) {
|
// String AnchorPath = Config.getAnchorConfig();
|
// ModifyConfig.writeData(AnchorPath, "huceju", message);
|
}else if (message.startsWith("SOS")) {
|
//转发
|
Transfer_Receive.insert(message);
|
}else {
|
// String time=GetNowTime.timestamp2();
|
// int timestamp=GetNowTime.timestamp();
|
// //原始数据转发
|
// Transfer_Receive.insert(message);
|
// // 原始报文
|
// String hex = datas.toUpperCase();
|
// // 如果是合法的55AA01数据
|
// if (hex.startsWith("55AA01") && lenth == 42) {
|
// Yuanshi_Receive.insert(hex, ip);
|
// }
|
// // 如果是心跳包
|
// if (hex.startsWith("55AA02") && lenth == 32) {
|
// Yuanshi_Receive.insert(hex, ip);
|
// }
|
// // 如果是注册信息
|
// if (hex.startsWith("55AA0A") && lenth == 48) {
|
// // 调用处理注册信息的方法
|
// Zhuce_Receive.insert(hex, ip);
|
// // 处理返回的读取配置信息成功
|
// }
|
// if (hex.startsWith("55AA03") && lenth == 202) {
|
// Yuanshi_Receive.insert(hex, ip);
|
// }
|
// if(hex.startsWith("0103")|| hex.startsWith("0203")|| hex.startsWith("0303") ) {
|
// Gas_Receive.insert(hex, ip);
|
// }
|
}
|
}
|
|
//
|
// ip = null;
|
// message = null;
|
// byt = null;
|
// datas = null;
|
|
|
|
} catch (Exception e) {
|
e.printStackTrace(); // 输出异常信息
|
}
|
}
|
}
|
|
public static DatagramSocket getSocket() {
|
return socket;
|
}
|
|
public static byte[] subBytes(byte[] src, int begin, int count) {
|
byte[] bs = new byte[count];
|
System.arraycopy(src, begin, bs, 0, count);
|
return bs;
|
}
|
|
public static void main(String[] args) {
|
|
}
|
}
|
