使用Spring云流媒体，如何将消息同步发送到binder？
我正在使用Spring与Azure事件中心和服务总线构建一个云流应用程序。在我的用例中，我试图实现以下功能：
- 从单个活页夹（事件中心）接收消息的应用程序
- 分几个步骤处理消息，例如步骤a、B、C
- 过程中的每一步都会创建对象
- 将每个步骤中创建的对象流到不同的绑定器。如果在任何步骤中发送消息失败，请不要继续
问题是，消息发送是同步还是异步？它会等到步骤A中发送的所有消息之后再执行下一步吗？
共有1个答案
-
如何使用新的Spring Cloud Stream Kafka功能模型发送消息？ 不推荐的方式是这样的。 但是我如何以函数式风格发送消息呢？ 应用yml公司 我会自动连接MessageChannel，但对于process、process-out-0、output或类似的东西，没有MessageChannel Bean。或者我可以用供应商Bean发送消息吗？谁能给我举个例子吗？谢谢！
-
如何在Kafka中发送同步消息 实现这一点的一种方法是设置properties参数 。 但是我想知道是否有一种甚至直接或替代的方式在Kafka中发送同步消息。（比如producer.sync发送（...）等等）。
-
在搜索文档之后，我找不到任何关于如何在没有使用外部服务器的情况下使用FCM向设备发送消息的信息。 例如，如果我正在创建一个聊天应用程序，我将需要向用户发送关于未读消息的推送通知，因为他们不会一直在线，而且我不可能在后台有一个始终连接到实时数据库的持久服务，因为这会占用太多资源。 那么当某个用户“B”向他/她发送聊天消息时，我将如何向用户“a”发送推送通知呢？我需要一个外部服务器来完成这个任务吗？还
-
嗨， 谢谢你，也很抱歉西班牙语的命名，我知道这让阅读代码变得有点困难。
-
我是Spring JMS的新手。我的应用程序是使用Spring Boot开发的，并部署在JBoss EAP7.2.0中。我有一个远程队列，它是一个活动的MQ Artemis队列，也嵌入在JBoss EAP7.2.0中。有人能建议我如何使用Spring Boot的JmsTemplate向远程JMS队列发送消息吗？基本上，我不知道应该如何定义远程connectionFactory来连接到远程队列。