对客户端隐藏Spring消息传递基础设施
是指在使用Spring框架进行开发时，通过封装和抽象，将底层的消息传递基础设施隐藏起来，使得开发者可以更加专注于业务逻辑的实现，而不需要过多关注底层的消息传递细节。
在Spring框架中，消息传递基础设施主要包括消息队列、消息中间件和消息传递模式等。通过隐藏这些基础设施，开发者可以更加方便地使用消息传递来实现异步通信、解耦和扩展性等需求。
优势：
- 解耦性：通过隐藏消息传递基础设施，客户端与具体的消息传递实现解耦，使得系统更加灵活和可扩展。
- 简化开发：开发者无需关注底层消息传递细节，可以更加专注于业务逻辑的实现，提高开发效率。
- 异步通信：通过消息传递，可以实现异步通信，提高系统的响应速度和吞吐量。
- 可靠性：消息传递基础设施通常具备高可靠性和可恢复性，可以保证消息的可靠传递。
应用场景：
- 分布式系统：在分布式系统中，通过隐藏消息传递基础设施，可以实现不同服务之间的异步通信和解耦。
- 高并发系统：通过消息传递，可以将请求异步处理，提高系统的并发能力。
- 事件驱动架构：通过消息传递，可以实现事件的发布和订阅，实现松耦合的系统架构。
推荐的腾讯云相关产品： 腾讯云提供了一系列与消息传递相关的产品和服务，以下是其中几个推荐的产品：
- 腾讯云消息队列 CMQ：提供高可靠、高可用的消息队列服务，支持消息的发布和订阅，适用于异步通信、解耦等场景。详情请参考：腾讯云消息队列 CMQ
- 腾讯云云函数 SCF：提供事件驱动的无服务器计算服务，可以与消息队列等服务结合使用，实现事件的触发和处理。详情请参考：腾讯云云函数 SCF
- 腾讯云物联网通信 IoT Hub：提供物联网设备与云端的双向通信服务，支持设备消息的发布和订阅，适用于物联网场景。详情请参考：腾讯云物联网通信 IoT Hub
相关·内容
1回答
我正在开发一个利用Spring进行消息传递和集成的服务。该服务有一个入站消息通道和一个出站消息通道，客户端可以使用该通道将控制信息发送给该服务，而该服务可以使用该通道将事件信息发送给感兴趣的客户端。 我希望在客户端位于不同的地址空间并使用消息传递技术(例如zeromq或AMQP)与服务通信的情况下，以及在客户端驻留在与服务相同的地址空间并使用基本POJO调用与服务进行通信的情况下，服务是可部署的。 在后一种情况下-客户端和服务在同一地址空间-对我来说，如何使用诸如MessagingGateway之类的东西来隐藏从客户端到服务的调用的消息传递基础结构对我来说已经足够清楚了。但是，对于我来说，如
浏览 37提问于2021-06-17得票数 0
回答已采纳
我在VPN中有一个Elasticsearch集群。
如果集群位于VPN之外的一个单独的服务器上，那么我的Spring应用程序如何安全地访问它，以及如何在Spring引导配置(application.yml/application.properties)中配置它？
我还希望应用程序能够以一种方式连接到集群i，这样如果我有两个主节点，而其中一个节点失败了，那么连接将保持完整。
浏览 0提问于2018-10-27得票数 0
回答已采纳
2回答
我需要实现一个拉动的消费者。我看到的大多数例子都是生产者向消费者推送消息；假设消费者总是在线的。我希望生产者将消息推送到队列，而消费者按照自己的计划使用这些消息。我的客户有一个非工作时间日历，不能在非工作时间处理请求。
我该如何在spring中配置它。
提亚
拉古
浏览 2提问于2011-05-17得票数 0
我有一个Spring应用程序，位于上游RabbitMQ代理和下游REST服务之间。它从上游代理中的队列中读取消息，并将数据从消息发送到下游的REST服务。
为了读取消息，我使用了@RabbitListener注释
我有定期检查休息服务的健康状况。如果它不可用，我想停止从RabbitMQ队列中读取消息。我觉得这可能需要定制RabbitListenerContainer，但我不确定这是否正确，也不确定从哪里开始
任何只在满足条件的情况下配置消息消耗的帮助都将不胜感激。
浏览 9提问于2022-10-03得票数 0
回答已采纳
在Kafka Streams + Spring Boot应用程序中配置(提供主机和端口信息)和访问交互式查询的惯用方式是什么？ 访问KafkaStreams实例以访问状态存储的正确方法是什么？ 我知道spring-cloud-stream中有InteractiveQueriesService，但我并不是只在Spring Boot中使用spring-kafka库。 谢谢
浏览 11提问于2020-10-17得票数 1
回答已采纳
Google消息传递与Firebase Cloud Messaging有什么区别？
浏览 20提问于2016-06-24得票数 0
我正在观察一种我无法解释的奇怪的行为。我的应用程序使用Spring访问ActiveMQ Artemis，并生成和使用工作正常的消息。
但是，当我尝试对我的应用程序正在监听的队列使用浏览时，如果消息计数大约低于1000，则无论是我的浏览调用还是Artemis管理控制台都不能枚举队列内容。对于更大的消息计数，或者当我停止队列侦听器时，它就可以工作了。为什么会发生这种事？
浏览 2提问于2019-07-03得票数 0
回答已采纳
应用程序数据流： JSon Messages-> Active MQ --> Spring -业务登录(将JSon转换为Java对象)-->将数据保存到目标DB ->DB。
问题：
Sprin-Xd在集群模式下运行，配置为Radis。
Spring从活动消息队列(AMQ)接收消息。因此，在AMQ中，信息已不再存在。现在，当使用某种业务逻辑处理此消息的容器之一突然下降时。在这种情况下-
Spring框架会自动重新处理特定的消息吗？这背后的机制是什么？
谢谢,
阿比
浏览 3提问于2015-03-02得票数 1
回答已采纳
当调用singleRequest时，如何自定义连接池使用的执行上下文？我简要地查看了代码，对singleRequest的调用导致消息被发送到PoolMasterActor，而消息又发送给池接口参与者。
每个连接是阻塞还是非阻塞？
连接池使用哪个上下文？(我希望确保我的HTTP请求不会阻塞所有线程)
浏览 3提问于2017-02-06得票数 5
我有一个主题和相应的订阅者以Spring的形式。我的问题与以下情况有关：
在主题上发布消息，订阅服务器开始处理该消息。如果在处理前一条消息时，另一条消息到达此主题，则假设订阅服务器繁忙或在处理前一条消息后将处理此邮件，新消息会丢失吗？
如果答案是第二条消息将在第一条消息之后处理，那么后续问题是这种行为是由代理处理，还是由订阅者来处理。
浏览 6提问于2015-10-06得票数 0
回答已采纳
3回答
我目前的项目是利用Spring，我们的架构师决定让Spring管理服务、存储库和工厂对象，而不是域对象。我们正在紧跟领域驱动设计。不为域对象使用spring的原因主要是spring只允许静态依赖注入。我所说的静态依赖注入是指依赖关系是在xml配置中指定的，它们被“冻结”了。
我可能错了，但我目前的理解是，尽管我的域只利用接口与对象通信，但spring的xml配置迫使我指定一个具体的依赖项。因此，所有具体的依赖项都必须在部署时解决。有时，这是不可行的。我们的大多数用例都是基于运行时数据或从最终用户接收到的消息注入特定类型的。
我们的大部分设计都遵循命令模式。因此，当我们收到命令时，我们想要构建我
浏览 2提问于2009-09-17得票数 14
3回答
我正在构建一个spring引导微服务，我有一些问题。
我有一个账户微型服务，一个支付微型服务，一个产品微型服务.在这些微服务中，有些请求有时需要使用邮件api、sms发送api或推送通知api。
我现在所做的是创建一个用于邮寄的微服务、用于发送sms的微服务和用于推送通知的微服务。
我似乎无法解决的是如何使这些微服务只在内部使用。例如，禁止用户直接调用邮件微服务。
在提出这个关于堆栈溢出的问题之前，我自欺欺人，为什么我不把发送sms的代码放在库中，而把发送电子邮件和推送通知的代码添加到微服务中。当一个微服务需要使用这些apis之一时，我会添加所需的库。例如，我创建了一个推送通知库，并将其添加到
浏览 5提问于2020-07-24得票数 4
回答已采纳
我需要帮助来解决gcp pub/sus的问题。我有一个进程，它向pubsub发送100条带有过滤器的消息，另一个应用程序(在spring boot中)接收这些消息。当spring boot应用程序从pubsub (而不是pull)接收消息时，处理100条消息，但进入进程时，接收更多消息，在不同的时间接收不同数量的消息，任意时间接收120条，另外140条，其他超过200条。我没有找到任何解决方案，这是我的代码：
@Bean
@ServiceActivator(inputChannel = "pubsubInputChannel")
public Messa
浏览 0提问于2019-06-11得票数 3
组播是每个以太网系统固有的吗？
我正在尝试做的是通过以太网向许多设备发送代码(而不必向每个设备发送相同的‘消息’)。我不熟悉多播系统的设计，所以如果这是一个愚蠢的问题，请原谅我。我确实知道有为使用多播保留的IP范围，但这是否意味着如果我将接收设备设置为这些IP，它们将全部接收相同的“消息”？
浏览 3提问于2012-06-26得票数 0
1回答
我有一个相对简单的要求编写一个windows服务，它执行以下任务，并希望使用一些关于最简单和最好的设计模式的建议。
从存储的proc的SQL server返回X行数
将每一行转换为消息并发送到TCP服务器。
发送完所有消息后，返回到步骤1。
需要存在一种机制，该机制检测TCP连接是否已进入半开放/关闭状态，例如在发送每批消息后发送消息和从服务器接收响应。如果没有响应返回，我们将需要重新连接和重新发送currect批。必须将消息传递给服务器。我们将把上一次轮询消息的ID存储在数据库中，这样，如果服务出于任何原因需要sto/crash/重新启动，我们就可以从中断的位置重新启动。
浏览 3提问于2014-05-26得票数 0
我正在使用GCM在android上创建一个聊天应用程序。我已经能够从云中接收消息，并使用cURL通过PHP脚本手动发送它们。我可以简单地在每次用户发送消息时对此脚本进行HTTPRequest，但我想知道是否有方法可以删除此脚本，从而使android应用程序直接将消息发送到云。如果这是可能的，我也想知道这是不是“正确”的方法，或者HTTPRequest是否和它一样好。
提前谢谢。
浏览 3提问于2014-02-23得票数 0
我在实现MessageListener的自定义类中使用Spring2.5。如果在我的JmsException ()方法中抛出了一个onMessage，那么队列的状态会发生什么呢？
在调用onMessage时，队列是否认为消息是“传递”的？或者JmsException是否触发某种回滚，并将消息重新输入到队列中？
提前感谢！
浏览 3提问于2010-04-07得票数 17
1回答
JMS和Spring批处理
、、、、
我们的项目是集成两个应用程序，使用每个应用程序的rest，使用JMS (提供异步性质)和spring批处理从JMS队列读取大量数据，并对其进行处理，然后将其发送到接收应用程序。
我是JMS和spring batch的新手。我几乎没有什么基本问题要问：
-(PTP还是Pub/Sub)
可以从JMS批量读取消息(使用JMSItemReader)。如果是，请提供密码给任何人。
一旦消息被成功发布，我们希望将其确认为“阅读”(即。读取-进程-写入)接收应用程序，而不是当它被JMSItemReader读取时.我们如何才能做到这一点？
高层设计图如下所示
浏览 3提问于2015-10-07得票数 10
1回答
我正在尝试使用websockets在Android (将来也可能是webapp )中构建聊天应用程序。本项目的目的是熟悉websockets，了解websockets和实时应用程序。现在，我能够发送/广播消息给所有连接到运行在本地机器上的websocket服务器的客户端(Android)。我正在使用okhttp创建到nodejs websocket服务器的websocket连接。websocket服务器使用nodejs和ws实现。关闭所有套接字后，立即删除所有用户和消息。
基本上，我想要做的是能够在连接到websocket服务器之前对用户进行身份验证。我需要一个数据库，但还不确定是哪一个。我正
浏览 0提问于2020-06-14得票数 -1
。。或者在不呈现按钮的情况下登录？
Google docs展示的概述了如何创建Google登录按钮。在呈现按钮时，如果用户已经登录，我猜这意味着有一个有效的令牌可用，登录按钮将其文本切换为“登录”，并调用onSuccess回调。
这看起来有点草率，所以我想知道是否有一种方法可以以编程方式登录，并仅在用户尚未登录时呈现按钮。
我的最终目标是使用身份验证调用我的Google Cloud Endpoint后端方法。
浏览 2提问于2015-10-10得票数 1
我有一个关于Spring消息的问题:在处理过程中，我能够用一些特定的值更新字符串AMQP消息中的消息属性的标题。在此消息的DeadLettering之后，所有特定的标头都消失/删除。
这种行为正确吗？期待您的回复。你好，安东。
春季-兔子版:1.3.5 rabbit.version spring.version: 4.1.1 rabbit.version
浏览 2提问于2014-12-26得票数 0
回答已采纳
我正在使用javascript对消息进行加密和解密，并希望将结果消息发送到spring控制器mvc。
@RequestMapping(value = "/token")
public @ResponseBody String getAllBooks(@RequestParam boolean isAuth, @ModelAttribute("somedata") Token data) {
ModelAndView mav = new ModelAndView();
mav.addObject("encryptedToken",
浏览 1提问于2013-07-22得票数 2
1回答
我读到了春天云体系结构和技术(比如eureka，hystrix断路器)，因为您的一些微服务失败，所以可以防止应用程序停机。总之，spring建议使用作为所有微服务的入口点。因此，我想问自己，如何提供春云网关本身的容错性？正如我现在所看到的，如果这个入口点将失败，那么所有这些技术，如eureka和hystrix断路器都将不可用，因为它们是在spring云网关级别上实现的。现在，当spring云网关关闭时，所有客户端都无法访问spring云网关后面的所有服务。那么，如何处理这种情况呢？
浏览 0提问于2019-05-28得票数 1
回答已采纳
我们开发了一个spring-boot服务，它提供rest api (spring-webflux)并通过RabbitMQ (spring-rabbit)发送数据。该服务部署在cloud foundry上，我们在版本2.1.4中使用spring-boot。我们添加了spring-boot-starter- data -redis来使用redis缓存一些数据，我们得到了以下错误： [io.netty.util.ResourceLeakDetector] [] LEAK: HashedWheelTimer.release() was not called before it's garba
浏览 94提问于2019-04-16得票数 2
回答已采纳
1回答
我使用Spring和ActiveMQ。我想发送和接收来自一个主题的消息。效果很好。我的代码如下所示：
@RunWith(SpringRunner.class)
@SpringBootTest(classes = {
JmsSpike.TestListener1.class,
JmsSpike.TestListener2.class,
JmsSpike.Config.class
})
@TestPropertySource(properties = {
"spring.activemq.broker-url: tcp://l
浏览 1提问于2017-03-23得票数 1
回答已采纳
我想在我的应用程序中使用推送通知，其他事情，比如与我手动处理的服务器数据库同步，那么最好的选择是什么？
另外，我可以在FCM中使用GCM API密钥吗？
FCM对无限数量的消息是免费的吗？
浏览 1提问于2016-09-27得票数 0
1回答
使用spring集成的Kafka dsl，我想知道为什么侦听器不接收消息？但是，如果我用带有KafkaListener注释的方法替换，相同的应用程序可以很好地使用消息。我缺了什么DSL？
不消耗的DSL代码：
@Configuration
@EnableKafka
class KafkaConfig {
//consumer factory provided by Spring boot
@Bean
IntegrationFlow inboundKafkaEventFlow(ConsumerFactory consumerFactory) {
Integ
浏览 0提问于2019-07-01得票数 1
回答已采纳
1回答
从MQ侦听器通知客户端
、、、
我使用的是使用Spring的网络套接字。
这是我的控制器。一个简单的控制器，它接受一个结果对象，并返回一个带有填充值的结果对象。它将向STOMP主题订阅者发布消息"/ topic /update“。
@Controller
public class ReportController {
@MessageMapping("/charthandler")
@SendTo("/topic/update")
public Result pushMessage(Result r) throws Exception {
Th
浏览 3提问于2016-05-05得票数 3
回答已采纳
我只想问，现在有没有可能在不使用Firebase控制台的情况下在App Message中发送Firebase？我想在应用程序消息(FIAM)发送到安卓应用程序从.NET C# MVC Web应用程序。我成功地发送了推送通知(FCM)，但是在App Messaging中呢？有没有可用的API来做这件事？
浏览 18提问于2019-12-18得票数 0
回答已采纳
1回答
谷歌GCM还可用吗？
、、、
我正在尝试使用Phonegap构建和GCM创建一个简单的android推送通知应用程序。目前，我可以使用phonegap插件获取android的设备令牌，并将其存储在我的数据库中，没有任何问题。
我只需要知道我是否还可以使用GCM (Google云消息传递)还是我需要开始使用FCM (Firebase cloud Messaging)？
我在Google上找到的任何教程都是关于GCM的，他们都说要启用google控制台中google云消息部分下的'Auth & API‘。但是当我去我的谷歌控制台GCM，我没有看到任何类似的事情，一切似乎是关于FCM，这是令人沮丧的，当没有信息，
浏览 2提问于2016-09-25得票数 2
回答已采纳
我以前有过使用Spring框架和Flex的经验，但从来没有一起使用过。我正在启动一个新项目，希望使用Spring和Flex。我注意到有一些特殊的库。由于时间紧迫，我无法进行适当的评估，我希望StackOverflow社区能帮助我决定是否使用这个库。
问题如下：
在服务器端使用"Spring集成“与”普通BlazeDS集成“有什么优缺点？
Spring BlazeDS集成将大大加快开发速度吗？
是否存在通过使用引入的任何灵活性限制？还有什么要考虑的吗？
提前感谢！
浏览 7提问于2010-01-13得票数 6
回答已采纳
我已经进入了一个新的项目，作为唯一的“软件人员”，我欢迎并期待着对现有代码提出设计改进建议(代码刚刚脱离原型阶段，需要扩展到最终的可发布版本；加上添加功能)
代码有多个独立的组件，这些组件应该是协同运行的，但是每个组件都可以自己重新启动。他们通过几个手工编写的类在这些守护进程之间传递消息，这些类用消息队列实现自己的服务器。它工作得很好，项目通过了原型阶段，虽然稳定性是他们最大的长期关注点之一，但它并不是众所周知的不稳定；只是不能完全达到最终发布的标准。不过，每当我看到代码时，我都会想到“我会使用JMS来完成这个任务。”如果我回到他们的实现日，我会告诉他们从一开始就用JMS来做这件事；现在我很想
浏览 0提问于2013-02-28得票数 1
回答已采纳
1回答
我有两个链接。在一个会话中，我存储一些数据。如果用户单击某个特定的链接查看会话，如果包含适当的值，我希望继续。否则会出现一个AJAX弹出块。
JAVASCRRIPT弹出块
function displaymessage(title,message,close)
{
resultReturn= $.confirm({
'title' : title,
'message' : message
'buttons' : {
close/*'Ye
浏览 3提问于2012-07-08得票数 1
3回答
使用Java应用程序(JSP/Servlet，没有EJB)，在不使用HttpSession的情况下，对用户进行身份验证和授权其操作的最佳方法是什么？
NB这个方法/问题的原因是我希望我们的应用程序保持无状态，所以我不需要在地理位置分散的数据中心中复制完整的会话，并且可以更容易地从集群中添加和删除服务器。
谢谢
浏览 10提问于2012-05-28得票数 1
回答已采纳
我正在尝试使用Spring boot和akka。我有两个进程，并与akka集群通信。只有进程A使用spring boot。
@Autowired
private ActorSystem springActorSystem;
@Autowired
private SpringExtension springExtension;
private ActorRef caActor;
caActor = springActorSystem.actorOf(springExtension.props("clientAgentActor"), "ca");
当然，如果我
浏览 0提问于2018-01-05得票数 1
我使用Spring jms将jms消息发送到websphere mq，在目标解析器上使用目标客户端as 1。但是，这会导致删除我为jms消息设置的所有自定义标头。当我将目标客户端设置为0时，它工作得很好，但出于其他原因，我需要将它保持在1。谁能解释一下这里发生了什么，以及一个可能的解决方案。谢谢。
浏览 2提问于2016-05-18得票数 1
4回答
我有一个JQuery函数，它在JSP中动态添加一个表：
$('#add').click(function(event) {
event.preventDefault();
$('.tabela_procurador').before
('<table id="tabela_nova' + i + '" class="tabela_nova"> ' +
'<tr> ' +
'<td col
浏览 0提问于2013-05-29得票数 8
回答已采纳
我正在尝试创建一个应用程序，该应用程序可以使用订阅外部遗留/非Spring服务器。我同时使用AbstractServerConnectionFactory和AbstractClientConnectionFactory。问题是，在发送启用订阅的消息之后，对于单个请求，我会收到多个回复(一个订阅回复，然后每x分钟接收一条包含订阅数据的消息)。@Gateway似乎不适合这种情况，因此我试图通过将TcpInboudGateway上的request通道和reply通道TcpOutboundGateway设置为相同的方式将答复重定向到@MessageEndpoint。这没有帮助，我无法摆脱的TcpOut
浏览 6提问于2020-05-31得票数 1
回答已采纳
1回答
我最近开发了一个带有Spring和Security的简单消息传递应用程序。该应用程序接收两个用户-用户A和用户B。一旦用户A执行了通知发送给用户B的特定任务。目前，我正在通过添加Spring消息依赖项和SockJS来做到这一点，而且它工作得很好。
这里是我困惑的地方，希望能得到一些指导。我意识到有许多关于RabbitMQ和ActiveMQ的教程。据我所知，他们是信息经纪人。我可以问一下SockJS和RabbitMQ/ActiveMQ之间有什么区别吗？在我的当前应用程序中是否需要RabbitMQ/ActiveMQ和SockJS？
浏览 0提问于2020-03-30得票数 0
回答已采纳
下面是使用Spring和Webphere进行消息传递的配置。
我需要为场景实现重试逻辑，其中我从队列接收消息，并将消息数据放到弹性搜索服务器(搜索服务器是非事务性的)，如果搜索服务器关闭，则必须再次将消息回滚到队列中，并在某个时间间隔(例如:30秒)后处理消息。这个重试必须做5次。消息被放入死信队列5次后，.we使用Tomcat作为服务器。
我们使用spring集成jms:消息驱动-通道适配器来接收消息。
如何使用spring和Websphere MQ实现此行为？
我已经爬过许多站点，我可以找到对Active MQ的支持，但不支持IBM。
<bean id="mqConnecti
浏览 0提问于2015-12-17得票数 3
回答已采纳
我在和android合作。我需要从我的服务器发送通知给选定的用户，所以，我必须集成Firebase Cloud消息传递或Google消息传递。
除了分析，FCM和GCM的确切区别是什么？我可以将FCM与我的服务器集成吗？
浏览 1提问于2016-07-12得票数 1
回答已采纳
2回答
我有一个分布式系统应用程序，它使用JBoss作为应用程序服务器。我有一个用作模拟引擎的客户端应用程序。当客户端启动时，它向服务器发送一条注册消息(JMS消息)，然后在数据库中设置一些字段。当服务器启动时，它会向所有客户端发送一条消息(主题)，以检查它们是否处于活动状态。如果客户端是活动的，它们可以读取消息并向服务器(队列)发送一个响应，表明它是活动的。
如果用户正常关闭客户端，客户端将向服务器发送一条消息，我将取消注册。然后服务器注销它。这是在数据库端完成的。
如果用户异常关闭客户端(Kill)，则客户端无法向服务器发送注销消息。那么服务器就不知道这个客户端已经不存在了。这会导致我的应用程序不
浏览 2提问于2017-03-30得票数 0
在带有VideoJS的Azure媒体服务中，我们正在创建Mainfest文件并在UI中显示视频，
我想隐藏Azure URL或使用不同的方式来显示视频，而不在前端显示Azure Cloud。
下面的URL来自Spring boot后端，
需要对客户端隐藏Azure端口，或者以任何其他方式将视频从springboot ressonce显示到Video.js，
代码：
const videoJsOptions = {
techOrder: ['html', 'youtube', 'flash', 'other supported tech
浏览 11提问于2021-07-19得票数 0
2回答
我有一个Azure运行第三方服务器进程。此服务器进程通过调用我给出的可执行文件通知我重要事件，并将一些数据作为命令行参数传入。
该数据需要由另一个工作人员排队和处理。
重要的是不要错过这些通知，所以我想知道：
(考虑到我的要求)，直接将消息排队到Azure服务总线是否可以接受？
或者我应该先排队到本地MSMQ，然后让另一个工作人员从MSMQ读取消息并将它们推入Azure服务总线？
谢谢
浏览 5提问于2014-03-06得票数 1
回答已采纳
1回答
我一直在阅读有关微服务的文章，并在Jonas Bonér的Reactive microservices Architecture (可从免费下载)中找到了许多有趣的建议。他强调了miroservices之间异步通信的必要性，但他表示，外部客户端的API有时需要同步(通常是REST)。
我一直在尝试思考如何最好地将从微服务发回的异步响应消息路由回等待的客户机。对我来说，最明显的方法是在处理请求时发送的所有消息中记录类似请求id的内容，然后将此id复制到服务发送的响应消息中。在最终将响应发送到客户端之前，公共API将在处理请求时阻塞，收集所有具有匹配id的预期响应消息。
我说对了吗？有没有更好的方
浏览 1提问于2016-09-21得票数 1
当When流量应用程序中存在一些内部异常时，我为什么要/需要编写代码来处理这些异常？我理解在服务客户端错误调用服务或非错误条件(即查询返回空游标等)时，如何处理问题并返回适当的ServerResponse主体。发生。
但是，除了将调试信息生成日志文件之外，滚动自己的异常处理组件还有什么可获得的吗？在一个单一的应用程序中，这种方法对我来说“更有意义”，在这个应用程序“刚刚死掉”的情况下，人们试图避免这种情况。
但是，对于服务实现，特别是如果有一些动机不向客户机公开过多的内部实现，为什么Spring的默认错误/异常处理(以及"500内部服务器错误“响应/消息)就不够了。
浏览 1提问于2019-09-17得票数 0
回答已采纳
1回答
我希望建立一个由通过NServiceBus通信的各种自主服务组成的系统。该系统将以不同的配置部署在客户端位置(某些服务可能会被排除，服务将以不同方式设置)。这些地点通常是大型仓库，不会有大规模的IT基础设施。这些服务可能都在一台机器上，也可能在许多不同的机器上；这对于每个站点来说可能是不同的。大多数站点都有一台活动的DB服务器(通常是SQL服务器)和一台备份服务器。网站将在不同的时间间隔对数据库进行定期备份--比如说每天。
每个服务都有自己的数据存储(这可以是一个真正独立的数据库或共享模式中的隔离表)。当然，每个服务也有自己的消息队列。尽管这些服务是自治的，但它们确实在本地存储来自其他服务的信
浏览 0提问于2013-06-26得票数 1
回答已采纳
1回答
我正试图为我们现有的基础设施创建一个合理的客户-客户-通信设置。我已经读了一个多星期的Spring、Websocket、STOMP、SockJS和ActiveMQ的文档，我不知道我想做的是可行还是明智。Spring服务器和JavaScript客户机的启动和运行相对较快，在客户端之间发送消息只有效(从JS客户端到Spring服务器的直接连接)。这个设置不足以满足我们的需要，所以我们决定在两者之间设置专门的经纪人。配置ActiveMQ可能是一场噩梦，因为我真的不知道从哪里开始。到目前为止，我还没有和专门的经纪人合作过。
环境
170独立服务器(Tomcat、Spring、SockJS、STOMP)
浏览 3提问于2021-03-05得票数 0
回答已采纳
1回答
我正在使用Spring MVC和Hibernate做一个项目，我还在学习它们。这是我的问题。我在BookInfo.jsp页面上创建了下表。
<table class="table table-bordered table-hover table-striped ">
<thead>
<tr>
<th>Book Id</th>
<th>Book price</th>
</tr>
</t
浏览 1提问于2015-06-25得票数 1
回答已采纳
我使用SpringBoot1.5.6 Kerberos 来使用Kerberos身份验证连接到Kafka 0.11。这些是我为Kafka使用的依赖关系：
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-kafka</artifactId>
<version>3.0.0.RELEASE</ver
浏览 4提问于2019-02-20得票数 3
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
