《stream》专题

使用spring cloud stream和RabbitMQ的配置： Exchange改为和队列改为。怎么修？

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

关于如何使用春云流实现同样的事情，有什么想法吗？

我有一个类具有以下签名： 我想将映射到在单个流中同时包含stringA和stringB的 或： 当然他们都不编译，但你明白了。 编辑： 示例：

我希望能够像这样使用Stream：：FlatMap 但我得到以下编译器错误 test.java：25：错误：不兼容类型：无法推断类型变量R ListofStrings.Stream（）.FlatMap（str->duplicate（str））.Collect（Collectors.ToList（））； 为什么这不是Java中flatMap的有效用法？

我一直在检查即将到来的，即:。是的，我很不耐烦，有很多新东西，但是，有些东西我不明白，一些简单的代码： javadocs是

我有以下几门课： 我有一个a的列表，我想将其转换为具有以下逻辑的映射： 在一行流方法中做它的最好方法是什么？ 谢谢Elad

考虑一个和方法。我想将s映射到s并获得第一个。显而易见的解决方案是使用，但要求返回一个流，而没有方法（或者它是或提供一个方法将其转换为，或将其作为)查看。 我能想出的最好的办法是： 但这似乎是一个很普通的案例，但却显得太冗长了。谁有更好的主意？

我已经创建了一种计算字母表中每个字符的方法。我正在学习流（函数式编程），并尝试尽可能经常地使用它们，但我不知道在这种情况下该怎么做：

我愿意使用https://github.com/awslabs/amazon-kinesis-video-streams-webrtc-sdk-js来访问KVSWebRTC用于我们的现场摄像机视频流。我想在从端口读取相机流(rtsp)的服务器上运行此代码。当我将这些代码移植到服务器端运行时（JS代码运行在NODEJS上），我了解到这些代码使用了很多用于access laptop Camera的浏览

下面的备选案文1或备选案文2是否正确（例如，其中一个优于另一个），或者它们是否等同？ 备选案文1 或 备选案文2

我可以让Spring+Rabbit以非功能性的方式工作（在2.0之前？），但我试图与功能性模式一起使用，因为以前的模式是不推荐的。 我一直在关注这个文档:https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_binding_and_binding_names 队列

我已经实现了如下所示的示例Spring Dynamic Destination 在rabbitmq中，它动态地创建一个交换，但没有提供绑定或路由密钥的选项。我的要求是用路由密钥向这个动态创建的exchange发送消息。我需要如何实现这一点来设置路由密钥？