1

我在 Android 上使用 CometD Java 客户端。

编译组：'org.cometd.java'，名称：'cometd-java-client'，版本：'2.9.1'

我需要订阅 CometD 服务器上的频道。但是有一个问题 - 服务器需要自定义订阅消息（这是来自服务器文档的预期订阅消息有效负载）：

[
    {
        "user": "xyz-WQUAq3shWho1ZcJHaibQYzCh2ILMMX1o-gA6NuehTFYMhvViv6Ow3dvPbyt8Zwg10-bd8bd779f107615b1c5a1470706e4050e5389ddc",
        "domain": "xyz",
        "pid": "gA6NuehTFYMhvViv6Ow3dvPbyt8Zwg10",
        "sid": "85f103a2",
        "gid": "WQUAq3shWho1ZcJHaibQYzCh2ILMMX1o",
        "pageId": "6ea23e",
        "entityId": "xyz",
        "triggeringGoal": "3E955818355C44E2479B2A26629E69566C8C6376",
        "chatSearchPattern": "ua.domain=xyz",
        "startTime": 1482931626853,
        "metadata": "{}",
        "chatMetadata": "{}",
        "language": "en",

        "id": "3",
        "channel": "\/meta\/subscribe",
        "subscription": "\/chat\/xyz-WQUAq3shWho1ZcJHaibQYzCh2ILMMX1o-gA6NuehTFYMhvViv6Ow3dvPbyt8Zwg10-bd8bd779f107615b1c5a1470706e4050e5389ddc",
        "clientId": "26l1v2ngpdcwdtno1wu30rk92dur4",
        "ext": {
        }
    }
]

所以我的问题是如何将自定义字段添加到订阅消息（user、、、domain等pid）sid？目前我正在订阅这样的频道：

cometdClient.getChannel("/chat/" + clientID).subscribe(new ChannelListener("/chat/ messages"), new ChannelListener("/chat/ progress"));

但它按预期失败了。

顺便说一下，我使用org.eclipse.jetty.client.HttpClient的是 HttpClient。

4

1 回答 1

1

首先，你真的应该升级，因为 CometD 2.9.1 现在真的很老了，而且 Android 支持 JDK 7。

要求消息中所有这些字段的服务器设计/meta/subscribe确实是错误的。大多数信息是静态的（例如user各种“cookies”pid等），可以在 CometD 握手时确定，因此无需在订阅期间发送。

此外，在消息期间发送它/meta/subscribe会使其受到攻击（例如，攻击者可以伪造具有不同user字段的消息）。您想阅读CometD 文档的安全部分。

此外，不推荐使用每个用户的频道（因为频道名称是/chat/和user字段的串联）不是推荐的方法，因为它可能会创建很多频道，而相同的功能可以通过以下方式更有效地实现单个服务通道（以及user作为正在发送消息的字段）。

如果您确实必须将这些字段添加到/meta/subscribe消息中，则方法是使用自定义扩展名，如下所示：

class SubscribeExtension extends ClientSession.Extension.Adapter {
    @Override
    public boolean sendMeta(ClientSession session, Message.Mutable message) {
        if (Channel.META_SUBSCRIBE.equals(message.getChannel())) {
            String subscription = (String)message.get(Message.SUBSCRIPTION_FIELD);
            if (subscription.startsWith("/chat/") {
                // Add fields.
            }
        }
        return true;
    }
}

最后，如果你真的需要在/meta/subscribe消息中添加额外的字段，你希望在ext字段内进行，并使用适当的命名空间：

{
    "id": "3",
    "channel": "/meta/subscribe",
    "subscription": "/chat/xyz-WQUAq3shWho1ZcJHaibQYzCh2ILMMX1o-gA6NuehTFYMhvViv6Ow3dvPbyt8Zwg10-bd8bd779f107615b1c5a1470706e4050e5389ddc",
    "clientId": "26l1v2ngpdcwdtno1wu30rk92dur4",
    "ext": {
        "com.acme.myapp": {
            "time": 1234567890,
            "pageId": "6ea23e",
            ...
        }
    }
}

请注意，额外字段不会污染消息本身，而是分组在代表您的公司和应用程序的ext命名空间下的字段中。com.acme.app

于 2017-08-15T10:21:54.187 回答