SpringCloud Stream @EnableBinding注解过时

@EnableBinding源码中明确声明该注解在从3.1版本开始被弃用，推荐我们使用函数编程的方式我将给出一个生产者和消费者的使用案例：生产者案例：yml配置：server:port: 8801spring:application:name: cloud-stream-providerrabbitmq:host: 192.168.220.101port: 5672username: guestp

00发II

10371人浏览 · 2022-04-11 12:45:35

00发II · 2022-04-11 12:45:35 发布

@EnableBinding源码中明确声明

该注解在从3.1版本开始被弃用，推荐我们使用函数编程的方式

我将给出一个生产者和消费者的使用案例：

生产者案例：

yml配置：

server:
  port: 8801

spring:
  application:
    name: cloud-stream-provider
  rabbitmq:
    host: 192.168.220.101
    port: 5672
    username: guest
    password: guest
  cloud:
    stream:
      bindings: #服务的整合处理
        myChannel-out-0: #这个名字是一个通道的名字
          destination: studyExchange #表示要使用Exchange名称定义
          contentType: application/json #设置消息类型，本次为json，文本则设置为“text/plain”

注意bingdings 集合中的key由通道名-out/in-数字组成

service层代码：

package com.jx.springCloud.service.impl;

import com.jx.springCloud.service.MessageProvider;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.stereotype.Service;

import java.util.UUID;

/**
 * @author LDW
 * @date 2022/4/10 20:35
 */
@Service
public class MessageProviderImpl implements MessageProvider {

    private final StreamBridge streamBridge;

    public MessageProviderImpl(StreamBridge streamBridge) {
        this.streamBridge = streamBridge;
    }

    @Override
    public String send() {
        String serial = UUID.randomUUID().toString();
        streamBridge.send("myChannel-out-0", MessageBuilder.withPayload(serial).build());
        System.out.println("发送消息: " + serial);
        return null;
    }
}

@Autowire注解自动注入StreamBridge的实例，上述代码的写法省去了@Autowire注解

StreamBridge的send方法第一个参数是binding的名字，第二个参数是想要发送的消息

controller层代码：

@RestController
public class SendMessageController {

    private final MessageProvider messageProvider;

    public SendMessageController(MessageProvider messageProvider) {
        this.messageProvider = messageProvider;
    }

    @GetMapping("/sendMessage")
    public String sendMessage() {
        return messageProvider.send();
    }
}

消费者案例：

yml配置：

server:
  port: 8802

spring:
  application:
    name: cloud-stream-consumer
  rabbitmq:
    host: 192.168.220.101
    port: 5672
    username: guest
    password: guest
  cloud:
    stream:
      bindings: #服务的整合处理
        myChannel-in-0: #这个名字是一个通道的名字
          destination: studyExchange #表示要使用Exchange名称定义
          contentType: application/json #设置消息类型，本次为json，文本则设置为“text/plain”

service层代码：

@Service
@Slf4j
public class StreamConsumerService {
    @Bean
    public Consumer<String> myChannel() {
        return message -> log.info("消息："+message);
    }
}

上述代码的方法名（即Consumer的bean实例名）需要是yml配置中的通道名，应用程序启动后会自动接收生产者发送的消息

发送请求：localhost:8801/sendMessage