EdgeX通过Redis接收IoT消息总线问题：无法用redis-cli订阅消息

问题描述 #

EdgeX 默认使用 Redis PubSub 作为消息总线。我已完成以下操作：

• 本地启动Redis服务器；
• 运行Core Data和/或Device Services，默认配置为使用Redis Pub/Sub；
• 部署Virtual Device Service，向edgex/events/#主题发布数据；
• 配置Application Service订阅edgex/events/#主题，配置如下：

[Trigger.EdgexMessageBus]
Type = "redis" # message bus type (i.e "redis`, `mqtt` or `zero` for ZeroMQ)
    [Trigger.EdgexMessageBus.SubscribeHost]
        Host = "localhost"
        Port = 6379
        Protocol = "redis"
        SubscribeTopics="edgex/events/#"
    [Trigger.EdgexMessageBus.PublishHost]
        Host = "localhost"
        Port = 6379
        Protocol = "redis"
        PublishTopic="" # optional if publishing response back to the MessageBus

目前Application Service可以接收该主题下的所有消息，但直接通过redis-cli连接Redis服务器，执行SUBSCRIBE edgex/events/#或其他变体（如edgex/events、edgex）时，无法看到任何消息，执行PUBSUB CHANNELS也显示无活跃通道。原本以为EdgeX使用本地Redis服务器时，可直接通过redis-cli订阅对应主题查看消息，请问哪里操作有误？

问题原因与解决方案 #

核心问题是EdgeX 使用的是 Redis Streams 而非原生 Redis Pub/Sub，尽管配置里标注的是redis类型，但EdgeX 2.x及以后版本默认用Redis Streams实现消息总线，而非传统的Redis Pub/Sub机制。

具体原因 #

• EdgeX 从2.0版本开始，将Redis消息总线的实现从原生Pub/Sub切换到Redis Streams，以此提供消息持久化、消费确认等更可靠的消息能力。
• 你的Application Service能正常接收消息，是因为EdgeX的SDK会自动适配Streams的消费逻辑，而redis-cli的SUBSCRIBE命令仅针对原生Pub/Sub通道，无法读取Streams中的消息。

验证与查看消息的方法 #

要查看EdgeX通过Redis Streams发布的消息，需使用Redis的Streams相关命令：

1. 查看所有存在的Streams：

redis-cli KEYS "edgex/events/*"

你应该能看到类似edgex/events/device/<设备服务名>的Stream键。
2. 读取Stream中的消息（以edgex/events/device/virtual为例）：

redis-cli XREAD COUNT 10 BLOCK 0 STREAMS edgex/events/device/virtual 0

该命令会从Stream的起始位置读取10条消息，若无消息则阻塞等待新消息。
3. 查看活跃的消费者组（可选）：

redis-cli XINFO GROUPS edgex/events/device/virtual

补充说明 #

如果确实需要使用原生Redis Pub/Sub而非Streams，需修改EdgeX服务的配置：

• 对于Core Data、Device Services等发布端，将MessageBus.PublishMode设置为PubSub
• 对于Application Service，在[Trigger.EdgexMessageBus]配置块下添加Mode = "pubsub"字段
  但这种方式会失去Streams带来的消息可靠性特性，仅适合测试场景。

内容的提问来源于stack exchange，提问作者Phillip Ng