发送时间同步没有收到服务器返回

[taofu328]

使用mqttx客户端测试，
productId:1838407478897602560
deviceId:109C553500C0C00007B19514
上行topic:/1838407478897602560/109C553500C0C00007B19514/time-sync
订阅topic：/1838407478897602560/109C553500C0C00007B19514/time-sync/reply
发送消息内容:{"messageId":"4"},没有收到服务器返回消息，是怎么回事呢

[zhou-hao]

是使用的官方协议吗？

[taofu328]

是使用的官方协议吗？

使用的官方协议，通过emqx接入的。

[taofu328]

测试了一下，使用jetlinks自带的mqtt服务能获取时间戳，通过emqx接入就不行

[zhou-hao]

你订阅了这个topic没

[taofu328]

订阅了的，截图里是通过通配符订阅的，通过emqx接入的，收到的是上行消息，通过jetlinks自带mqtt服务器接入的，没有收到上行消息，收到了时间戳。测试过订阅/1838407478897602560/109C553500C0C00007B19514/time-sync/reply，通emqx接入的也收不到时间戳，通过jetlinks接入的能收到

[zhou-hao]

官方协议好像 时间同步的topic 没有加到路由里。所以不会去订阅emqx。 你修改一下官方协议试试。 https://github.com/jetlinks/jetlinks-official-protocol/blob/v3/src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java#L47

[taofu328]

好的，我研究一下，谢谢

[taofu328]

我按照文档[MQTT协议解析 | JetLinks 物联网基础平台]，把时间同步的topic加到路由里，但是不起作用。应该怎么修改呢

CompositeProtocolSupport support = new CompositeProtocolSupport();
        support.setId("jetlinks.v3.0");
        support.setName("JetLinks V3.0");
        support.setDescription("JetLinks Protocol Version 3.0");

        support.addRoutes(DefaultTransport.MQTT, Arrays.asList(
                Route.mqtt("/*/time-sync")
                        .group("时间同步")
                        .upstream(true)
                        .downstream(false)
                        .description("获取服务器时间戳")
                        .example("{\"messageId\":\"消息ID\"}")
                        .build()
        ));

        support.addRoutes(DefaultTransport.MQTT, Arrays
                .stream(TopicMessageCodec.values())
                .map(TopicMessageCodec::getRoute)
                .filter(Objects::nonNull)
                .collect(Collectors.toList())
        );

[zhou-hao]

不要调用两次。 同一个addRoutes中添加。
应该是这样吧 /*/*/time-sync ？

[taofu328]

可以了，谢谢。我看到TopicMessageCodec里面是topic都是一个星号，这里也就只写了一个星号。