什么时候在应用启动时通过Spring Cloud Stream发送消息是安全的？

在应用启动时通过Spring Cloud Stream发送消息是安全的，当以下条件满足时：

应用启动时发送的消息不包含敏感信息：如果消息中包含敏感信息，如用户密码、个人身份证号码等，应避免在应用启动时发送，以防止信息泄露。
消息发送的目标是可靠的：确保消息的接收方在应用启动后能够正常接收和处理消息。如果接收方在应用启动时还未准备好接收消息，可能会导致消息丢失或处理失败。
消息发送的频率适中：如果应用启动时需要发送大量消息，可能会对系统的性能和稳定性产生负面影响。因此，应根据实际情况评估消息发送的频率，避免过度发送。
消息发送的内容符合业务需求：确保应用启动时发送的消息对业务流程有实际意义，能够帮助实现特定的功能或提供必要的信息。

总之，安全性是在应用启动时通过Spring Cloud Stream发送消息时需要考虑的重要因素。根据具体的业务需求和安全要求，合理评估消息发送的时机和内容，确保系统的安全性和稳定性。

带有兔子绑定的Spring云流-源/接收器队列名称不匹配

spring-cloud、spring-rabbit、spring-cloud-stream

最近，我开始使用和RabbitMQ绑定。如果当两个服务想要传递消息时，我正确地理解了一切，那么一个应该配置发送消息的源，另一个应该配置接收器来接收消息--两者都应该使用相同的通道。我有个频道叫testchannel。不过，我注意到该源代码创建了RabbitMQ绑定：交换testchannel，路由密钥testchannel 队列testchannel.default (持久的)，接收器创建了RabbitMQ绑定：交换testchannel，路由密钥# 队列testchannel.anonymous.RANDOM_ID (执行)。为了简洁起

浏览 3提问于2016-02-05得票数 3

回答已采纳

1回答

寻找一种SpringBoot Hystrix解释(SpringBoot启动器)的解决方案--启用安全性的Hystrix (作为它自己的项目)？

java、spring、spring-boot、microservices、hystrix

我的Hystrix仪表板启用应用程序：主修班：包装com.example.hystrixdemo； import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import org.springframework.cloud.netflix.hystrix.dashboard.Enabl

浏览 4提问于2019-11-25得票数 1

2回答

为什么spring cloud stream的@InboundChannelAdapter不接受任何参数？

spring、apache-kafka、spring-integration、spring-cloud、spring-cloud-stream

我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序 “使用@InboundChannelAdapter批注的方法不能接受任何参数” 我试着这样使用它： @InboundChannelAdapter(value = ChannelManager.OUTPUT) public EventCreated createCustomerEvent(String customerId, String thingId) { return new Even

浏览 0提问于2017-07-27得票数 0

3回答

对于银行应用程序，RESTful web服务是否足够安全？

spring、rest、soap、spring-security、ws-security

我将开发一个银行应用程序，将发送和接收信息到银行账户持有人的移动设备。我想使用Spring框架的REST api来实现这个目的。是否有使用RESTful api进行应用的银行？RESTful应用程序接口是否提供了足够的安全性来实现此目的？或者我应该坚持使用SOAP web服务？我知道，这个问题已经被问了好几次了。但我想集中讨论REST api在银行领域的可行性。

浏览 2提问于2015-03-30得票数 2

1回答

为什么Spring Cloud Stream会在重试次数耗尽后抛出MessagingException？

spring-cloud-stream

我有一个使用Spring Cloud Stream接收消息的消费者应用程序。我已配置重试和DLQ，但在超过重试次数后获取MessagingException。下面是我的配置： spring.cloud.stream.bindings.input.group = myProcessingGroup spring.cloud.stream.bindings.input.consumer.max-attempts=3 spring.cloud.stream.rabbit.bindings.input.consumer.auto-bind-dlq=true spring.cloud.stream.r

浏览 0提问于2019-08-26得票数 0

2回答

在重新部署业务流程时管理挂起/脱水的实例

biztalk、biztalk-2010、biztalk-orchestrations

场景： biztalk应用程序部署有接收端口、编排和发送端口。消息流正确。在某种程度上，编排中发现了一个bug，导致消息挂起。必须修复和重新部署编排。问题：因为您不能使用挂起的实例重新编写编排，您将如何保留这些消息、终止实例、重新部署，然后通过固定编排重新发送这些消息？是否有相应的流程或工具来完成此任务？

浏览 3提问于2012-10-27得票数 1

回答已采纳

1回答

无法使用spring云流kafka发送自定义标头

spring-boot、apache-kafka、spring-cloud、spring-cloud-stream、spring-cloud-stream-binder-kafka

我有两个用Java编写的微服务，使用Spring。，通过，在它们之间发送消息。我需要发送一个自定义头，但到目前为止没有成功。我在互联网和Spring 上已经阅读和尝试了大多数东西。 ..。不过，我还是无法使它发挥作用。这意味着我从未在接收方中接收到消息，因为无法找到标头，也不能为空。我怀疑标题从来没有写在消息中。现在我正试图用Kafkacat来验证这一点。任何帮助都将是wellcome 提前谢谢。 --信息这里是发件人代码： @SendTo("notifications") public void send(NotificationPayload payload, Str

浏览 5提问于2020-10-29得票数 0

1回答

春云流支持json标头？(在身体中)

apache-kafka、spring-cloud、spring-cloud-stream、amazon-kinesis

我们所有的消费者应用程序都使用spring-cloud-stream。但是我们的一个大型生产者应用程序(遗留.)不能使用spring-cloud-stream，因为春季引导版本是1.4。我们试图使用kinesis message发送消息。我们希望通过动态发送自定义的标题，但正如您所知道的，动态不支持发送标头。因此，我们决定在body中发送一个标头。 { "header": { ~~ } "payload": { ~~ } } 但是spring-cloud-stream无法在body中接收标头。我们认为我们可以在body中

浏览 0提问于2020-04-28得票数 0

回答已采纳

1回答

多应用下的Spring Cloud Stream DLQ、生产者和消费者

rabbitmq、spring-cloud-stream

我在应用程序A中有producer，配置如下，生产者属性： spring.cloud.stream.bindings.packageVersionUpdatesPublishChannel.destination=fabric-exchange spring.cloud.stream.bindings.packageVersionUpdatesPublishChannel.producer.requiredGroups=version-updates spring.cloud.stream.rabbit.bindings.packageVersionUpdatesPublis

浏览 1提问于2019-05-30得票数 0

1回答

我是否应该将世博会推送通知令牌视为敏感信息？如果是，我如何以安全的方式发送通知？

google-cloud-functions、expo、expo-notifications

在我的应用程序中，用户向某人发送消息后，会触发另一个功能通知接收者。为此，发送方必须拥有接收方的推送令牌(前端)。我的问题是:这样安全吗？有没有更好的方法？我正在使用Firebase，但我想不出通过Google函数发送通知的方法.

浏览 11提问于2022-03-15得票数 0

1回答

应用程序之间的文件传输

python-3.x、sftp、message-queue、messaging

我们正在构建一个Python应用程序来接收来自另一个应用程序的文件，处理接收到的文件并将处理后的文件发送回该应用程序。对于文件的传输，我们正在考虑选项SFTP和消息传递queue.Below是我们的要求。安全传输文件确认文件并通知发送者应用程序是否有任何故障负载平衡文件处理请求为了能够验证发送者应用程序发送的文件的状态考虑到这个场景，SFTP还是消息队列，您认为哪个更适合？我知道每个人都有自己的优点和缺点，但我也想了解一些东西是否被忽视了。

浏览 3提问于2018-06-05得票数 0

回答已采纳

1回答

如何用OutputDestination捕获特定于组的消息？

spring-boot、rabbitmq、integration-testing、spring-cloud、spring-cloud-stream

我们进行了集成测试，最终将多条消息发送到同一个目的地，但有许多不同的组。在rabbitMQ术语中，相同的交换具有不同的主题。 spring.cloud.stream.bindings.userEdited-out-0.destination=user.exchange spring.cloud.stream.rabbit.bindings.userEdited-out-0.producer.routing-key-expression='user-edited.v1' spring.cloud.stream.bindings.userEdited-out-0.content-t

浏览 4提问于2022-05-12得票数 1

回答已采纳

2回答

应用程序重新启动后，GlobalKTable是否会保留数据？

apache-kafka、apache-kafka-streams、spring-kafka、spring-cloud-stream

我正在使用Spring Cloud Streams，我有一个接收KStream和GlobalKTable的BiFunction。我不想在应用程序重新启动后丢失GlobalKTable数据，但这正是正在发生的事情。 @Bean public BiFunction<KStream<String, MyClass1>, GlobalKTable<String, MyClass2>, KStream<String, MyClass3>> process() { ... } 我还配置了"materializedAs“属性： spring.clou

浏览 3提问于2021-05-14得票数 0

2回答

消息JSON转换不起作用

java、json、spring-cloud-stream

我按照前面的问题和配置的流进行了描述，但是，我无法使它正确工作。我的设置如下。我有两个应用程序A和B。App A使用输入通道one，输出two。App B使用输入two。通道two配置为内容类型application/json。应用程序A.属性。 spring.cloud.stream.bindings.input.destination=one spring.cloud.stream.bindings.input.group=default spring.cloud.stream.bindings.output.destination=two spring.cloud.stream.b

浏览 0提问于2016-03-15得票数 3

回答已采纳

1回答

简单的消息传递应用程序，用户指定自己的密钥

encryption、decryption

如果我制作了一个简单的消息传递应用程序，它用一个带有密钥的算法对消息进行加密，用户在应用程序中键入密钥，然后将加密的消息发送给另一个用户，而不需要在任何地方存储任何内容，当接收者收到加密的消息时，他同样会输入密钥来加密消息。除了破解密钥外，还有什么办法监视这些消息吗？

浏览 0提问于2016-10-22得票数 1

2回答

如何防止应用程序实例接收重复消息？

spring-integration、spring-cloud-stream、idempotent

Spring 至少基于一次方法，这意味着在一些罕见的情况下，复制消息可以到达端点。是否保留了已经接收到的消息的缓冲区？企业集成模式()书中的建议:将接收方设计为幂等接收方，它可以安全地多次接收相同的消息。 Spring 是否控制使用者中的重复消息？更新：的一段话说： 4.5.1。与Stream的固执己见的应用模型相一致的持久性，使用者组订阅是持久的。也就是说，绑定器实现确保组订阅是持久的，并且一旦创建了组的至少一个订阅，组将接收消息，即使消息是在组中的所有应用程序停止时发送的。匿名订阅本质上是不持久的。对于某些绑定器实现(如RabbitMQ)，有可能具有非持久的组订阅。通常，在将应用

浏览 0提问于2019-03-14得票数 1

回答已采纳

1回答

SSL上的传输安全性和消息身份验证有什么区别？

java、web-services、ssl、wsit、transport-security

地铁WSIT的Transport Security和Message Authentication over SSL有什么区别？传输安全机制在传输期间保护应用程序，使用SSL进行身份验证和保密。 SSL上的消息身份验证机制将加密安全的标识或身份验证令牌与消息附加在一起，并使用SSL进行保密保护。

浏览 5提问于2011-05-05得票数 2

回答已采纳

1回答

在消费者端应用程序中没有接收到报头，使用kafka作为生产者和消费者端之间的中间件。

spring-boot、spring-cloud-stream、spring-kafka

我们已经实现了一个应用程序来生成消息和标题，并将其发送到kafka主题。消费者端应用程序正在聆听卡夫卡的主题。消费者端应用程序能够接收有效载荷，但是头不是received.Earlier，我们的头是在有效载荷属性中接收的。为了禁用将报头(包括contentType)嵌入到有效负载中，我们使用了 spring.cloud.stream.bindings.output.producer.headerMode=raw spring.cloud.stream.bindings.input.consumer.headerMode=raw 但是，我们无法在使用者端应用程序中接收报头。我们如何接收这些标头？

浏览 2提问于2019-05-08得票数 0

1回答

如何在自定义Google网络接收器应用程序中安全地存储密钥？

chromecast、google-cast、google-cast-sdk、caf-receiver-sdk

在我的自定义Web接收器Google应用程序中，我需要一些安全密钥，使应用程序能够正常工作。此密钥不应公开给任何用户。用户将通过iOS发件人应用程序启动和使用该应用程序。我想了两个主意，但我有安全考虑。第一个想法:简单地硬编码接收方源代码中的密钥我在这里看到的问题是，web接收器应用程序只是一个包含Cast框架的普通网页。因此，每个具有页面URL的人都可以在桌面浏览器中打开此网页，并查看源代码。如果有人知道URL并在浏览器中打开web应用程序，是否有任何选项可以隐藏这样的密钥？第二个想法:使用GCKCastChannel从iOS应用程序发送密钥因为iOS应用程序也安全地存储了这个密钥，

浏览 7提问于2022-09-15得票数 0

1回答

Spring Cloud Stream RabbitMQ多个接收器

java、spring、spring-boot、rabbitmq、spring-cloud-stream

我很难掌握RabbitMQ和Spring Cloud Stream如何协同工作的知识。我想做的是(基本解释)：我有一个生产者来产生消息，比如: SendEmail，ReceiveEmail和ErrorOccurred。这些将被发送到消息总线上。然后我有3个消费者。一个LogService、一个Emailservice和一个ParserService。 EmailService将拾取所有的Email消息，LogService将拾取ErrorOccurred (也由其他生产者生成)和EmailSend消息。最后，ParserService将只获得ReceiveEmail消息。我似乎不能用Spr

浏览 1提问于2018-10-11得票数 2