消息队列保存

guoshilong

2023-08-04 42d552cc4fcd9a91ae88104204155f4f33b863b8

消息队列保存

 skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java

@@ -1,5 +1,9 @@
package cn.gistack.nky.rabbitmq;

import cn.gistack.nky.entity.AlarmGet;
import cn.gistack.nky.service.IAlarmGetService;
import com.alibaba.fastjson.JSONObject;
import lombok.AllArgsConstructor;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@@ -11,10 +15,16 @@
 * @DATE: 2023/8/3 15:54
 */
@Component
@AllArgsConstructor
public class MyRabbitReceiver {
    private final IAlarmGetService alarmGetService;

    @RabbitListener(queues = "alarm")
    public void processMessage(Message message) {

        AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
        alarmGetService.save(alarmGet);

        System.out.println("收到消息"+new String(message.getBody()));
    }