腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(7968)
视频
沙龙
1
回答
Flowable.fromPublisher
需要
发布者
,
那么
它为
什么
要
接受
订阅
者
?
java
、
rx-java
、
reactive-programming
但是如果我写这段代码,它会以某种方式工作: Flowable<String> flowable =
Flowable.fromPublisher
(subscriber -> { subscriber.onNext
浏览 29
提问于2021-07-29
得票数 0
回答已采纳
3
回答
ACTIVEMQ -在publisher启动后,subscriber如何接收主题消息?
spring
、
jms
、
activemq
、
jmstemplate
在我的程序中,我有两个模块:-
发布者
和
订阅
者
,它们通过主题进行通信。 我理解为了通过
订阅
者
接收消息,它应该在
发布者
之前启动。但可能存在这样一种情况,即
订阅
者
由于某种原因而停机并
需要
重新启动。有没有
什么
方法,如果我在发布之后启动
订阅
服务器,
那么
它也应该能够接收消息?
浏览 0
提问于2012-10-22
得票数 4
回答已采纳
1
回答
Agora安全令牌生成(Golang)
security
、
go
、
privileges
、
agora.io
、
agora-web-sdk-ng
在生成令牌时,我们
需要
提供用户的角色。在Go API中有4种角色定义:与会
者
、
发布者
、
订阅
者
和管理人员。谢谢
浏览 3
提问于2020-06-25
得票数 0
回答已采纳
1
回答
在单机上部署nServiceBus的方法
nservicebus
我打算将每个逻辑
发布者
和
订阅
者
部署在它们自己的服务中(根据advice ),并让每个
发布者
和
订阅
者
都有自己的消息队列(我将使用)。然后,部署另一个
订阅
者
就像添加服务和队列一样简单。
要
删除它,只需删除服务和队列即可。使用这种方法有
什么
严重的问题
需要
我注意吗?
浏览 0
提问于2010-11-30
得票数 2
回答已采纳
1
回答
通过redis推拉共享状态
design-patterns
、
redis
、
publish-subscribe
我想通过Redis分享一个国家,有以下要求: 如果不
需要
推就
需要
拉,
那么
简单的redis键和值就会工作得很好。支持所有需求的最佳设计模式是
什么
?
浏览 1
提问于2013-09-24
得票数 0
1
回答
Google /Sub多主题v/s多
订阅
筛选器
google-cloud-platform
、
google-cloud-pubsub
在阅读文章时,我喜欢
订阅
过滤器的pub/sub功能。 我想要有一个有多个
订阅
的单一主题。多个
发布者
将向同一主题发布离散消息。每个
订阅
都将使用属性筛选器来提取特定于其需求的消息。有人知道使用pub/sub
订阅
过滤器的缺点吗?我应该继续使用这种单一主题的方法,还是为每种消息类型创建单独的主题?
浏览 4
提问于2022-07-11
得票数 3
回答已采纳
1
回答
NServiceBus -两个
发布者
,一个
订阅
者
,相同的消息接口
nservicebus
文档状态: “
订阅
服务器上的总线
订阅
发布服务器的方式是将消息发送到已在其部分中配置的队列。”我认为每个
订阅
者
必须包含一个指向每个
发布者
的端点(或队列)的MessageEndpointMapping,这些
发布者
可能会发布
订阅
者
处理的消息,这是正确的吗?如果是这样,
那么
如何为同一消息类型配置多个MessageEndpointMapping呢?不能有重复的值。假设
订阅
者
是一个FTP进程,它获取一个文件并将
浏览 3
提问于2012-08-04
得票数 2
回答已采纳
2
回答
让卡夫卡消费
者
在
订阅
前消费现有信息
apache-kafka
如果有
发布者
和N个使用
者
,如果消费
者
使用auto.offset.reset=latest,
那么
他们会错过在
订阅
主题之前发布到某个主题的所有消息.众所周知,使用auto.offset.reset=latest的消费
者
在
订阅
之前不会重播主题中存在的消息.所以我
需要
: 让发行者等到所有
订阅
者
开始使用消息,然后开始发布。不知道如何在不利用动物园管理员的情况下做到这一点。卡夫卡提供了这样做的手段吗?另一种方法是让auto.
浏览 2
提问于2016-06-14
得票数 1
1
回答
在这种情况下,项目反应堆将做
什么
?
project-reactor
在非常低的事务量环境(例如我们的一些测试环境)中,如果
订阅
者
请求处理N个新项目,但发行者当前
要
发送的新项少于N个,
那么
项目反应堆类将做
什么
。
发布者
(1)会立即发送少于N个新项目,(2)等待直到它要发送N个新项,还是(3)在发送少于N个新项之前等待可配置超时?我正在尝试解决一个问题,在这样一个非常低容量的环境中,这使我相信某种东西被卡在发布端,即使
订阅
者
应该定期请求批量工作。
浏览 1
提问于2022-04-18
得票数 0
回答已采纳
1
回答
面向微服务型用户的Azure服务总线主题及
订阅
设计
azure
、
azureservicebus
我正在研究如何使用Azure服务总线在我们的应用程序中发布/传递不同服务之间的消息,并试图在services命名空间中为主题和
订阅
找到一个不错的设计。任何
订阅
来自任何其他服务的事件的服务在本主题中创建一个
订阅
,使用筛选器获取他们想要的消息类型--每个消息类型一个
订阅
(例如。service-b-service-a-test-event)。服务总线命名空间每个
发布者
有一个主题(例如。events-service-a)。任何
订阅
该服务事件的服务都会在主题中创建一个
订阅</em
浏览 2
提问于2016-11-19
得票数 1
回答已采纳
3
回答
发布者
/
订阅
者
使用滑入有状态
c#
它造成了一些心理上的代码阻塞...如果这只是一个常见的陷阱,我不想继续这样做,但如果它是被
接受
的用法,我想继续,因为代码非常干净和解耦(除了横切消息)。我在代码中有一个基于列表的
发布者
/
订阅
者
模式,我使用它来允许任意代码段发送未知
订阅
者
可以监听的消息。相当简单。 对于此模式,我当前的一个用例是启动一个UI状态指示器,向用户显示应用程序正忙。这种用法是否违背了发布/
订阅
模式?如果是这样,问题是依赖于消息顺序吗?如果没有,
那么
很好,我可
浏览 0
提问于2012-02-15
得票数 2
回答已采纳
2
回答
如何在子服务器套接字关闭时使ZMQ发布客户端套接字缓冲区消息
java
、
sockets
、
kotlin
、
zeromq
、
jeromq
如果应用程序A正在使用发布服务器客户端将数据流到具有子服务器套接字以
接受
该数据的应用程序B,
那么
我们如何在应用程序A中配置发布客户端套接字,以便当B不可用(如重新部署、重新启动)时,A缓冲所有挂起的消息PUB客户端的默认行为是处于静默状态,但是如果我们可以将其更改为限制大小的缓冲区,
那么
zmq可以吗?还是我
需要
在应用程序层次上.我尝试过在我的套接字中设置HWM和LINGER,但是如果我没有错,它们只对缓慢的消费
者
情况负责,在这种情况下,我的
发布者
连接到
订阅
服务器,但是<
浏览 15
提问于2019-10-18
得票数 3
回答已采纳
3
回答
使用ZeroMQ进行反向发布/
订阅
的问题
linux
、
ipc
、
publish-subscribe
、
zeromq
我正在尝试用ZeroMQ设置“倒置”的发布/
订阅
。这意味着
订阅
(子)套接字属于多个长期存在的服务器,执行zmq_bind();而发布(PUB)套接字是一个短暂的客户端,执行zmq_connect()。问题是:只有一个
订阅
者
进程会收到消息。如果这个过程结束了,publisher就会被zmq_term()卡住。 zmq是否支持这种操作模式?如果是,
那么
我
浏览 1
提问于2011-04-23
得票数 6
回答已采纳
2
回答
NServiceBus,WCF架构
wcf
、
architecture
、
nservicebus
当然,如果服务宕机,我们的客户端就会开始收到错误,所有这些消息都会丢失(这也是我们
需要
ESB的原因之一)。客户端(
发布者
) -> NServiceBus处理程序(
订阅
者
) -> WCF服务客户端(
发布者
)
浏览 0
提问于2013-02-28
得票数 2
回答已采纳
1
回答
Google Cloud Kubernetes上任务队列的替代方案
go
、
google-cloud-platform
对于任务队列,
什么
是一个好的替代方案?推送队列是当前正在使用的队列。我在网上阅读了文档,也浏览了这个链接:When to use PubSub vs Task Queues,但对于发布/
订阅
是否是Kubernetes上的一个好选择,还没有明确的答案。编辑: 我目前的用例是,服务对一组ID和一些任务执行类似的任务,这些任务
需要
一些时间才能完成,因此队列将
接受
此任务并处理它,而服务可以并行执行其他任务。虽然发布/
订阅
主要是在我们这里有
发布者
和
订阅
浏览 11
提问于2019-02-14
得票数 2
1
回答
在combine中使用void @Published变量的正确方式是
什么
?
swift
、
combine
假设我有一个呈现ViewControllerB的ViewControllerA,并且我想
订阅
一个按钮点击。func buttonTapped() { }然后用sink在ViewControllerA中
订阅
浏览 0
提问于2021-04-14
得票数 0
2
回答
简论阿帕奇卡夫卡
bigdata
、
apache-kafka
它是用来干
什么
的?信息传递意味着
什么
?
什么
消息?!!在BigData分析的哪个阶段使用?PS:请像你为非技术人员解释的那样解释。
浏览 0
提问于2016-01-11
得票数 3
1
回答
nodejs mqtt客户端包收到消息后如何发送确认?
node.js
、
mqtt
在这里,我
需要
在收到消息后来自mqtt nodejs客户端的确认,以便从服务器队列中删除该消息。
浏览 68
提问于2019-09-25
得票数 0
回答已采纳
1
回答
如何处理和更新Actor系统中的共享散列映射?
spring-boot
、
akka
、
actor
嗨,我有元数据,HashMap对象,
需要
在我的Actor类中被访问,并且
需要
被查找。如果找到密钥,我应该在Actor业务逻辑中使用它。如果找不到,我
需要
创建一个键和值,并更新HashMap对象。
那么
如何在演员系统中处理这个问题呢?如您所知,每个参与
者
实例将同时生成一个未找到的键,这将导致重复和不恒定。
那么
,处理这种情况的行业标准是
什么
呢?请提供您的意见,如何处理它。
浏览 0
提问于2019-08-21
得票数 0
回答已采纳
3
回答
面试问题:事件处理程序中的异常
c#
、
.net
、
events
、
exception
1)您的.NET应用程序中的事件有10个
订阅
者
。一旦调用了事件,
订阅
者
是同步地还是异步地得到通知? 2)您的.NET应用程序中的某个事件有10个
订阅
者
。
浏览 12
提问于2011-02-20
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
推动数据设备信息化进程 勤哲Excel服务器发挥大作用
C#中的事件
什么是MQTT协议?
ROS 的一些基础知识
观察者模式VS发布-订阅模式
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券