NetMQ发布订阅最新版本
NetMQ是一个基于ZeroMQ的开源消息传递库，它提供了高性能、可靠的消息传递机制。NetMQ发布订阅模式是其中的一种通信模式。
发布订阅模式是一种一对多的消息传递模式，其中一个消息发布者将消息发送给多个订阅者。发布者和订阅者之间通过一个称为消息代理的中间件进行通信。在NetMQ中，消息代理可以是一个独立的进程或线程，也可以是同一个进程中的不同组件。
NetMQ发布订阅模式的优势包括：
- 高性能：NetMQ使用ZeroMQ作为底层通信库，具有高性能和低延迟的特点，能够满足大规模消息传递的需求。
- 可靠性：NetMQ提供了可靠的消息传递机制，确保消息的可靠传递和顺序性。
- 灵活性：NetMQ支持动态的发布订阅关系，可以根据需求动态添加或移除订阅者，实现灵活的消息传递。
NetMQ发布订阅模式适用于以下场景：
- 实时数据传输：例如金融行情、股票交易等领域，需要将实时数据传输给多个订阅者。
- 分布式系统：在分布式系统中，不同组件之间需要进行消息传递和事件通知，发布订阅模式可以实现解耦和灵活性。
- 多播通信：当需要将消息广播给多个接收者时，发布订阅模式可以提供高效的多播通信机制。
腾讯云提供了一系列与消息队列相关的产品，可以用于实现发布订阅模式，例如：
- 云消息队列CMQ：腾讯云消息队列CMQ是一种高可用、高可靠、高性能的分布式消息队列服务，支持发布订阅模式，可以实现消息的可靠传递和顺序性。
- 云原生消息队列TDMQ：腾讯云原生消息队列TDMQ是一种高性能、低延迟、高可靠的分布式消息队列服务，支持发布订阅模式，适用于大规模消息传递场景。
你可以通过以下链接了解更多关于腾讯云消息队列相关产品的信息：
- 云消息队列CMQ：https://cloud.tencent.com/product/cmq
- 云原生消息队列TDMQ：https://cloud.tencent.com/product/tdmq
请注意，以上答案仅供参考，具体产品选择还需根据实际需求和情况进行评估。
相关·内容
2回答
我试图在本地网络上的不同计算机上进行程序间的消息传递。该设计基本上是一个“服务器”，“多个”客户端，服务器向客户端发送消息，从客户端接收消息，客户端从服务器接收消息，彼此之间发送/接收客户端消息。
我正在尝试使用NetMQ来实现这一点，但我在网络上使用它时遇到了困难。我可以在一台机器上很好地运行服务器和客户端程序，但我不知道如何让它在网络上工作，而且我找不到任何NetMQ示例来显示这一点--为了明确的是，我可以找到的每个示例都使用"localhost“或其他IP地址---- "publisher”和"subscriber“(我使用的是Pub模式，但不管在示例中使用的模式
浏览 3提问于2019-07-13得票数 2
回答已采纳
1回答
在典型的pub sub模式中，有一些客户端订阅发布事件的服务器。在我的应用程序中，发布者持续发布异步到来的事件。在我的客户中，他们有时会在处理这些事件时出现延迟。我的问题是，是否有一种解决办法，即客户端总是采用发布者发出的最新事件，而不是必须按顺序处理所有接收到的事件。
浏览 31提问于2016-07-25得票数 0
回答已采纳
我正在尝试决定使用哪种技术来将我的实时市场数据传播到我的交易策略中。场景如下所示，
我有多个交易策略订阅不同的报价器，当收到某些报价器的市场数据时，我会将这个报价器的市场数据广播给策略。监听交易策略将根据收到的市场数据采取行动。
我有两种类型的实现，
1)使用事件总线，如mvvmlight提供的Messenger类，
2)另一种方式是使用消息队列系统，如ZeroMQ(NetMQ)
注意到市场数据api和交易策略都在同一台机器上，因此不涉及网络。
哪一个更适合我的情况？
浏览 0提问于2015-05-18得票数 1
我找不到任何说明如何在PollTimeout中使用NetMQ的文档。它可以用于检测发送或接收超时吗？万一可以，怎么做？
浏览 4提问于2015-08-17得票数 2
回答已采纳
我对ZeroMQ相当陌生，并且一直在比较使用ZeroMQ NuGet包和NetMQ & NetMQ Security NuGet包的消息安全性。
到目前为止，我还没有找到使用曲线安全性的Ironhouse示例的C#版本。在ZGuides回购上有一个"todo“项，但是到目前为止还没有实现。()
我还试图确定NetMQ.Security安全方法是否比内置在ZeroMQ 4中的曲线安全方法更好。似乎大多数关于曲线的信息至少是从2014年或更早开始的。
如有任何信息，将不胜感激！
浏览 5提问于2017-10-13得票数 9
回答已采纳
环境
生产中的操作系统: Windows XP SP3
IDE: Microsoft Visual Studio 2013终极版
目标框架：.NET框架3.5
NetMQ: 3.3.1
AsyncIO: 0.1.18
语言: C#
我们需要在Windows上使用简单的REP套接字运行NetMQ应用程序。我们从第412号问题中了解到，在Windows上运行时，我们需要在使用AsyncIO.ForceDotNet.Force()之前调用NetMQ ()。
在我们开始运行应用程序一段时间(~ 3分钟)之后，由于我们每秒发送大量消息(每5毫秒1条消息或每秒12,000条
浏览 9提问于2016-06-24得票数 1
回答已采纳
我创建了两个简单的C#控制台项目(.net 4.5.2)，将v4.0.0.1 NetMQ Nuget包添加到每个项目中，将每个程序加载到单独的Visual Studio2017社区版中，在OnReceiveReady回调方法中包含的一行上设置断点，首先启动订阅者程序，然后启动发布者程序。订阅服务器中未触发ReceieveReady事件。我做错了什么？即使我选择了subSocket.Subscribe("")，我仍然没有收到任何消息。此外，删除/修改发送/接收HighWatermarks也不会改变事情。谢谢你的帮忙!
以下是发布器代码：
using System;
using N
浏览 56提问于2017-06-24得票数 3
我正在尝试用python中的NetMQ向C#传递消息。
python充当订阅者，C#充当发布者。
当我使用C# .Net核心时，我可以看到消息到达C#订阅者，但当我使用python UWP时，什么也没有发生，尽管代码完全相同，并且我可以看到Publisher正在发送消息。
python中的代码：(工作中)
import zmq
import time
def subscribe():
port = "6789"
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.co
浏览 27提问于2019-02-21得票数 3
在NetMQ中发布/订阅时，如何接收字节。
我正在尝试使用来自byte[] ReceiveFrameBytes()的扩展ReceivingSocketExtensions，但我只是看不到intellisense。
我使用的是NetMQ，它是扩展的容器名称空间。我正在使用Nuget NetMq包(不确定它是否相关-我假设它与github版本相同)
namespace WhoCares
{
using NetMQ; // the extension are in this namespace?
using System;
using System.Collectio
浏览 4提问于2015-08-28得票数 0
回答已采纳
我在订阅者读取下一帧之前简单地设置了延迟，所以我预计这将模拟慢订阅者，并给出一些HighWatermark选项的效果。我没有观察到任何东西，订阅者不会跳过(丢弃)任何消息，也不会减慢发布者的速度。我已经运行了1个发布者和x个订阅者。
我尝试使用一个取自documentation 的pub-sub示例
有什么方法可以检测到订阅者速度慢吗？我的意思是，要接收的排队消息数超过了HighWatermark值。我应该期待NetMqMonitor中的任何异常或事件吗？我也在寻找是否有一个选项，以断开如此缓慢的用户。
using System;
using System.Threading;
using N
浏览 48提问于2020-02-06得票数 0
回答已采纳
2回答
netMQ 4.0多线程
、、、、
基于netMQ 4.0的多线程服务器存在一些问题.我试着使用http://zguide.zeromq.org/cs:mtserver，但是netMQ 4.0上没有上下文。
我试过：
for (var i = 0; i < workerCount; ++i)
{
new Thread(() => Worker(connStr.Value)).Start();
}
//...
private void Worker(string connStr)
{
using (var socket = new DealerSocket(connStr))
{
浏览 2提问于2016-12-01得票数 1
回答已采纳
1回答
我一直在阅读关于ZeroMQ的更具体的关于NetMQ的文章，以及我看到的用于绑定发布者套接字的几乎每一个Pub/Sub示例，然后订阅者套接字连接到另一个。
所以我想知道是否有可能做相反的事情，我的意思是绑定订阅者套接字，然后发布者连接到它。
这有可能吗？(我在文档中没有发现任何明确的内容)使用这种连接策略有哪些缺点？
任何帮助都是有用的。
浏览 6提问于2015-04-20得票数 7
我认为这个问题确实说明了一切。
对于一些背景，我有一个订阅者，我正试图为其编写一些测试。为了做到这一点，我从测试中拆分了一个发布者，指定tcp://localhost:[port]作为地址。当消息被发送时，订阅者不会接收它。下面是一些要演示的示例代码：
string address = "tcp://localhost:1026";
// string address = "inproc://localhost1026";
var pubSocket = new PublisherSocket();
pubSocket.
浏览 0提问于2018-05-23得票数 1
1回答
在NetMQ中是否需要作为订阅服务器的顶部“锁定”？
我想是的，我在下面做这件事是否合适呢？
private void Subscribe()
{
using (var client = new SubscriberSocket())
{
client.Options.ReceiveHighWatermark = 1000;
client.Connect(Connection);
client.Subscribe(Key);
while (true)
浏览 2提问于2018-10-11得票数 0
回答已采纳
1回答
我使用NetMQ作为客户机/服务器通信，用于定价系统，使用Pub/Sub作为价格数据，使用Req/Res作为C&C。它运行得很好，只是我看到NetMQ库的内部出现了随机和不可复制的异常。
我目前正在WindowsServer2008R2/20012R2上的WindowsV4.7.2堆栈上使用NetMQ v4.0.1.6。
例外情况包括：
NetMQ.FaultException @ NetMQ.Msg.Close()System.ArgumentOutOfRangeException NetMQ.Core.Patterns.Utils.ArrayExtensions.Swap[]Sys
浏览 5提问于2021-03-16得票数 5
目前，我们正在开发GCP项目中的spring引导应用程序，它连接到同一个GCP项目中的PubSub端点，但也连接到另一个GCP项目中的PubSub端点。我想使用普通的spring组件，但是对于这些组件，我没有机会设置到第二个GCP项目的第二个PubSub连接。另外，如果我有一个服务帐户，使用PubSubTemplate对象，我就不可能在另一个项目中针对一个主题，而不是服务帐户中的当前主题。是实现/扩展PubSubAdmin/PubSubTemplate的唯一方法，还是也有类似于JPA数据库的多个连接和模板的解决方案？
亲切问候斯文
浏览 0提问于2019-08-01得票数 1
回答已采纳
2回答
几个月前，我选择.NET库来实现ZeroMQ通信，我对建议的库很少这一事实感到非常困惑。
与此同时，我学到了一些东西，所以我将在这里分享。也许有人会觉得这很有帮助。所以让我问问自己：
NetMQ和clrzmq有什么区别？
(虽然我会亲自回答这个问题，但如果其他人在这个问题上有经验的话-欢迎选择答案！)
浏览 7提问于2016-07-31得票数 6
回答已采纳
我想知道zmq是否已经解决了以下问题(或者)位于zmq之上的应用程序需要处理它。
1)向所有订阅者发布数据的中央发布者。这些数据本质上是静态的，类似于配置。可以在任何时间点修改数据。
2)多个订阅者订阅来自该发布者的消息。发布者可以在任何时间点加入。
3)如果数据发生变化，发布者应该只将差异发布到现有的订阅者。
4)如果订阅者稍后加入，发布者应将所有数据(当前配置)发布给新订阅者。
Zeromq指南建议遵循以下方法来解决慢Joiner综合征，但这并不能解决上述问题。
浏览 0提问于2013-05-04得票数 3
回答已采纳
我正在按照微软的指导来开发一个使用StreamingSubscription的应用程序。它可以工作，但我总是在下面的代码中得到一个System.ArgumentNullException。
ExchangeService srv = new ExchangeService(ExchangeVersion.Exchange2010_SP2);
//service.AutodiscoverUrl("xx.xx@xxxx.nl");
srv.Credentials = new WebCredentials("xxx", "x
浏览 0提问于2017-02-21得票数 1
2回答
我有一个类，它在构造时创建一个发布套接字，代码如下：
this.context = NetMQContext.Create();
this.pubSocket = this.context.CreatePublisherSocket();
var portNumber = this.installerSettings.PublisherPort;
this.pubSocket.Bind("tcp://127.0.0.1:" + portNumber);
使用messagePublishingServer.Publish(message)发送消息会执行：
this.pubSock
浏览 3提问于2015-10-26得票数 0
回答已采纳
我有一段时间一直试图在我的NextJS项目中使用打字本.我认为从打字本开始是最困难的，但不是:它的安装更加复杂。
我遵循了上所说的(创建一个新项目)。
以下是我所做的事情：
npx create-next-app --ts
cd test-nextts
npm run dev
这是我在npm run dev上遇到的错误
> test-nextts@0.1.0 dev
> next dev
ready - started server on 0.0.0.0:3000, url: http://localhost:3000
It looks like you're tryin
浏览 8提问于2022-04-12得票数 0
回答已采纳
我有两个业务域(DomainA和DomainB)，它们在不同的数据库(不同的服务器)中为自己的NServiceBus enpdpoints使用自己的SQL。
我的理解是，您可以通过路由器将消息从一个域发送/发布到另一个域。官方文档明确指出，它就是。出于重现的目的，我采用了更新和发布，并对其进行了修改，以便两个端点都使用SQL Server传输+ SQL持久性。
目标是从DomainA发布一条消息，并在DomainB中处理它。
DomainA (web应用程序)-没有路由器配置，因为它只发布用于演示的内容：
var endpointConfiguration = new EndpointConf
浏览 10提问于2019-07-10得票数 2
回答已采纳
我正在使用来自Powershell的NetMQ库，但一直收到以下异常。
环境
NetMQ Version: NetMQ.4.0.0.1
Operating System: Windows Server 2012
.NET Version: 4
我在PowerShell：$pubSocket = New-Object NetMQ.Sockets.ResponseSocket -Args ("@tcp://localhost:5556")中使用它，但是它抛出了以下异常：
New-Object : Exception calling ".ctor" wi
浏览 11提问于2017-03-16得票数 0
2回答
我正在尝试编写一个典型的股票交易程序，它接收来自netmq的股票代码/订单/交易，将流转换为IObservable，并在WPF前端显示它们。我尝试使用NetMQ阻塞ReceiveString (假设我期望得到一些字符串输入)来使用异步/等待，这样ReceiveString循环就不会阻塞主(UI)线程。由于我对C#还不熟悉，所以我在这篇文章中接受了Dave的回答：()，并试图写一些这样的例子：
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
浏览 1提问于2015-03-15得票数 3
回答已采纳
我尝试设置一个Arduino，它将一些消息发布到NodeJaS服务器，但我无法从中获得发布者名称。我搜索了文档，没有发现任何真正有用的东西。我在PubNub以PubNub.set_uuid(uuid);开头之前设置了一个UUID，但没有效果。应用程序只返回一个未定义的。我该如何设置它？
#include <ESP8266WiFi.h>
#define PubNub_BASE_CLIENT WiFiClient
#include <PubNub.h>
// Replace these with your WiFi network settings
const char*
浏览 0提问于2018-02-22得票数 2
1回答
O希望在SailsJS上使用带套接字的自定义方法。
new: function(req, res){
Talk.create({message: "text"}).exec(function created(err,created){
Talk.publishCreate(created);
res.send(created);
});
}
在客户端，我完全按照这里所描述的那样做：
publishCreate没有向客户端发送更新。我是不是漏掉了什么？
浏览 1提问于2014-07-25得票数 0
1回答
我用我的NetMQ实现创建了一个要点，因为我觉得在这里粘贴有点多：
如果我在.Net核心控制台应用程序中执行以下操作，则一切正常，并收到MessageReceived事件：
static void Main(string[] args)
{
_transportWithHost = new NetMqTransport(
"tcp://localhost:9990",
"tcp://localhost:9991",
true);
_transportWithHost.Start();
Co
浏览 5提问于2019-07-11得票数 4
我正在寻找一个良好的开源实现进程间消息总线，可能基于命名管道。
是否有值得推荐的(仍在积极维护的)建议？我的要求是
免费和开放源码(因此没有Tibco会议，也没有NServiceBus)
必须能够轻松地在不需要任何安装的情况下以非管理权限运行(因此不需要RabbitMQ)。
我知道WCF+NamedPipes在这方面是一个流行的选择，但我觉得我的应用程序的结构使得使用WCF越来越不方便，所以我想探索其他的选择。
我偶然发现了NetMQ.ReactiveExtensions，它在原则上看起来非常有趣，它使用Protobuf + NetMQ。但我不确定它到底有多可靠。乍一看，它为每条消息发送3部分
浏览 0提问于2017-10-03得票数 1
我一直试图运行一个逻辑逐步回归模型，使用有序的结果。因为我试图解释比例概率的假设，我的一些变量有不均匀的斜率。因此，在我的代码中，我同时指出了等斜率和非等斜率，但是我继续得到这个语法错误。
ERROR 22-322: Syntax error, expecting one of the following: ;, ABSFCONV, AGGREGATE, ALPHA, BACKWARD, BEST, BINWIDTH, BUILDRULE, CL,
CLODDS, CLPARM, CODING, CONVERGE, CORRB, COVB, CT, CTABLE,
浏览 13提问于2022-01-23得票数 0
回答已采纳
我在本地设置了WSO2应用程序接口，并将简单的HelloWorld应用程序接口添加到我的本地发布者中，引用此。然后，我在APIM管理控制台中创建了一个子租户。我启用了所有租户的订阅可用性，请参考此 (我确信我启用了，因为我可以在Publisher中看到选项)。我打开Devportal。在租户开发者门户列表中，我选择carbon.super (为了查看由超级租户管理员创建的HelloWorld应用程序接口)，然后使用我的子租户id和密码登录。我创建了我的应用程序并生成了密钥和密钥。然后，我订阅了由supertenant创建的HelloWorld应用程序接口。一切似乎都很正常。
我可以为上级管理员
浏览 17提问于2021-06-03得票数 0
我是Azure和MassTransit的新手，我正在尝试向队列发送一个简单的命令，然后让使用者使用该命令。我可以成功地发送消息，然后由我的使用者消费，但是我注意到也创建了一个相应的主题。我对此有点天真的理解是，主题只需要用于事件发布和订阅。
这就是我的IBus实例的设置，其中IMessageBus封装了MassTransit.IBus实例
public static IMessageBus CreateBusAndRegisterQueueConsumer<T>(string servicePath, string queueName, IComponentContext auto
浏览 0提问于2019-05-23得票数 2
回答已采纳
1回答
所以我想知道一个问题。假设发布者在上午10:00创建了一个主题，并立即开始在该主题上发布消息。它通知消费者主题的创建，然后他们在上午10:01订阅主题这些消费者不会在上午10:00 - 10:01之间收到发布者发送的消息因此，如果消息传递提供程序发现此主题没有活动订阅者来接收任何消息，它是否应该立即丢弃这些消息。我们是否可以提供一种订阅机制，通过该机制，消费者可以指定他们希望从哪个点接收消息，(例如，从主题开始或2011年12/25上午10:00太平洋标准时间等)
浏览 0提问于2012-09-05得票数 1
2回答
我设置了azure，创建了iot集线器、设备、主题和订阅。现在，我希望通过mqtt从python脚本发送一条消息，并以某种方式将其显示在azure页面上
def on_connect(client, userdata, flags, rc):
print ("Device connected with result code: " + str(rc))
def on_disconnect(client, userdata, rc):
print ("Device disconnected with result code: " + str(rc))
de
浏览 2提问于2018-05-25得票数 1
我正在尝试实现NetMQ发布/订阅模型，但是订阅者没有收到任何消息。这里到底出了什么问题？
private static void ServerTask()
{
using (var context = NetMQContext.Create())
{
using (var socket = context.CreateSubscriberSocket())
{
socket.Bind("tcp://10.120.19.109:5000");
浏览 19提问于2014-08-13得票数 3
1回答
我已经开始学习dojo，并且在的一个项目中遇到了非常奇怪的语法。
dojo.declare('app.services.Favorites', [ dojo.store.Memory ], {
constructor : function() {
this.inherited(arguments);
dojo.subscribe('/favorites/add', dojo.hitch(this, 'put'));
dojo.subscribe('/favorites/remove
浏览 3提问于2014-03-31得票数 0
在选择要发布的订阅后，我会得到一个红十字会(见下文)。我不能继续发布，没有错误，只有一个红十字会。我没有创建订阅，但我已被添加为用户，并指定了所有者的角色。我有另一个订阅(免费试用)，我可以发布到没有问题。红十字会是什么意思？
此外，我可以创建资源和使用帐户，没有问题，通过Azure门户网站。
浏览 4提问于2016-04-07得票数 0
回答已采纳
我有一个定期上传照片到GCS存储桶的应用程序。当这些照片上传时，我需要添加缩略图并进行一些分析。如何设置存储桶的通知？
浏览 0提问于2017-03-29得票数 7
是否有Server 2017订阅服务器可订阅Server 2012发布(运行Server 2016的分发服务器)？
谢谢
浏览 3提问于2017-11-10得票数 0
1回答
我想通过Redis分享一个国家，有以下要求：
解耦：解耦发布者和订阅者
单一所有权：每个状态由单个发布者设置
Push:一旦状态发生变化，必须立即通知相关订阅者
拉：一旦用户初始化，就应该立即提取相关状态
如果不需要推送，则pub\sub将是最优的
如果不需要推就需要拉，那么简单的redis键和值就会工作得很好。
支持所有需求的最佳设计模式是什么？
浏览 1提问于2013-09-24得票数 0
我有两个简单的组件，它们应该使用REQ/REP ZeroMQ模式相互通信。服务器(REP )是在Python中使用pyzmq实现的：
import zmq
def launch_server():
print "Launching server"
with zmq.Context.instance() as ctx:
socket = ctx.socket(zmq.REP)
socket.bind('tcp://127.0.0.1:5555')
while True:
m
浏览 1提问于2016-10-04得票数 2
回答已采纳
1回答
在概念层面上，订阅者可以以何种方式赶上它可能错过但需要在以后知道的事件。
例如，服务正在运行并订阅事件总线上的事件。当它感兴趣的事件到达时，它会更新其持久化数据以保持最新。然而，该服务由于某种原因而停止，并在一段时间后重新启动。在这次中断期间，它错过了一些已经发布的事件。
如何才能赶上这项服务？服务应该有兴趣迎头赶上，还是有其他方法可以实现最终的一致性？
浏览 0提问于2019-06-27得票数 1
回答已采纳
我想知道Server 2012复制发布服务器和一些Server 2005复制订阅服务器是否存在问题？
有人有微软提供的有关这方面的文件吗？
我这么问是因为我的一位同事一直告诉我们，这是行不通的。
它是否也是相反的呢？(2012 =订户& 2005 = Publisher)
谢谢扎尔科斯
浏览 4提问于2013-01-24得票数 3
我想使用CentOS。我已经习惯了RedHat9.x，但现在我想使用CentOS。但是我不知道什么CentOS版本相当于RedHat9.x？
浏览 0提问于2016-04-15得票数 1
回答已采纳
我试图将这个web应用程序部署到Azure，但在资源组‘xxxWebApiGroup’中资源'xxxWebApiDb‘的部署过程中遇到了错误: NoRegisteredProviderFound:没有为位置“北欧”找到注册的资源提供者，而为“服务器”类型找到API版本'2.0’。支持的api版本是'2014-01-01,2014-04-01,2014-04-01-预览‘。所支持的地点有:东北、东、韦斯特斯、南中央、eastus2、中央、北中心、东亚、东南、日本西部、日本东部、西部、巴西南部、东北、东北、中部、西部、南部、中部、西部、南部、南部、中部、西部、东南部、美洲大
浏览 3提问于2017-01-03得票数 4
回答已采纳
我正在运行以下命令：
New-AzureAffinityGroup -Name $AfGroup -Location $Location -Label $AfGroup -Description $AfGroup
但出现以下错误：
New-AzureAffinityGroup : Value cannot be null.
Parameter name: managementCertificate
我正在删除%appdata%\Windows Azure Powershell xml文件，然后添加azure帐户，但仍然收到相同的错误。
浏览 6提问于2014-08-21得票数 0
1回答
用户从我的应用程序向第三方API提出请求，而第三方API的限制是3 req/min。例如，当用户是一个没有问题的时候，就可以从控制器进行操作。我希望对所有用户的请求进行排队，并以适当的时间间隔发送它们。我不想以异步的方式这样做，而是想向用户展示一个进度条或旋转器。我试着用Sidekiq来完成它，但是在完成工作后呈现结果有一个问题(我的应用程序控制器试图在创建之前从DB获取记录)。如果这是一个标准的方法的话？
控制器
InitWorker.perform_async(current_user.id, params[:group][:domain], params[:group][:owner
浏览 2提问于2015-12-29得票数 1
1回答
请帮助我理解JMS中的持久订阅，我正在浏览这个链接，并看到了以下语句：
持久订阅者使用JMS提供程序保留的唯一标识注册持久订阅。具有相同标识的后续订阅服务器对象在前一个订阅服务器保留的状态下恢复订阅。如果持久订阅没有活动订阅服务器，JMS提供程序将保留订阅消息，直到订阅接收到消息或消息到期为止。
订阅服务器和持久订阅服务器是同时存在的两个不同对象吗？也请帮助我这些声明是什么意思？
浏览 2提问于2013-12-01得票数 12
回答已采纳
我有一个redis实例，它通过不同的主题发布消息。除了实现复杂的心跳机制(之所以复杂，因为如果消息未被使用，实例将在一段时间后停止发布消息)，是否有一种方法可以检查是否有人使用了pub？
例如，实例RedisServer向topic1和topic2发布消息。RedisClient1订阅topic1，RedisClient2订阅topic2。无论出于什么原因，当RedisClient2停止使用topic2的消息时，我希望RedisServer知道这一点，并决定何时停止向topic2发布消息。topic2消费的中断是不可预测的，因此我无法通知RedisServer停止/取消订阅。
我想，如果有一种
浏览 5提问于2015-02-02得票数 1
2回答
我有以下设置：
名为afterwards.One的One服务应该接收一个Bus.Send到它的ExecuteWorkflowByAttributeCommand，并发布WorkflowByAttributeExecuted "client“，它使用Bus.Send执行命令，并订阅WorkflowByAttributeExecuted消息。<code>F 211</code>
Handler看起来如下：
public void Handle(WorkflowByAttributeCommand message)
{
Message
浏览 4提问于2011-08-08得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
