From 1d2b99ce88ff853ac8b84296b942c79bb649b6ee Mon Sep 17 00:00:00 2001
From: 于紫祥_1901 <email@yuzixiang_1910>
Date: Sat, 10 Oct 2020 11:01:10 +0800
Subject: [PATCH] 设备进行排序
---
src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java | 34 ++++++++++++++++++++++------------
1 files changed, 22 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java b/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
index 0579cad..9b42ef0 100644
--- a/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
+++ b/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
@@ -18,6 +18,7 @@
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.HashMap;
+import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@@ -60,6 +61,7 @@
private static Map<String, Sensor> sensors;
+
@PostConstruct
public void init() {
sensors = new HashMap<>();
@@ -92,22 +94,25 @@
paramMap.put("regionCode", regionCode);
ParameterUtils.getRegionType4RegionCode(paramMap);
List<Device> deviceList = deviceService.queryDevice(paramMap);
+ Map<String,Device> deviceMap = new HashMap<>();
try {
Connection connection = RabbitMQUtils.getConnection();
final Channel channel = connection.createChannel();
//������������������
String queue = channel.queueDeclare().getQueue();
-
//������������������������routingKey������������
String routingKey = "";
for (Device d : deviceList) {
+ deviceMap.put(d.getMac(),d);
routingKey = orgId + "." + d.getMac();
channel.queueBind(queue, exchange, routingKey);
}
+
+
//������������,���������������������
- channel.basicQos(1);//���������������������������
+ channel.basicQos(30);//���������������
channel.basicConsume(queue, false, new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
@@ -117,10 +122,10 @@
//���������������������������������������mac���������������������������������mac������������
if(mac!=null&&(!mac.equals(0)))
- sendDeviceInfo(message);
+ sendDeviceInfo(message,deviceMap);
//������������
- channel.basicAck(envelope.getDeliveryTag(), false);
+ channel.basicAck(envelope.getDeliveryTag(), true);
//������socket������������������
if (!webSocketMap.containsKey(accountId)) {
@@ -145,7 +150,6 @@
@OnMessage
public void onMessage(String message, Session session) {
if (!ObjectUtils.isEmpty(message)) {
- System.out.println(message);
Map<String, Object> map = JSON.parseObject(message);
this.mac = (String) map.get("mac");
}
@@ -194,22 +198,28 @@
* @Author: ���������
* @Date: 2020/9/30
*/
- private void sendDeviceInfo(Map<String, Object> param) {
+ private void sendDeviceInfo(Map<String, Object> param,Map<String,Device> deviceMap) {
String deviceMac = (String) param.get("mac");
if (mac.equals(deviceMac)) {
try {
- Map<String, Object> map = new HashMap<>();
+ Map<String,Object> sortMap = new LinkedHashMap<>();
+
+ //���������������������������������
+ Device device =deviceMap.get(mac);
+ sortMap.put("������",device.getName());
+ sortMap.put("������",device.getAddress());
+
+
+ //���������������������������������
param.forEach((key, value) -> {
Sensor sensor = sensors.get(key);
if (!ObjectUtils.isEmpty(sensor)) {
String unit = ObjectUtils.isEmpty(sensor.getUnit()) ? "" : (String) sensor.getUnit();
- map.put(sensor.getName(), value + unit);
+ sortMap.put(sensor.getName(), value + unit);
}
});
- String mac = (String) param.get("mac");
- map.put("mac", mac);
- map.put("flag",1);
- sendMessage(JSON.toJSONString(map));
+
+ sendMessage(JSON.toJSONString(sortMap));
} catch (IOException e) {
log.error("������mac������������������������");
}
--
Gitblit v1.8.0