Spring 集成 XMPP 和 Google Cloud Messaging

Question

我正在使用 spring 集成 xmpp 模块编写连接到 GCM 云服务的第 3 方服务器的自定义实现，如 GCM Cloud Connection Server (XMPP)。

到目前为止，我已经成功连接到 GCM 服务器，但是当我向服务器发送消息时，我最终会得到如下信息：

<message id="m-1366082849205" to="REGISTRATION_ID">
<body>{"hello":"world"}</body>
</message>

，但我需要发送如下内容：

  <message id="">
  <gcm xmlns="google:mobile:data">
  {
      "to":"REGISTRATION_ID",
      "message_id":"m-1366082849205"
      "data":
      {
          "hello":"world",
      }
  }
  </gcm>
</message>

我用的是最新的SI版本，4.0.4，这是我在xml中的配置：

<int-xmpp:outbound-channel-adapter
    id="gcmOutboundAdapter" channel="gcmOutboundNotificationChannel"
    xmpp-connection="gcmConnection" auto-startup="true"/>

我正在使用通常的 MessageBuilder 发送消息，如下所示：

Message<String> xmppOutboundMsg = MessageBuilder.withPayload(xmppPayload)
        .setHeader(XmppHeaders.TO, REGISTRATION_ID)
        .build();

其中 xmppPayload 是一个 json 字符串。

我需要配置/覆盖 xmpp 消息的组成方式，实现结果的最佳实践是什么？我是否应该使用自定义服务激活器覆盖实现 int-xmpp:outbound-channel-adapter 的类，是否可以配置 xmpp 消息的组成方式？

感谢您的帮助。

Answer 1

-->

<int:chain input-channel="gcmOutboundNotificationChannel">
    <!--<int:transformer ref="toGcmTransformer" output-channel="gcmOutboundNotificationChannel"/>-->
    <bean class="com.payumoney.cardhash.service.MyMessageSendingMessageHandler">
        <constructor-arg ref="gcmConnection" />
    </bean>
</int:chain>
<int:transformer id="testTransformer" ref="toGcmTransformer" input-channel="gcmInboundNotificationChannel"
         method="doTransform" output-channel="gcmOutboundNotificationChannel"/>
<!--<int:transformer ref="toGcmTransformer" output-channel="gcmOutboundNotificationChannel"/>-->

<int-xmpp:outbound-channel-adapter
    id="gcmOutboundAdapter" channel="gcmOutboundNotificationChannel"
    xmpp-connection="gcmConnection" auto-startup="true"/>

<int:chain input-channel="gcmInboundNotificationChannel">
    <bean class="com.payumoney.cardhash.service.PayumoneyNotificationListeningEndpoint">
        <constructor-arg ref="gcmConnection" />
        <property name="outputChannel" ref="gcmOutboundNotificationChannel" />
    </bean>
</int:chain>

<int-xmpp:inbound-channel-adapter 
    id="gcmInboundAdapter"  channel="gcmInboundNotificationChannel" 
    xmpp-connection="gcmConnection" extract-payload="true" auto-startup="true" />

Answer 2

在我们引入PackExtension 注入之前，您可以使用自定义<transformer ref=""> 来克服它，因为<int-xmpp:outbound-channel-adapter> 可以接受org.jivesoftware.smack.packet.Message 作为消息payload：

<transformer ref="toGcmTransformer" output-channel="gcmOutboundNotificationChannel"/>

<int-xmpp:outbound-channel-adapter
    id="gcmOutboundAdapter" channel="gcmOutboundNotificationChannel"
    xmpp-connection="gcmConnection" auto-startup="true"/>

---

public class ToGcmTransformer extends AbstractTransformer {


   protected Object doTransform(Message<String> message) throws Exception {
        String to = message.getHeaders().get(XmppHeaders.TO, String.class);
        xmppMessage = new org.jivesoftware.smack.packet.Message(to);
        xmppMessage.setBody(message.getPayload());
        xmppMessage.addPacketExtension(gcmPackExtension);
        return xmppMessage;
   }

}

请提出关于PackExtension 支持的问题。

Answer 3

消息的格式在 Smack Message.toXML() 方法中是硬编码的（我们使用下面的 smack 库）。

查看@Flow 的回答。

然后，子类ChatMessageSendingMessageHandler，覆盖handleMessageInternal() - 几乎复制代码并在创建消息后设置扩展。

配置自定义处理程序的最简单方法可能是将其放入chain...

<chain input-channel="gcmOutboundNotificationChannel">
    <bean class="foo.MyChatMessageSendingMessageHandler">
        <constructor-arg ref="gcmConnection" />
    </bean>
</chain>

或者您可以将其连接为顶级 bean 并将其注入到 ConsumerEndpointFactoryBean。

请随时打开New Feature JIRA Issue，我们会考虑添加一个扩展点以简化此操作。

Answer 4

<gcm xmlns="google:mobile:data"> 是一个扩展的内容元素（参见 RFC 6120 8.4），它在 Smack 中被建模为 PacketExtension。不要子类化消息，而是创建一个 GCMPacketExtension 类并将其实例添加到您的消息中

message.addPacketExtension(gcmPackExtension)