From 8a16116027464d17e800cd070d256aff59350b7d Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 16 Nov 2020 15:50:32 +0800
Subject: [PATCH] 更改监测因子趋势图M
---
src/main/java/com/moral/webSocketServer/WebSocketServer.java | 23 ++---------------------
1 files changed, 2 insertions(+), 21 deletions(-)
diff --git a/src/main/java/com/moral/webSocketServer/WebSocketServer.java b/src/main/java/com/moral/webSocketServer/WebSocketServer.java
index f886cd2..a6654ed 100644
--- a/src/main/java/com/moral/webSocketServer/WebSocketServer.java
+++ b/src/main/java/com/moral/webSocketServer/WebSocketServer.java
@@ -84,14 +84,6 @@
try {
- //������������������������������������������������
- /*ConnectionFactory factory = new ConnectionFactory();
- //������MabbitMQ������������ip���������������
- factory.setHost("47.96.15.25");
- factory.setPort(5672);
- factory.setUsername("guest");
- factory.setPassword("guest_pass");*/
- //Connection connection = RabbitMQUtils.getConnection();
String routingKey;
this.connection = RabbitMQUtils.getConnection();
channel = this.connection.createChannel();
@@ -101,24 +93,13 @@
routingKey = orgId + "." + d.getMac();
channel.queueBind(QUEUE_NAME, "screens_data", routingKey);
}
- //���������������������
- /*java������������*/
- /*QueueingConsumer consumer = new QueueingConsumer(channel);
- //������������������
- channel.basicConsume(QUEUE_NAME, true, consumer);
-
- while (true) {
- //nextDelivery������������������������������������������������������������take���������
- QueueingConsumer.Delivery delivery = consumer.nextDelivery();
- String message = new String(delivery.getBody());
- sendMessage(message);
- }*/
+ channel.basicQos(30);//���������������
channel.basicConsume(QUEUE_NAME, false, new DefaultConsumer(channel){
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
String msg = new String(body, "utf-8");
sendMessage(msg);
- channel.basicAck(envelope.getDeliveryTag(), false);
+ channel.basicAck(envelope.getDeliveryTag(), true);
}
});
} catch (Exception e) {
--
Gitblit v1.8.0