Spring Cloud Stream Binder 实现

  • 时间:
  • 浏览:2

1.增加Maven依赖

2.配置META-INF/spring.binders

3.原生API:生产消息

请注意启动后的控制台输出

5.实现Binder接口 - 实现消息消费

8.实现User消息监听

6.整合消息消费者- user-service-provider

引入 ActiveMQ Spring Cloud Stream Binder Maven 依赖

2.启动ActiveMQ broker

7.配置ActiveMQ Spring Cloud Stream Binder 属性

5.启动user-service-client

预先启动“eureka-server”以及“config-server”

6.改造user-service-provider:实现ActiveMQ User对象信息消费

4.改造user-service-client:实现ActiveMQ User对象消息生产

UserServiceClientController.java

2.配置ActiveMQ属性

application.properties

创建spring-cloud-stream-binder-activemq 工程

引入Maven

实现Binder接口-仅实现消息发送

3.配置JMS属性

application.properties

1.Maven依赖

4.配置ActiveMQ Spring Cloud Stream Binder 属性

3.整合消息生产者user-service-client

引入 ActiveMQ Spring Cloud Stream Binder Maven 依赖

4.原生API:消费消息