rabbitmq开发记录

蔚落 2022-12-28 12:43 117阅读 0赞

1.定义一个绑定类

public interface SyncSchoolBinding {
    
        String OUTPUT = "school-plan-center-syncSchool-output";
        String INPUT = "school-plan-center-syncSchool-input";
    
        /**
         * 消息订阅
         *
         * @return 消息订阅
         */
        @Input(INPUT)
        SubscribableChannel input();
    
        /**
         * 通道
         *
         * @return 通道
         */
        @Output(OUTPUT)
        MessageChannel output();
    }

2.发送消息

@Autowired
    private SyncSchoolBinding syncSchoolBinding;
    
    syncSchoolBinding.output().send(MessageBuilder.withPayload(schoolDTO).build());

3.接收消息并处理

public class SyncSchoolHandlerImpl implements SyncSchoolHandler {
    
        @StreamListener(SyncSchoolBinding.INPUT)
        @Override
        public void listen(SchoolDTO schoolDTO) {
    	log.info("接收到的学校信息：{}",JSON.toJSONString(schoolDTO));
        }
    }

4.配置文件添加配置

spring.cloud.stream.bindings.school-plan-center-syncSchool-input.destination=school-plan-center-syncSchool
    spring.cloud.stream.bindings.school-plan-center-syncSchool-output.destination=school-plan-center-syncSchool
    spring.cloud.stream.bindings.school-plan-center-syncSchool-input.group=${spring.application.name}

5.启动类添加注解

@EnableBinding({SyncSchoolBinding.class,SyncTeacherBinding.class})

发表评论取消回复

表情：

评论列表（有 0 条评论，117人围观）

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot整合RabbitMQ学习记录

SpringBoot整合RabbitMQ学习记录 RabbitMQ简介交换机类型介绍 Direct Exchange： Topic

た入场券/ 2023年06月22日 13:46/ 0 赞/ 16 阅读

相关 rabbitmq开发记录

1.定义一个绑定类 public interface SyncSchoolBinding { String OUTPUT = "school

蔚落/ 2022年12月28日 12:43/ 0 赞/ 118 阅读

相关 rabbitmq 群集问题记录

生产环境中：有两套rabbitmq 集群，一套用于mqtt消息订阅与发布。由于服务器消息总是堆积两三十万，两台节点打算在加一台节点。现象：由于一直会堆积二

约定不等于承诺〃/ 2022年11月08日 14:24/ 0 赞/ 133 阅读

相关 rabbitmq使用记录

官网 [https://www.rabbitmq.com/][https_www.rabbitmq.com] 在官网上能找到遇到的所有问题，前提是英文能看懂。 Sp

迈不过友情╰/ 2022年11月06日 15:54/ 0 赞/ 191 阅读

相关 RabbitMQ 下载相关记录

1、RabbitMQ 下载地址：[https://www.rabbitmq.com/download.html][https_www.rabbitmq.com_download

向右看齐/ 2022年10月07日 13:52/ 0 赞/ 170 阅读

相关安装Rabbitmq记录

rabbitmq官网 [https://www.rabbitmq.com/install-rpm.html][https_www.rabbitmq.com_install-

╰半橙微兮°/ 2022年08月23日 04:55/ 0 赞/ 141 阅读

相关 RabbitMQ 问题记录

问题： com.rabbitmq.client.ShutdownSignalException: connection error; protocol method:

超、凢脫俗/ 2022年06月03日 10:36/ 0 赞/ 132 阅读

相关简单记录一下springboot+rabbitmq集成

1.Windows下安装RabbitMQ需要以下几个步骤 (1)：下载erlang，原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，下载地址：ht

Dear 丶/ 2022年05月08日 15:06/ 0 赞/ 157 阅读

相关 RabbitMQ 使用记录

目前的exchange的路由策略是：每个需要队列的服务独享一个队列（queue），消费者（consumer）采用ACK自动应答模式处理队列消息。如果需要新增一个队列服务，需

左手的ㄟ右手/ 2022年03月16日 15:54/ 0 赞/ 179 阅读

相关 windows下面安装RabbitMQ记录

[windows下安装 rabbitMQ 及操作常用命令][windows_ _ rabbitMQ] rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业

灰太狼/ 2022年01月07日 08:45/ 0 赞/ 239 阅读