如何在Google Pub/Sub中验证外部发布者？
在Google Pub/Sub中，可以通过使用身份验证和授权机制来验证外部发布者。以下是一种验证外部发布者的方法：
- 创建服务帐号：首先，您需要在Google Cloud Console中创建一个服务帐号。服务帐号是一个用于代表应用程序或服务进行身份验证和授权的实体。
- 生成密钥：创建服务帐号后，您可以为该服务帐号生成一个密钥。密钥将用于在发布消息时进行身份验证。
- 配置发布者身份验证：将生成的密钥配置到外部发布者应用程序中。这可以通过将密钥文件保存在应用程序的安全位置，并在发布消息时使用该密钥进行身份验证。
- 使用身份验证密钥发布消息：在发布消息时，外部发布者应用程序需要使用生成的密钥进行身份验证。可以使用Google提供的客户端库或API来实现这一点。
通过上述步骤，您可以在Google Pub/Sub中验证外部发布者的身份。这种验证机制可以确保只有经过授权的应用程序才能发布消息到Pub/Sub主题。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ。CMQ 是腾讯云提供的一种高可用、高可靠、高性能的分布式消息队列服务，适用于云计算、大数据、移动应用和物联网等场景。CMQ 提供了多种消息发布和订阅模式，同时支持消息持久化、消息重试、消息过滤等功能。
更多关于腾讯云消息队列 CMQ 的信息，请访问：腾讯云消息队列 CMQ
相关·内容
我正试图找到一种方法来保护我的google云应用程序引擎标准环境端点，它订阅了一个由创建google云存储文件触发的push pub/sub主题。
由于只能将IP地址设置为应用程序引擎的防火墙规则，而pub/sub没有预先定义的IP地址集，因此不可能使用此功能。也不可能在pub/sub调用上使用自定义头并检查其在应用程序引擎上的有效性，因为我无法控制pub/sub请求。
对于如何保护应用程序引擎端点有什么建议吗？
谢谢
浏览 0提问于2019-08-28得票数 0
回答已采纳
let p1: PassthroughSubject<Int, Never> = .init()
let p2: PassthroughSubject<Bool, Never> = .init()
var pub1: AnyPublisher<Int, Never> {
return p1.eraseToAnyPublisher()
}
var pub2: AnyPublisher<Bool, Never> {
return p2.eraseToAnyPublisher()
}
var sub: AnyCancellable
浏览 4提问于2022-06-02得票数 2
1回答
上下文：我们托管了一个在线商店，需要跟踪客户的行为。为了实现这一跟踪，我们已经集成了几个跟踪事件基于客户的旅行在我们的商店。根据欧洲的GDPR要求，我们被迫将跟踪事件发送到由我们作为公司控制的基础设施中。GDPR法律禁止通过直接向Google服务器发送数据。Sidenote:为了简化这个问题，我故意忽略了所有关于用户同意管理的内容。
问题陈述：我们需要每个客户端将每个跟踪事件直接从浏览器发送到Pub/Sub端点。现在，我的问题是，一个适当的安全的最佳实践将是什么样子。
当前建议： Pub/Sub端点不需要身份验证-> AllUsers已被授予Pub/Sub发布服务器权限。此外，我还创建了
浏览 2提问于2020-08-07得票数 0
我正在从事使用google进行消息传输的项目，我已经看到在pub Sub中创建的主题应该指定区域(如果我们定义了多个区域，消息将只存储在发布服务器的附近区域)。我对此有疑问。
在区域间是否存在用于存储消息的主题的复制。
Is订阅也存在于在主题上创建的任何区域。
浏览 4提问于2021-12-07得票数 0
我有一组运行openwrt linux的嵌入式设备，这些设备使用POST每3分钟发送数据(json)到URL。随着设备数量的增加，我想在对数据进行流式分析之前使用google pub/sub服务来处理这些数据
但是每次我试图发布一些东西到这个主题时，我都会得到这个错误：
POST https://pubsub.googleapis.com/v1/projects/myproject/topics/mytopic:publish
{ "error": { "code": 401, "message": "The request does
浏览 0提问于2016-05-30得票数 0
1回答
ZMQ发布/订阅
、、、
关于ZMQ的pub/sub功能，我很难弄清楚如何订阅一个特别的“频道”。
下面是发布者：
var zmq = require('zmq');
var pub = zmq.socket('pub');
pub.bindSync('tcp://127.0.0.1:5555');
setInterval(function(){
pub.send('pub msg');
},500);
下面是订阅者：
var sub = zmq.socket('sub');
sub.connect('tcp://1
浏览 2提问于2015-04-28得票数 4
回答已采纳
我想发布我的库，和以前一样，我已经在author文件中包含了pubspec名称。
运行flutter pub pub publish --dry-run会给我以下警告：
Warning: Your pubspec.yaml includes an "author" section which is no longer used and may be removed
我将授权我的出版使用电子邮件在我的作者价值。如果我移除它，我将如何授权。
我很感激能知道更多这件事。
浏览 5提问于2020-01-12得票数 4
回答已采纳
我想计数最后一小时的消息数量(最后一小时指消息数据中的一个时间戳字段)。
我目前有一段代码可以同步计算消息(我正在使用Google /Sub同步拉)，但我注意到这需要很长时间。
我的代码将反复轮询预定义的订阅次数(我将其设置为100+)，因此我确信在最后一小时内不会有更多的消息出现故障。
这是一个不可接受的设计，因为它意味着用户必须等待5-10分钟的服务，以计数消息时，他们想要的度量！
在Pub 设计中是否存在解决此类问题的最佳实践？
这似乎是一个简单的问题来解决(计算上一个X时间框架内的事件数量)，所以我想可能有。
异步设计会有帮助吗？异步设计将如何工作？我不太确定异步和Python的fut
浏览 1提问于2019-10-01得票数 1
我正在尝试实现类似于Figure 14 - Extended Pub-Sub 中描述的模型。 我已经看过这个snippet，它工作得很好。但在尝试实现第一部分时(即：{pub, ...} -> {xsub )，我在xsub套接字上没有接收到任何数据。 以下代码将永远阻塞，而不是接收消息： use zmq::{Context, SocketType::XSUB, PUB};
const ADDRESS_XSUB: &'static str = "tcp://127.0.0.1:9123";
fn main() {
let context = Co
浏览 65提问于2021-06-25得票数 0
回答已采纳
我在我的应用中使用了zeromq sub-pub模式，但我遇到了一个问题:我启动了sub应用并订阅了消息，然后启动了pub app，pub app在半小时或更长时间内不会发布任何消息，之后pub app会向sub-app发布pub消息，但是该子应用在那里被屏蔽，没有任何消息或一些消息丢失。
如果有人知道问题出在哪里？提前谢谢你。
浏览 8提问于2013-05-15得票数 0
我在很多地方都看到过这个错误，但是没有人回答过需要做些什么来修复它，或者为什么会发生这种错误。我希望我能有更好的运气。
ConsentInformation consentInformation = ConsentInformation.getInstance(getActivity());
String[] publisherIds = {"pub-**********~*******"};
consentInformation.requestConsentInfoUpdate(publisherIds, new ConsentInfoUpdateListener() {
浏览 0提问于2019-04-22得票数 8
2回答
使用导入scala.collection.mutable.{Publisher，Subscriber}我正在尝试实现一个订阅事件和发布事件的类。例如，这个类可以接收原始数据，对其进行操作，然后将结果发布给其他订阅者。
扩展Subscriber的基类：
scala> class Sub[Evt, Pub]() extends Subscriber[Evt, Pub]{
def notify(pub: Pub, evt: Evt){
}
}
defined class Sub
扩展Publisher的基类：
scala> class Pub[Evt]() extends Pub
浏览 0提问于2011-04-20得票数 2
回答已采纳
似乎XPUB/XSUB套接字类型存在一个很难处理的严重缺陷：
这是我的中心节点的实现：
#include <zmq.hpp>
int main()
{
zmq::context_t context(1);
//Incoming publications come here
zmq::socket_t sub(context, ZMQ_XSUB);
sub.bind("ipc://subscriber.ipc");
//Outgoing publications go out through here.
浏览 6提问于2017-03-30得票数 8
回答已采纳
在我当前的项目中，我们已经在使用Google发布/订阅: cloud.google.com/Pub_Sub 现在，我们还需要创建一个Chrome扩展，它将为(特定域的)每个url发送一些信息。扩展不需要接收任何东西。我想知道pub/sub是不是一个好主意？(这有可能吗？)或者我应该为此创建一个web服务。 如果可能的话，有人能给我介绍一下现有的应用程序吗？ 我是新来pub/sub的。
浏览 15提问于2019-09-17得票数 0
回答已采纳
我是GCP的新手，目前有一个使用GKE和gRPC的微服务架构。微服务正在将事件发布到Google Cloud Pub/Sub。我的Web-UI使用Google Cloud Endpoint向微服务发送请求。我想在网站上有很多实时/推送更新(例如实时更新，用户统计等)，现在想知道如何做得最好。让Web-UI订阅Google Cloud Pub/Sub中的主题是一种糟糕的做法吗？对于这种情况，GCP中是否还有其他更好的技术？
浏览 21提问于2019-01-21得票数 0
回答已采纳
我正试图在我的kubernetes集群上设置一个基本的NATS服务，根据他们的文档。我执行了以下代码：
$ helm install test-nats nats/nats
NAME: test-nats
LAST DEPLOYED: Thu Jul 14 13:18:09 2022
NAMESPACE: default
STATUS: deployed
REVISION: 1
NOTES:
You can find more information about running NATS on Kubernetes
in the NATS documentation website:
浏览 14提问于2022-07-14得票数 2
回答已采纳
我想玩和处理中的消息。在Pub/Sub中是否有任何公共数据提要可供我开始使用？
在Dataflow 示例中，输入是从，gs://dataflow-samples/shakespeare/kinglear.txt中的文件中读取的。似乎所有项目都可以访问dataflow-samples，这对启动非常方便。对于Pub/Sub有类似的东西吗？
浏览 0提问于2016-08-09得票数 5
回答已采纳
2回答
有一个服务器，它收集一些数据，然后将其发送到客户端。我需要确保客户端获得了服务器发送的数据。我认为这里的发布/订阅模式是最好的选择，但我不知道如何检查客户端是否获得了数据？我听说过一些关于可靠的PUB/SUB的事情，但是没有真正的例子。
有什么想法、建议、例子和帮助吗？
简单的发布者：
import zmq
context = zmq.Context()
server_socket = context.socket(zmq.PUB)
server_socket.bind('tcp://*:5559')
while True:
server_socket.send(
浏览 4提问于2013-04-29得票数 1
每秒大约90或100个呼叫
pubsub_client.projects().topics().publish(topic='projects/xxxx',body=body).execute(num_retries=0)
每秒从Google App Engine App到Google Cloud Pub/Sub，结果为
HttpError: <HttpError 429 when requesting https://pubsub.googleapis.com/v1/projects/xxxx:publish?alt=json returned "Request
浏览 0提问于2016-07-27得票数 0
1回答
根据ZeroMQ文档，当排队的消息数量达到高峰时，pub套接字就应该丢弃消息。
在下面的示例中，这似乎不起作用(是的，在绑定/连接之前设置了hwm )：
import time
import pickle
from threading import Thread
import zmq
ctx = zmq.Context()
def pub_thread():
pub = ctx.socket(zmq.PUB)
pub.set_hwm(2)
pub.bind('tcp://*:5555')
i = 0
while True:
浏览 2提问于2018-11-17得票数 2
我建议这个方案用于联邦身份验证和WebCrypto。我不确定是否有这样的东西(或更好的)存在，请给我相关的材料。
实体
爱丽丝的浏览器，浏览器
鲍勃的服务器，鲍勃
爱丽丝的服务器，爱丽丝
背景
标识是域名，每个服务器在每个资源上都有访问控制列表。
Bob写入访问控制文件"alice.com“可以读取"/foo”。
艾丽斯想读福
协议
tl;dr版本：
Alice的浏览器试图访问Bob服务器上的资源，Bob用未经授权的消息和一条nonce回复
Alice用webcrypto在浏览器中生成一个密钥，并将其保存在内存中。
爱丽丝把她的钥匙上传到她的网站上。
爱丽丝签署了现在的地址，鲍
浏览 0提问于2016-05-06得票数 2
因此，有了，我尝试创建一个简单的发布者，它将能够发布基于主题的消息(类似于)：
using (var context = ZmqContext.Create())
using (var pub = context.CreateSocket(SocketType.PUB))
{
pub.Bind(url);
while (true)
{
pub.Send( // How to send "Message" string on topic "A.message"?
}
}
那么如何在topic/上发送带有A.messa
浏览 0提问于2013-03-03得票数 0
我尝试在我的应用程序中创建admob横幅，我得到错误代码3，请帮助我获得解决方案。 我在清单中有元数据 布局： <com.google.android.gms.ads.AdView
xmlns:ads="http://schemas.android.com/apk/res-auto"
android:id="@+id/adView111"
android:layout_width="wrap_content"
android:layout_height="wr
浏览 178提问于2019-12-13得票数 0
如果在GCP pub/sub组件中发生任何事件，则需要调用外部服务，例如，如果在GCP pub/sub api中接收到任何消息，则它应该使用这些消息详细信息调用GCP外部服务。任何关于如何从Google Cloud平台调用外部web服务的信息都会很有帮助
浏览 7提问于2021-10-11得票数 0
Google的pub/sub服务为消息的订阅者提供了一个端点，以显式地确认消息的成功传递。如果未使用此端点，则subscriber必须在超时之前返回200响应，否则发布/订阅会认为消息传递不成功，并将在超时后重试发送消息。因此，对于长时间运行的订阅者进程，可以在运行主进程之前先发送确认，而不是等到进程完成。
我没有在Azure Event Grid中找到类似的机制，所以如果事件处理程序花费了很长时间(根据，超时只有30秒)，那么在过程的中间，event grid会重试向同一个订阅者发送更多的事件：
“事件网格在传递消息后等待30秒的响应。30秒后，如果终结点没有响应，消息将排队等待重试。事件网
浏览 1提问于2020-06-25得票数 1
1回答
我正在尝试使用pyzmq的内置日志处理程序为我的分布式应用程序实现一个集中式日志服务器(请参阅)。尽管从体系结构的角度来看，我可以理解PUB/SUB模式的使用，但我不能掌握这样一个系统的正确的技术实现。
根据我到目前为止所理解的情况，由于我将有N个单独的进程在N个单独的端口上发布，我确实需要N个单独的记录器来捕获所有的消息。
因此，这意味着我需要为系统上的每一个新出版商打开一个单独的“侦听器”进程？
编辑：来澄清这个问题:在pyzmq提供的工具的上下文中，如何实现集中式日志服务器？
浏览 5提问于2014-03-19得票数 3
回答已采纳
我正在尝试在一个简单的安卓应用程序中使用Ti.admob模块。我下载了它，并尝试运行示例代码。
点击此处：
我在tiapp.xml中添加了这个
<application>
<activity android:configChanges="keyboardHidden|orientation" android:theme="@android:style/Theme.Translucent"/>
<meta-data android:name="com.google
浏览 28提问于2019-07-08得票数 1
回答已采纳
1回答
我遵循了以下步骤：
Create/select 转到Google控制台并创建/选择一个项目。标题上的，单击打开菜单并选择“Pub/Sub”，或单击“主题”。添加服务帐户google-play-developer-notifications@system.gserviceaccount.com，并授予它Pub/Sub Publisher.Create订阅的角色。有两种类型的订阅: messages.Push：拉:我们需要将服务器配置为新的，类似于ios，通知发送到我们configure.的端点
转到Google控制台并选择您的应用程序。单击“开发工具”，然后单击“服务和app”。实时开发人员通知
浏览 7提问于2020-10-01得票数 5
回答已采纳
根据这个指南，我尝试添加一个用于填写表单的触发器：
在编写脚本后，我尝试添加触发器，如此链接中所述。不幸的是，我收到了一条消息：“这个应用程序还没有被Google验证过。只有在你知道并信任开发者的情况下才能继续。”
我很感谢你的指导，谢谢
浏览 0提问于2020-04-18得票数 0
我是redis的新手，在读这篇文章的时候，我认识了pub/sub。我发现pub/sub和socket有很多相似之处。我用谷歌搜索了同样的问题，但没有得到任何满意的答案。请帮帮忙。
浏览 0提问于2020-09-04得票数 0
O‘’Reilly的"Java消息服务“一书写道：
在点对点消息传递中使用请求/应答模型。
我们可以在pub/sub消息传递中使用消息选择器，因此编写请求/回复模型就像在回复主题上编写一个简单的选择器一样简单：
correlationID)subscriber publisher发布具有某些唯一属性的消息(例如，UUID响应于与应答主题的correlationIDpublisher(also订阅者相同的消息UUID )选择发送的UUID消息。
这是个错误的模式吗？
浏览 3提问于2012-06-19得票数 6
回答已采纳
给出一个obj-c键盘
@objc dynamic var someProp: String { string(forKey: "someProp") }
正规出版商：
private let sub = UserDefaults.standard.publisher(for: \.someProp).sink { print($0) }
这只发布第一个值(例如当前值)。
但是，从sub发布服务器SwiftUI中观察到的效果很好：
.onReceive(pub) { value in
print("received", value)
}
这会发布后续的任
浏览 3提问于2022-11-06得票数 1
回答已采纳
如何在Node.js中使用Google /Sub？
有一个完整的全局版本的库，但是对于lite版本没有任何库。npm只有完整的全球版本Pub/Sub的“lite”包装。
是否可以使用完整的Pub/Sub库进行一些设置更改或类似的操作？还是有别的办法？
浏览 8提问于2022-08-23得票数 0
回答已采纳
据我所知，我们可以在Kafka上定义AVRO模式，使用该模式定义的主题将只接受与该模式匹配的数据。在接受队列之前验证数据结构是非常有用的。
Google Pub/Sub中有类似的东西吗？
浏览 1提问于2018-11-08得票数 4
回答已采纳
1回答
我注意到了zmq.PUB的奇怪行为，它需要有send循环来发送消息。示例：
想象一下我有个替补在等酒吧：
context = zmq.Context()
subscriber = context.socket(zmq.SUB)
subscriber.setsockopt(zmq.SUBSCRIBE, '')
subscriber.connect ('tcp://*:5555')
while True:
msg = socket.recv()
我想从酒吧发出一个信息：
context = zmq.Context()
publisher = context.
浏览 2提问于2015-07-15得票数 3
是否有一种通用模式用于使0mq pub/sub节点中的发布者冗余？其动机是能够与发布者一起运行多个进程，这些进程可能会定期失败/重新启动。
我最初的想法是在master中创建一个转发器，并从worker publishers连接到它：
var cluster = require('cluster')
, zmq = require('zmq')
, endpointIn = 'ipc:///tmp/cluster_pub_sub'
, endpointOut = 'tcp://127.0.0.1:7777';
if
浏览 1提问于2012-06-28得票数 1
我需要加载AJAX的谷歌广告。我发现，这是不被允许的，所以我在想，并发明了这个：
我通常在DIV的HTML页面中包含Google javascript代码，ID如下：
<div id="google_ad">
<script>
google_ad_client = "ca-pub-XXXXXXXXXXXXXXXXXXXX";
google_ad_slot = "XXXXXXXXXXX";
google_ad_width = 300;
google_
浏览 0提问于2012-11-15得票数 3
3回答
我有一个表格，其中包含一些非正态化的数据，如下所示(假的，简化我的问题)：
图书表
ID, Title, Author-Name, Publisher-Name, Category
在另一张表中，我有如下内容：
作者表
ID, Author-Name, Address
Publisher表
ID, Publisher-Name, Address
假设Publisher-Name和Author-Name总是唯一的。
期望的结果集
现在，我要做的就是创建一个创建结果集的查询，该结果集包括：
1. all columns from Book table
2. Author.ID
3. Pub
浏览 0提问于2018-10-31得票数 0
回答已采纳
Pub1 -> XSub - XPub --> XSub1Pub2 -> XSub XPub --> XSub2Pub3 -> XSub Pub3 en19
我的问题是，XSub应该侦听特定的ip:端口，这意味着所有Pub1,2,3必须发布到同一个ip:端口(停靠器中的冲突和冲突组成以在yaml中公开端口输出)。
每个发布者位于同一台机器1中的自己的坞中，其中Xsub和订阅者位于同一台机器上，每个服务器都位于自己的容器中。
诚挚的问候。
浏览 0提问于2021-06-09得票数 0
我正在为我的新移动应用程序开发的最后阶段，但似乎找不到一种方式允许谷歌播放实时开发者通知通过推荐的Google /Sub方法与防火墙云功能通信。
预期的有效负载流应如下所示：
用户通过Play Store > Play Store向Pub/Sub > Pub/Sub发送消息到防火墙云功能>云函数运行负载。
我目前有一个类似的苹果开发者web钩子设置，它将收据有效负载与我设置的iOS云功能挂钩。
在pub/sub设置阶段，Pub/Sub页面要求验证云功能URL，因为我不是云功能域的真正站长，因此在google提供的‘添加实时开发人员通知’文档的过程中，我就半途而废。
有没有办法
浏览 2提问于2019-09-18得票数 12
1回答
使用pyzmq广播到子网地址
、、、、
我正在尝试使用广播数据包到子网地址，我成功地尝试使用套接字的广播选项，但我最近开始学习ZeroMQ，所以我想使用它来广播数据包到子网。我使用了zmq.PUB、zmq.SUB，但在用户端，由于我使用的是子网地址，数据包无法传送。如果我使用机器的IP地址，那么它可以工作，但这不是我想要的。
有没有使用ZMQ进行广播的选项？
以下是我到目前为止尝试过的代码：
出版商：
import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://192.X.X.255:
浏览 5提问于2018-11-24得票数 0
1回答
我想通过Redis分享一个国家，有以下要求：
解耦：解耦发布者和订阅者
单一所有权：每个状态由单个发布者设置
Push:一旦状态发生变化，必须立即通知相关订阅者
拉：一旦用户初始化，就应该立即提取相关状态
如果不需要推送，则pub\sub将是最优的
如果不需要推就需要拉，那么简单的redis键和值就会工作得很好。
支持所有需求的最佳设计模式是什么？
浏览 1提问于2013-09-24得票数 0
我在实例中运行了一个Java应用程序。我试图使用向Cloud /Sub主题发布一条消息，并获得DEADLINE_EXCEEDED异常。代码如下所示：
PubSub pubSub = PubSubOptions.getDefaultInstance().toBuilder()
.build().getService();
String messageId = pubSub.publish(topic, message);
结果是：
com.google.cloud.pubsub.PubSubException: io.grpc.StatusRuntimeExcepti
浏览 4提问于2016-11-11得票数 5
我想做什么？
使用Google列出并创建AdSense广告单元。
我试过什么？
去了。
插入我的accountId和adClientId (pub-
点击‘执行’。
我收到了错误403“客户不是AdSense主机”。
在网上寻找答案，但没有成功，所以我现在在StackOverflow上。
有人知道怎么做吗？
谢谢!
浏览 2提问于2014-08-18得票数 1
回答已采纳
在计算机%1上运行的脚本
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.bind("tcp://127.0.0.1:5000")
print "socket bound"
while True:
print "Waiting for message"
message = socket.recv()
print "message received: " + str(message)
此脚本访问socke
浏览 3提问于2013-05-15得票数 2
回答已采纳
1回答
我有一个使用ZMQ的python消息传递应用程序。每个对象都有一个PUB和一个子队列，它们相互连接。在某些特定情况下，我希望在子队列中等待特定的消息，而将我不感兴趣的消息留给以后处理。
现在，我正在获取所有消息，并将那些我对Python队列不感兴趣的消息排队，直到我找到我等待的消息。但他的意思是，在每个处理路由中，我需要首先在Python队列中检查旧消息。有没有更好的方法？
浏览 5提问于2012-11-02得票数 2
2回答
为了简化这个问题，我有三个表：
Books(isbn, title, author_id, pub_id)
Authors(id, first_name, last_name)
Publishers(pub_id, name)
书籍有两个外键，author_id和pub_id。它们被设置为“限制”删除和更新，我认为这意味着如果您尝试删除或更改作者或Publisher表中的一行时，它就会停止。
我想在桌上书中添加一本新书，但每次我试一次，我就会得到：
错误: SQL错误: Errno: 1452错误:无法添加或更新子行:外键约束失败(emilyc_library.Books, CON
浏览 5提问于2017-04-13得票数 1
回答已采纳
我正在尝试创建一个pub/sub架构，在同一个总线上存在多个发布者和多个订阅者。根据我在互联网上所读到的，只有一个套接字应该调用bind()，而所有其他套接字(不管是pub还是sub)都应该调用connect()。
问题是，使用这种方法，我发现只有在套接字上实际调用bind()的发布者才会发布消息。我所有调用connect()的发布者似乎都默默地失败了，并且实际上没有向总线发布任何消息。我已经确认这不是订阅者的关键问题，因为我编写了一个简单的“嗅探器”应用程序，它订阅总线上的所有消息，它只显示了名为bind()的发行者。
如果我尝试与发布服务器进行多个绑定，则“预期”的偷取总线的zmq行为会在
浏览 4提问于2013-08-26得票数 11
我使用的是nservicebus的pub sub模型。我有以下情况:我的发布者托管了一个web服务，并发布了message.Thw web配置，如下所示
<!--NSB configurations-->
<MsmqTransportConfig
InputQueue="Pubque1"
ErrorQueue="error"
NumberOfWorkerThreads="1"+
MaxRetries="5"
/>
我有一个订阅者在puque1中监听消息，比如
<MessageEndpo
浏览 1提问于2010-10-27得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
