package com.gk.hotwork.Scheduls.location;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.gk.hotwork.Config.Oauth2.IRedisService;
|
import com.gk.hotwork.Domain.Exception.BusinessException;
|
import org.apache.log4j.LogManager;
|
import org.apache.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import java.net.DatagramPacket;
|
import java.net.DatagramSocket;
|
import java.net.InetAddress;
|
import java.nio.charset.StandardCharsets;
|
import java.util.Base64;
|
|
|
//@Configuration
|
//@EnableScheduling
|
//@ConditionalOnProperty(prefix = "scheduling",name = "enabled",havingValue = "true")
|
public class LocationReceiver {
|
private Logger logger = LogManager.getLogger(getClass());
|
|
private boolean isopen = false;
|
|
@Value("${location.port}")
|
private int receiverPort;
|
@Autowired
|
private IRedisService redisService;
|
|
@Scheduled(initialDelay = 10000, fixedDelay = 30000)
|
public void start() {
|
if (isopen) {
|
return;
|
}
|
try {
|
isopen = true;
|
DatagramSocket server = new DatagramSocket(receiverPort);
|
// 2,准备接收容器
|
byte[] container = new byte[1024];
|
// 3,封装成包 new DatagramPacket(byte[] b,int length)
|
DatagramPacket receiver = new DatagramPacket(container, container.length);
|
logger.error("UDP服务端"+receiverPort+"已经开启,等待设备上报数据......");
|
while (true) {
|
try {
|
//服务器端接收来自客户端的数据
|
server.receive(receiver);
|
InetAddress address = receiver.getAddress();//获取发送端的 IP 对象
|
byte[] data = receiver.getData();//获取接收到的数据
|
int length = receiver.getLength();//获取具体收到数据的长度
|
String dataStr = new String(data, 0, length);
|
// handleData(dataStr);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
|
public void handleData(String dataStr) {
|
String content = "";
|
if (dataStr.startsWith("json")) {
|
//括号截取
|
int i = dataStr.indexOf("{");
|
int j = dataStr.lastIndexOf("}");
|
content = dataStr.substring(i, j + 1);
|
}
|
|
else if (dataStr.startsWith("base64-json")) {
|
//,分隔 第4个
|
String base64Content = dataStr.split(",")[3];
|
content = new String(Base64.getDecoder().decode(base64Content), StandardCharsets.UTF_8);
|
|
}
|
|
else{
|
throw new BusinessException("协议头对应不上");
|
}
|
|
JSONObject contentObj = JSONObject.parseObject(content);
|
String params = contentObj.getString("params");
|
String method = contentObj.getString("method");
|
|
//根据method判断处理方式
|
|
{
|
|
String standardMethod = method.toLowerCase();
|
if ("location".equals(standardMethod)) {
|
//DeviceLocation deviceLocation = JSONObject.parseObject(params, DeviceLocation.class);
|
String key = "device:location";
|
redisService.setDbIndex(1);
|
redisService.setExpiredTime(key,30*60);
|
redisService.rightPush(key, params);
|
}
|
if ("ping".equals(standardMethod)) {
|
//DevicePing devicePing = JSONObject.parseObject(params, DevicePing.class);
|
String key = "device:ping";
|
redisService.setDbIndex(2);
|
redisService.setExpiredTime(key,30*60);
|
redisService.rightPush(key, params);
|
}
|
if ("presskey".equals(standardMethod)) {
|
//DevicePressKey devicePressKey = JSONObject.parseObject(params, DevicePressKey.class);
|
String key = "device:presskey";
|
redisService.setDbIndex(3);
|
redisService.setExpiredTime(key,30*60);
|
redisService.rightPush(key, params);
|
}
|
|
}
|
}
|
|
|
|
|
|
|
|
|
|
|
}
|
