实现基于Spring Cloud的事件驱动微服务

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
 
@EnableBinding(Sink.class)
public class EventDrivenService {
 
    @ServiceActivator(inputChannel = Sink.INPUT)
    public void handleMessage(String message) {
        // 这里可以添加处理接收到的消息的逻辑
        System.out.println("Received message: " + message);
    }
 
    // 发送消息的方法
    public void sendMessage(MessageChannel output, String payload) {
        output.send(MessageBuilder.withPayload(payload).build());
    }
}

这个简单的例子展示了如何在Spring Cloud中使用事件驱动的方式来接收和发送消息。@EnableBinding(Sink.class)注解指定了一个消息接收端点，@ServiceActivator(inputChannel = Sink.INPUT)注解指定了处理接收到的消息的方法。MessageChannel接口用于发送消息，MessageBuilder用于构建消息实例。这个例子提供了一个简单的参考，展示了如何将事件驱动的架构应用于微服务架构中。