在Spring Cloud Stream中,你可以通过定义一个消息监听器(Message Listener)来消费自己生产的消息。这个监听器可以是一个方法注解如@StreamListener的POJO方法,或者是一个继承MessageListener的类。
以下是使用@StreamListener注解来消费消息的一个简单例子:
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;
 
@EnableBinding(Sink.class)
public class MessageConsumer {
 
    @StreamListener(Sink.INPUT)
    public void handleMessage(Message<?> message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message.getPayload());
    }
 
}在这个例子中,@EnableBinding(Sink.class)声明了一个消息接收器绑定到Sink通道,而@StreamListener(Sink.INPUT)注解标记了一个方法,该方法会监听Sink通道上的消息。每当接收到一个消息时,handleMessage方法就会被调用,并处理这个消息。
确保你的Spring Cloud Stream绑定器(如RabbitMQ或Kafka)正确配置,并且生产者和消费者使用相同的绑定器和通道。这样,消费者就可以接收到自己生产的消息了。