springcloudstream 3.X整合

最近开始整和springcloudstream 刚开始整合2.X 还能使用@Input、@Output 到了自己手写的时候就用了3.X 发现网上教程很少官网目前也是看不懂对新手还是蛮不友好所以决定发一篇博客

1、构建微服务

2、父pom导入依赖

    
        org.springframework.boot
        spring-boot-starter-parent
        2.5.5
    
    
    

        

            
                org.springframework.cloud
                spring-cloud-dependencies
                2020.0.4
                pom
                import

3、client pom导入依赖

微服务架构这边使用的eureka充当服务注册 eureka就不多赘述

    

        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-actuator
        

        
            org.springframework.cloud
            spring-cloud-starter-netflix-eureka-client
        
		
        
            org.springframework.cloud
            spring-cloud-starter-stream-rabbit

3.1、yml配置

这边注意如果是输出管道以 xxx-out-index 输入管道 xxx-in-index 详情请看官网

spring:
  application:
    name: stream-client8001
  cloud:
    stream:
      binders:
        defaultRabbit:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                addresses: 
                port: 5672
                username: 
                password: 
      bindings:
        msg-out-0: 
          destination: lyc-message

3.2 开始编码

这边就是接口实现一下

@Service
public class MqServiceImpl implements MqService {
	
	3.X以后导入这个 
	@Resource
	private StreamBridge streamBridge;

	@Override
	public void sendMessage(String message) {
		// send方法中第一个参数是bindingName 也就是 msg-out-0  个人习惯问题 写成了常量
		streamBridge.send(MyMessageChannel.MESSAGE_OUTPUT, message);
	}
}

3.2.1 写接口发请求

@RestController
public class MqController {

	private final MqService mqService;

	@GetMapping(value = "/{message}")
	public String sendMessage(@PathVariable("message") String message){
		mqService.sendMessage(message);
		return "ok";
	}

	public MqController(MqService mqService) {
		this.mqService = mqService;
	}
}

3.3、发送方搞定后就开始写接收方

pom和发送方是相同的 yml有一点区别前面那个是发送方所以是out 这边需要接收所以是in

spring:
  application:
    name: stream-client8002
  cloud:
    stream:
      binders:
        defaultRabbit:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                addresses: 
                port: 
                username: 
                password: 
      bindings:
        msg-in-0:
          destination: lyc-message

@Component
public class MyListener {

	// 方法名字  和 msg-in-0 前缀一致
	@Bean
	public Consumer msg() {
		return System.out::println;
	}
}

到这里就可以接收到消息了到这里只是能初步实现发送和接收可以初步参考
如果想要点到点和订阅可以尝试加入group

        msg-out-0:
          destination: lyc-message
          group

springcloudstream 3.X整合

Java相关栏目本月热门文章