XMPP 提供 '流管理'了解消息是否传递到 XMPP 服务器。
为此,您必须注册并激活它。
这是代码。
// Stream Management
func configureStreamManagement() {
let xmppSMMS = XMPPStreamManagementMemoryStorage()
xmppStreamManagement = XMPPStreamManagement(storage: xmppSMMS, dispatchQueue: DispatchQueue.main)
xmppStreamManagement.addDelegate(self, delegateQueue: DispatchQueue.main)
xmppStreamManagement.activate(xmppStream)
xmppStreamManagement.autoResume = true
xmppStreamManagement.ackResponseDelay = 0.2
xmppStreamManagement.requestAck()
xmppStreamManagement.automaticallyRequestAcks(afterStanzaCount: 1, orTimeout: 10)
xmppStreamManagement.automaticallySendAcks(afterStanzaCount: 1, orTimeout: 10)
xmppStreamManagement.enable(withResumption: true, maxTimeout: 0)
xmppStreamManagement.sendAck()
xmppStream.register(xmppStreamManagement)
}
认证成功后调用该方法。
func xmppStreamDidAuthenticate(_ sender: XMPPStream!) {
print("Stream: Authenticated")
configureStreamManagement()
}
使用 'XMPP流管理代理' 您可以获得发送到 XMPP 服务器的消息 ID。
func xmppStreamManagement(_ sender: XMPPStreamManagement!, didReceiveAckForStanzaIds stanzaIds: [Any]!) {
if let messageIds = stanzaIds as? [String] {
for id in messageIds {
print("Message is delivered to xmpp server: \(id)")
// TODO: Custom code goes here to change the message status
}
}
}
正如您上面提到的,下面的代码将自动发送客户端的已送达收据,这意味着消息已传递给客户端。
self.xmppMessageDeliveryRecipts = XMPPMessageDeliveryReceipts(dispatchQueue: DispatchQueue.main)
self.xmppMessageDeliveryRecipts!.autoSendMessageDeliveryReceipts = true
self.xmppMessageDeliveryRecipts!.autoSendMessageDeliveryRequests = true
In 'XMPPStreamDelegate' 当消息发送给客户时,您将收到回执消息。
func xmppStream(_ sender: XMPPStream!, didReceive message: XMPPMessage!) {
print("Message From: \(message.from().user)")
print("Message Body: \(message.body())")
print("Message is delivered to client -: \(message.receiptResponseID())")
// TODO: Compare receiptResponseID with sent message's id.
}