腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(3333)
视频
沙龙
1
回答
Hazelcast
Pub-Sub
,
订阅
者
未
收到
消息
java
、
hazelcast
我遵循下面这个非常简单的示例:https://github.com/ardlema/
hazelcast
-pubsub/tree/master/src/main/java/org/ardlema/
hazelcast
ITopic<String> topic = hz.getTopic("topic"); } }
浏览 32
提问于2021-02-12
得票数 0
回答已采纳
1
回答
Redis在扩展微服务时进行
订阅
。如何只让其中一个处理请求?
docker
、
redis
、
microservices
、
load-balancing
、
publish-subscribe
我在我的api服务器中使用redis
订阅
。
收到
消息
时,所有副本都在处理已发布的
消息
。如何让其中三个副本停止处理
消息
,而只让其中一个副本处理
消息
。 提前感谢
浏览 62
提问于2020-10-25
得票数 0
回答已采纳
2
回答
NServiceBus:共享
消息
DLL
soa
、
messaging
、
nservicebus
、
distributed-system
我最近一直在研究NServiceBus,因为我认为
消息
传递将是减少系统之间依赖性的好方法。但是,给我留下深刻印象的第一件事是,
消息
发布
者
和所有
订阅
者
必须共享
消息
定义DLL。在这种情况下会发生什么?每当客户端记录发生更改时,它都会发布一条
消息
,其中包含名称和地址。这有十个
订阅
者
,它们在
收到
消息
时更新其数据的本地副本。 有一天,需求发生了变化,其中一个
订阅
者
也需要客户
浏览 0
提问于2011-08-04
得票数 1
回答已采纳
1
回答
ZeroMQ + NodeJs:
订阅
者
未接收的
消息
javascript
、
node.js
、
message
、
zeromq
、
publish-subscribe
我的发布
者
(zpub.js)在循环中发布,如下所示。this.sock.send([payload.t, JSON.stringify(payload.m, null, null)])} } 我将我的
订阅
服务器启动为所有
浏览 6
提问于2020-08-21
得票数 0
回答已采纳
1
回答
确保在第一个
订阅
者
完成Google
pub-sub
主题拉取后触发第二个
订阅
者
google-cloud-platform
、
google-cloud-functions
、
google-cloud-messaging
、
publish-subscribe
、
google-cloud-pubsub
我有两个
订阅
者
,即SUB1和SUB2的同一主题。两个
订阅
者
将从Topic中提取完全相同的
消息
。如何确保
订阅
者
'SUB2‘仅在SUB1从主题中拉出
消息
后才开始拉取
消息
。...my
PUB-SUB
来自谷歌云平台...
浏览 18
提问于2020-10-09
得票数 0
回答已采纳
1
回答
无法从另一个项目的pubsub主题/
订阅
拉取
消息
python
、
google-cloud-platform
、
google-cloud-pubsub
我的用例涉及从多个不同项目(例如(A、B、C) )中存在的多个发布
订阅
中读取(拉出)数据到另一个项目(例如D )。我阅读了
pub-sub
中的访问控制文档。之后,我尝试将项目A、B、C(具有发布
者
/
订阅
者
角色)的服务帐户绑定到项目D上存在的主题。之后,我尝试使用项目D中的"gcloud“命令从项目A中存在的
订阅
中提取
消息
("gcloud pubsub
订阅
拉入[SUBSCRIPTION_NAME_IN_PROJECT_A&qu
浏览 20
提问于2020-07-15
得票数 0
回答已采纳
3
回答
zeroMQ: zmq_recv()不工作
c++
、
zeromq
、
recv
我正在使用zeroMQ实现发送-recv
消息
.我用的模式是:酒吧-潜艇。 } zmq_ctx_destroy(context);}sending...sent<l 但是,在<
浏览 6
提问于2015-04-15
得票数 0
回答已采纳
2
回答
消费
者
可以充当生产
者
并将
消息
发送到RabbitMQ中的
消息
代理吗?
rabbitmq
、
distributed-system
我们是否可以在RabbitMQ中设计发布-
订阅
模式,其中消费
者
也可以充当生产
者
并将
消息
发送到
消息
代理?
pub-sub
with the same service
浏览 47
提问于2020-02-01
得票数 0
回答已采纳
1
回答
如何获得ZMQ_PUB服务的数据?
zeromq
、
publish-subscribe
发布服务器服务可以从外部源接收数据并将其发送给
订阅
服务器吗? 关于
PUB-SUB
套接字还有一件更重要的事情要知道:您不知道
订阅
者
何时开始接收
消息
。即使启动
订阅
服务器,等待一段时间,然后启动发布服务器,
订阅
服务器也始终会忽略发布服务器发送的第一条
消息
。这是因为当
订阅
服务器连接到发布服务器(需要较小但非零的时间)时,发布
者
可能已经在发送
浏览 1
提问于2018-02-12
得票数 1
回答已采纳
2
回答
多重处理vs gevent
python
、
multiprocessing
、
zeromq
、
gevent
、
pyzmq
目前我正在使用带有
pub-sub
模式的zeromq,我有一个工作者要发布,多个(8)
订阅
者
(都将
订阅
)相同的模式。在这种情况下,建议使用multiprocessing或gevent?
浏览 1
提问于2012-04-03
得票数 4
1
回答
google
订阅
同一
消息
的多个
订阅
者
google-cloud-platform
、
google-cloud-pubsub
、
event-driven
我有一个名为orders的主题,该主题将有一个名为orderPlacedSubscription的
订阅
--我有两个服务希望侦听此
订阅
的所有
消息
并执行不同的操作,因此我有paymentService和notificationService,paymentService将侦听由orderPlacedSubscription过滤的每条
消息
并处理支付,通知服务将侦听相同的
消息
并发送通知。我的问题
pub-sub
是否支持有两个与一个
订阅
相关的
订阅
者<
浏览 7
提问于2022-07-25
得票数 1
回答已采纳
1
回答
如何在使用
者
应用程序使用完
消息
后,从队列中删除主题的脉冲星
消息
?
java
、
spring
、
pulsar
我有一个应用程序,它使用脉冲星从生产
者
应用程序中消耗主题。我需要一个逻辑或某种配置来删除某个主题的队列中的
消息
,一旦它被我的使用
者
application.Whenever使用--我的使用
者
应用程序被重新启动--它会获取队列中的所有
消息
,甚至以前
收到
的
消息
。
浏览 5
提问于2022-08-17
得票数 0
回答已采纳
1
回答
如何配置google pubsub以使用队列机制?
java
、
publish-subscribe
、
google-cloud-pubsub
我使用Google
pub-sub
(java)作为pub和sub。这意味着如果发布
者
在
订阅
者
启动之前发送
消息
, 则
消息
不会丢失,并等待
订阅
者
获取。
浏览 16
提问于2017-07-03
得票数 0
1
回答
Android Firebase云
消息
:推送
消息
会丢失吗?
android
、
firebase
、
firebase-cloud-messaging
如果某个主题的
订阅
者
在向该主题/
订阅
者
发送推送通知时
未
联机,该主题/
订阅
者
的
消息
会丢失还是在联机时
收到
消息
?
浏览 2
提问于2016-10-18
得票数 0
回答已采纳
1
回答
XMPP PubSub通知是同时广播还是像队列一样广播?
xmpp
、
publish-subscribe
我想知道xmpp发布-
订阅
功能是同时向所有
订阅
者
发送通知(广播),还是在队列中发送通知,即逐个发送通知。我想知道我正在使用的
pub-sub
和jaxl类之间的区别,因为jaxl在队列中一次发送一个用户的推送
消息
。
浏览 0
提问于2009-08-18
得票数 3
回答已采纳
1
回答
主题到主题交流(Google cloud
pub-sub
)
google-cloud-pubsub
我需要从topic1向topic2发布一条
消息
。 我们是否可以使用topic1中的发布-
订阅
配置将
消息
直接发布到topic2,而无需使用任何编程语言编写任何代码,也无需创建任何
订阅
者
。总结:可以在Google Cloud
Pub-Sub
中直接在主题之间进行交流吗?
浏览 12
提问于2019-09-27
得票数 0
1
回答
视图中的开放会话如何与jms连接/会话一起工作?
hibernate
、
session
、
grails
、
jms
我们有一个grails应用程序,它接受http请求,并使用activemq将处理委托给
pub-sub
。由于http请求是在将
消息
发布到目的地后返回的,因此在发布之后,Open In View拦截器令牌是否立即关闭?当
订阅
者
开始处理来自activemq队列(这里的服务方法是
订阅
者
)的
消息
时,整个事务(在
订阅
服务器服务方法中有多个事务)是在一个会话中,还是使用hibernate模板策略为单个事务打开会话并在提交后关闭它如果是这样,对于单个jms
消息
浏览 1
提问于2017-01-26
得票数 1
回答已采纳
1
回答
ZeroMQ:指向
消息
关系的链接
c++
、
zeromq
我使用的是ZMQ的
Pub-Sub
模式。我知道可以将
订阅
者
连接到任意数量的发布
者
,以便使用ZMQ recv-function在一个套接字上接收所有发布
者
消息
。但是,我还需要通过哪个“链接”(例如ipc:/tmp/link.ipc)接收当前
收到
的
消息
的信息。 有没有办法从ZMQ
消息
中查询此信息?
浏览 19
提问于2021-04-16
得票数 0
回答已采纳
1
回答
如何在MassTransit中配置多个
消息
使用
者
?
c#
、
publish-subscribe
、
servicebus
、
masstransit
在我的环境中,
订阅
该事件的多个进程可以在同一计算机上运行。using System;{ }} 如果我运行此C#应用程序的多个实例,则只有一个实例会
收到
消息
浏览 2
提问于2012-08-09
得票数 6
2
回答
Google Pubsub -获取出队计数信息
google-cloud-platform
、
publish-subscribe
、
google-cloud-pubsub
我使用Google
Pub-Sub
服务,有一个
订阅
者
和一个发布
者
。代码是用C#编写的。发布
者
向“队列”插入
消息
,
订阅
者
运行后台代码来处理它。我经常发现我的代码有一个bug,导致我一次又一次地重试相同的
消息
。问题是,对于这些情况,结果是相同的- crash。我的想法是有一个"dequeue-count“属性来计数有多少生产
者
已经尝试解决这个特定的任务。如果这个数字更大,那么3-丢弃这个
消息
。
浏览 15
提问于2019-07-10
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
图解:消息传输的架构模式
聊聊kafka结构,kafka基础了解
“还以为我的手机坏了……”
Kafka之安装部署
基于OPC UA协议的服务端开发
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券