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

Redis PUB/SUB:如何忽略自己的消息?

董子航
2023-03-14

这个想法是:我有N个WCF服务,它们连接并订阅了同一个Redis消息通道。这些服务使用此通道交换消息,以同步一些缓存和其他数据。

每个服务如何可以忽略自己的消息?即,如何向除我以外的所有人发布?

共有1个答案

吕子真
2023-03-14

Redis PUB/SUB似乎不支持这种过滤。因此,解决方案是为每个发布者使用一组单独的通道,并为它们之间的订阅同步使用公共通道。下面是一个golang的无回声聊天应用程序示例。

 类似资料:
  • 我正在为多人游戏实现简单的网络服务器。我只是想搞清楚Netty 我通过telnet测试服务器。我所做的是向所有频道广播信息。工作很顺利。此外,我从地图上删除通道关闭事件,这是罚款。 但问题是,如果其中一个客户端意外断开连接,则在关闭回调之前,MessageRec的回调调用其发送方断开连接的信道。 如何正确忽略来自断开连接的客户端的消息?我在中使用,但用于也不是正确的字符串。在断开连接的通道结束时,

  • 问题内容: 我使用了在Maven上找到的说明如何将任意的类路径条目添加到jar中,以向属性添加任意条目。这是我的文件: 我定义org.jace.examples.Test如下: 在中定义的位置。当我调用时,得到以下输出: 线程“主”中的异常java.lang.ClassNotFoundException:org.jace.util.ShutdownHook 换句话说,Java会将可执行的JAR文件

  • 问题内容: 我在代码中的不同业务用例之间共享的大型模型(超过50个字段)上使用了MapStruct。根据入口点的不同,某些属性将被映射,而某些属性将不被映射。构建项目时,我将始终收到“警告:未映射的目标属性”消息。 我研究发现,可以通过使用语义告诉mapstruct忽略字段 问题是,考虑到我的对象具有如此多的字段,将需要大量代码来忽略每个映射器类中的每个单个属性。我也不希望此警告出现在我的日志中。

  • 问题内容: 我正在尝试为api 编写Web服务。因此,我编写了一个MyLogRecord类,该类继承自LogRecord。我用JAX- B注释对此类进行了注释,包括,因此它将忽略未注释的字段和属性。当我启动tomcat时,出现错误,并且其他类没有默认的构造函数,但是没有带注释的方法对Level类或任何其他类进行任何引用。这些由父类引用。 我的子类具有需要定义的所有内容。如何使JAX-B完全忽略父类

  • 我们的一个Kafka主题有一个问题,该主题被&组合使用,这里用工厂使用的描述。不幸的是,有人有点热情,并发表了一些无效的消息到主题。看来斯普林-Kafka没有处理这些信息中的第一个。有可能让spring-kafka记录一个错误并继续吗?查看记录的错误消息,似乎Apache kafka-clients库应该处理这样的情况:在迭代一批消息时,其中一个或多个消息可能无法解析? 下面的代码是说明这个问题的

  • 试图从其他人那里得到答案 假设我有一个简单的控制器,如下所示: 我希望处理忽略“取消”信号,这通常在客户端断开连接时出现。试图通过nginx的