messaging

-1热度

1回答

我是微服务的新手，但我想知道处理通信的最佳方式是什么。我已经研究过一些解决方案，但想知道你的意见是什么TODO：我的微服务托管在Azure上ATM和我称他们与REST服务，但是...... 我想的是，除了来自其他服务的服务不能从任何人调用，因为我有一个外部应用程序的外观API。我已经用RabbitMQ调查过Servicebus，Eventhubs，REST，WCF，SQL，但我不知道什么是

0热度

1回答

Spring引导和rabbitmq集成，如何恢复组件失败？

我有一个作为消息中间件的兔子春天休息的应用程序。当应用程序接受传入的休息请求时，它会回复用户，同时它会异步执行一些额外的处理，生成一条新消息并将其放在兔子身上。从那里，一些消费者阅读消息并将其传递给外部系统。现在，有一种情况是兔子服务器本身可能关闭。来处理这种失败的，我有一个阻塞队列（当然具有可调整大小） @Bean public TaskExecutor taskExecutor() {

0热度

1回答

通知不使用已安装应用程序的区域中的设备

我一直在研究一个想实现的想法（我已经写了一篇论文）。我提到的方法包括发送通知给安卓系统中的用户，而不是专门安装我的应用程序。首先，可能吗？其次，我研究了Firebase云消息传递 - 我知道它应该被绑定到应用程序，但是用户必须下载应用程序才是必要的吗？第三，有没有其他方法可以发送这种类型的推送通知？（根据地点）最后，如果您觉得我没有付出任何努力，我很抱歉。提前致谢。

-2热度

2回答

将消息发送到计算机断网蟒

我写的基于断码在此链接通讯软件： http://code.activestate.com/recipes/578802-send-messages-between-computers/ 我爱这个代码和它的作品很好，但它不会让我将消息发送到不在我的网络上的计算机。我想知道是否有办法修改此代码，以便我可以在任何地方向计算机发送消息。任何帮助或建议将是伟大的。

1热度

1回答

通信和高性能高可用性的Java EE数据的同步分布式应用

之前，我开始与我的问题，让我简要介绍一下该架构，我们需要使用：我们将有一个中央应用实例。这个应用程序实例部署与业务管理Web应用 - 它是用来改变“内部”数据（我会谈谈这一刻）这个应用程序实例实际上是服务器集群我们将有n个（n> 0 & &ñ< = 3000）本地应用程序实例 - 1对每个 “位置” 种这种情况下，作为数据处理器用于其位置这种情况下不使用全套中央数据 - 仅子集限于所

0热度

2回答

在微服务中广播消息并在多个实例中运行一次

我正在使用微服务，假设我有3个服务，并且它们都通过JGroup UDP通道相互连接（JGroups可以在它们之间广播消息）： --- --- --- | A | --msg--> | B || C | --- --- --- 如果我只有一个服务的实例，一切都很好。但是，例如，如果我有两个服务实例C，它们都会收到该事件，并且它们都将运行自己的过程，并且结果将在数据库中重复（总计两次）

0热度

1回答

是否有可能由JMS中的同一队列中的多个消费者使用？

我学习JMS，我知道有2种类型的通信： 1.队列 2主题我了解的话题，但我不明白的是它可以从同一个队列由两个不同的消费者阅读。我问起它，因为我知道它可能在amqp。让我们排队这样 tail -> |5|4|3|2|1|-> head 和下面的操作顺序： consumer_1阅读并得到了1 consumer_2阅读并得到了2 consumer_1阅读并得到了3 consumer_2阅读并获

1热度

1回答

无法从Twilio通道

删除CallbackListener。调用channel.removeAllListeners似乎只从Channel中删除ChannelListener。我下面贴什么，我试图做的一些代码，这里是对Twilio chat docs的链接。有任何想法吗？ CallbackListener<Long> callbackListener = new CallbackListener<Long>() {

0热度

2回答

akka是否自发地向自定义演员发送自己的消息？

我创建了一些演员，它应该用自己的消息包装所有传入的消息并进一步转发它们。不幸的是，我没有任何用户消息的公共基类，所以我打算用Object.class来捕捉它们。现在我不确定阿卡是否可以将自己的消息发送给演员。我不想偶尔转发一些发给我的封装演员的系统消息。

0热度

2回答

有了Spring Cloud Stream，我应该为每种事件类型配置频道吗？

我正在使用springboot，spring cloud netflix等构建一个项目来构建微服务。对于一些异步通信，我使用Spring Cloud Stream来生成和使用事件。例如在合同服务中起草商业合同后，服务会发布一个合同创建事件，由审计服务使用，以启动审计过程。此外，用户服务将消耗该事件来为相关方创建通知。该场景是我有很多事件，消费者将根据事件类型订阅感兴趣的事件。我遇到的问题是，