Spring Cloud Stream3.x中不推荐EnableBinding

Question

我用Kafka做一个微服务项目。每当我将记录保存到数据库时，我希望调用一个事件。我一直在看关于春云流的教程。它们都使用@enableBinding、@input、@output注释。当我试图使用它们时，它说它们是不推荐的。我使用的是spring InitialZR。发布说明说，我应该使用供应商、消费者和函数，而不是像输入、输出和过程这样的旧方法。

@Bean
public Supplier<String> toUpperCase() {
    return () -> {
        return "hello from supplier";
    };
}

当我使用这样的供应商时，它每秒钟都会生成消息，因为它也在教程中突出显示。我不想让它每秒钟都出版。我希望它在我想出版的时候出版。它说我应该调用它的get（）方法，但我不知道如何调用。教程使用不推荐的函数来实现这样的功能。我怎样才能在没有被否决的函数的情况下实现这样的行为，或者我怎样才能在不说它被否决的情况下使用EnableBinder注释？

Answer 1

您可以在https://github.com/habeebcycle/spring-cloud-stream-implemention查看我的演示项目的repo

它展示了如何使用RabbitMQ和Kafka为供应商和消费者实现云流，以及两个服务的端到端测试。

对于您的情况：在您的供应商bean中，执行如下操作：

@Bean
public Supplier<DataEvent<String, User>> savedMessage() {
    return () -> {
        return null;
    };
}

private final StreamBridge stream;
private final UserRepository repo;

// Store your topic/binding name as the supplier name as follows
private static final String SUPPLIER_BINDING_NAME = "savedMessage-out-0"

public UserService(UserRepository repo, StreamBridge stream) {
   this.repo = repo;
   this.stream = stream;
}

// Your save method
public void saveUser(User user) {
  // Do some checking...

  //save your record
  User user = repo.save(user);
  
  //check if user is saved or not null
  //create your message event (Assuming you have a DataEvent class)
  DataEvent<String, User> event = new DataEvent<>("User Saved", user);
  boolean sent = stream.send(SUPPLIER_BINDING_NAME, event));

  // Check the repo above for proper implementation.
}

您还可以在以下位置查看GitHub上的Spring最近的项目https://GitHub.com/spring-cloud/spring-cloud-stream-samples/