Parcourir la source

增加设备消息接口

lixing il y a 4 ans
Parent
commit
e7501d55b8

BIN
src/main/java/com/persagy/dmp/starter/alarm/.DS_Store


+ 40 - 0
src/main/java/com/persagy/dmp/starter/alarm/communication/mq/sender/InstanceObjMessageSender.java

@@ -0,0 +1,40 @@
+package com.persagy.dmp.starter.alarm.communication.mq.sender;
+
+import com.alibaba.fastjson.JSONObject;
+import com.persagy.dmp.starter.alarm.communication.mq.DmpMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * @description: 将消息放入mq
+ * @author: lixing
+ * @company: Persagy Technology Co.,Ltd
+ * @since: 2020/12/10 9:45 上午
+ * @version: V1.0
+ **/
+@Slf4j
+@Component
+public class InstanceObjMessageSender extends MessageSender {
+    @Value("${dmp.rwd.routingKey}")
+    private String routingKey;
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    /**
+     * @description: 发送消息
+     * @param: message
+     * @return: void
+     * @exception:
+     * @author: lixing
+     * @company: Persagy Technology Co.,Ltd
+     * @since: 2020/12/10 9:48 上午
+     * @version: V1.0
+     */
+    public void sendMessage(DmpMessage message) {
+        super.sendMessage(message, routingKey);
+    }
+}

+ 40 - 0
src/main/java/com/persagy/dmp/starter/alarm/communication/mq/sender/MessageSender.java

@@ -0,0 +1,40 @@
+package com.persagy.dmp.starter.alarm.communication.mq.sender;
+
+import com.alibaba.fastjson.JSONObject;
+import com.persagy.dmp.starter.alarm.communication.mq.DmpMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+
+/**
+ * @description: 将消息放入mq
+ * @author: lixing
+ * @company: Persagy Technology Co.,Ltd
+ * @since: 2020/12/10 9:45 上午
+ * @version: V1.0
+ **/
+@Slf4j
+public abstract class MessageSender {
+    @Value("${dmp.alarm.exchange}")
+    private String exchange;
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    /**
+     * @description: 发送消息
+     * @param: message
+     * @param: routingKey
+     * @return: void
+     * @exception:
+     * @author: lixing
+     * @company: Persagy Technology Co.,Ltd
+     * @since: 2020/12/10 9:48 上午
+     * @version: V1.0
+     */
+    public void sendMessage(DmpMessage message, String routingKey) {
+        log.info("向rabbitMQ发送消息,message:" + JSONObject.toJSON(message).toString());
+        rabbitTemplate.convertAndSend(exchange, routingKey, message);
+    }
+}