当前位置: 首页 > 知识库问答 >
问题:

如何在PUB/SUB(ZeroMQ)中使用Pro buf二进制文件进行过滤?

束研
2023-03-14

我使用Go、ZeroMQ和protobuf编写了一个微服务。

具有发布/订阅原型的ZeroMQ。(zmq4Go中的lib)。如何在带有二进制protobuf消息的子消息中使用过滤器?

例如,我的proto消息:

语法=“协议3”;

message UserMessage {
    string userId = 1;
    string msg    = 2;
}

我想为值为userId的客户端筛选消息:

listener.SetSubscribe("42") // <-string not working.

共有1个答案

郭意
2023-03-14

我明白了:

listener.SetSubscribe( string( []byte{ 10, 2 } ) + "42" )
 类似资料:
  • 问题内容: 使用带有角的ResponseEntity下载任何文件不起作用 我需要在客户端使用angular下载文件,该文件可以具有pdf或excel或image或txt的任何格式…我的方法仅适用于txt文件,但给我excel和image的失败格式,对于pdf,它会给出一个空的pdf。 所以在我的控制器中,这里是调用service方法的函数: 而我的service.js具有: 我的服务方法是这样的:

  • 我刚刚开始使用ZeroMQ,我正在尝试让Hello World与Python 3.6中的PyZMQ和asyncio一起工作。我正在尝试将模块的功能与发布/子代码分离,因此,下面的类设置如下: 编辑1:最小化示例 编辑2:包含的解决方案,请参见答案。 使用上面的代码,只打印1<code>Hello World</code>,然后永远等待。如果我按ctrl c,我会得到以下错误: 版本:,, 任何真知

  • 问题内容: 目前,我可以按如下方式检索文本页面 假设get以二进制文件为目标。如何将其正确保存到磁盘? 问题答案: 只是不要通过-从中读取数据并将其写入。

  • 问题内容: 为了将二进制文件上传到URL,建议使用本指南。但是,该文件不在目录中,而是存储在MySql db的BLOB字段中。BLOB字段在JPA中映射为属性: 我以这种方式稍微修改了指南中的代码: 我没有使用分块流。使用的标头是: 主机正确接收了所有标头。它还接收上载的文件,但不幸的是,它抱怨该文件不可读,并且断言所接收文件的大小比我的代码输出的大小大37个字节。 我对流,连接和byte []的

  • 问题内容: 我对Go完全陌生,我试图读取一个二进制文件,一次读取一个字节或几个字节。该文档并没有多大帮助,我找不到任何教程或简单示例(顺便说一句,Google如何给他们的语言提供这样一个难以理解的名称?)。基本上,如何打开文件,然后将一些字节读入缓冲区?有什么建议吗? 问题答案: 要处理文件,该软件包是您的朋友: 在过去的文件是如何打开更多的控制,看到代替(DOC) 。 为了读取文件,有很多方法。

  • 问题内容: 我建立与工作流 Gitlab , 詹金斯 和-也许- 的Nexus (我需要一个工件存储装置)。我想让GitLab存储 发行版/二进制文件 -是否可以方便地进行? 我不想有另一个可以从中下载版本(和文档)的服务,但是希望以某种方式将其与存储库管理器集成在一起,就像在GitHub中处理版本一样。有什么线索吗? 问题答案: 2015年11月更新:GitLab 8.2现在支持发行版 。 借助