切换数据连接时在 Android 上丢失 XMPP 消息（例如，关闭 Wifi，GSM <-> Wifi 开关）

Question

我正在用 android 开发一个聊天应用程序。使用 XMPP 服务器。 PHP 服务器已迁移到 ejabber。

我的通知在所有情况下都能正常工作。但在一种情况下，我丢失了 XMPP 消息。事实上，我没有收到通知。

具体来说，我正在关闭 WiFi 或数据连接。在关闭 WiFi 或数据连接后，发送给我的任何通知都没有收到。当我打开 WiFi 或数据连接后，我无法收到发送给我的消息。

我已经在后台实现了服务。这使得 xmpp 连接始终有效。

我在关闭 WiFi 连接时收到此错误。

java.net.SocketException: sendto failed: EPIPE (Broken pipe)
java.net.SocketException: recvfrom failed: ETIMEDOUT (Connection timed out)
   at libcore.io.IoBridge.maybeThrowAfterSendto(IoBridge.java:506)
   at libcore.io.IoBridge.sendto(IoBridge.java:475)
   at java.net.PlainSocketImpl.write(PlainSocketImpl.java:508)
   at java.net.PlainSocketImpl.access$100(PlainSocketImpl.java:46)
   at java.net.PlainSocketImpl$PlainSocketOutputStream.write(PlainSocketImpl.java:270)
   at java.io.OutputStreamWriter.flushBytes(OutputStreamWriter.java:167)
   at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:158)
   at java.io.BufferedWriter.flush(BufferedWriter.java:124)
   at org.jivesoftware.smack.PacketWriter.writePackets(PacketWriter.java:286)
   at org.jivesoftware.smack.PacketWriter.access$12(PacketWriter.java:270)
   at org.jivesoftware.smack.PacketWriter$1.run(PacketWriter.java:137)
Caused by: libcore.io.ErrnoException: sendto failed: EPIPE (Broken pipe)
   at libcore.io.Posix.sendtoBytes(Native Method)
   at libcore.io.Posix.sendto(Posix.java:146)
   at libcore.io.BlockGuardOs.sendto(BlockGuardOs.java:177)
   at libcore.io.IoBridge.sendto(IoBridge.java:473)
   ... 9 more
   at libcore.io.IoBridge.maybeThrowAfterRecvfrom(IoBridge.java:552)
   at libcore.io.IoBridge.recvfrom(IoBridge.java:516)
   at java.net.PlainSocketImpl.read(PlainSocketImpl.java:489)
   at java.net.PlainSocketImpl.access$000(PlainSocketImpl.java:46)
   at java.net.PlainSocketImpl$PlainSocketInputStream.read(PlainSocketImpl.java:241)
   at java.io.InputStreamReader.read(InputStreamReader.java:244)
   at java.io.BufferedReader.read(BufferedReader.java:310)
   at org.jivesoftware.smack.XMPPConnection$AliveReader.read(XMPPConnection.java:1122)
   at org.kxml2.io.KXmlParser.fillBuffer(KXmlParser.java:1496)
   at org.kxml2.io.KXmlParser.peekType(KXmlParser.java:979)
   at org.kxml2.io.KXmlParser.next(KXmlParser.java:346)
   at org.kxml2.io.KXmlParser.next(KXmlParser.java:310)
   at org.jivesoftware.smack.PacketReader.parsePackets(PacketReader.java:321)
   at org.jivesoftware.smack.PacketReader.access$1(PacketReader.java:216)
   at org.jivesoftware.smack.PacketReader$1.run(PacketReader.java:70)
Caused by: libcore.io.ErrnoException: recvfrom failed: ETIMEDOUT (Connection timed out)
   at libcore.io.Posix.recvfromBytes(Native Method)
   at libcore.io.Posix.recvfrom(Posix.java:131)
   at libcore.io.BlockGuardOs.recvfrom(BlockGuardOs.java:164)
   at libcore.io.IoBridge.recvfrom(IoBridge.java:513)
   ... 13 more

Answer 1

所以要安装 mod_archive，我需要这样做，典型的： 在cmd中写入以下行。 （对于分操作系统）

以 root 身份登录 创建新目录：

mkdir ejabberd_archive_plugin
cd ejabberd_archive_plugin

现在使用以下命令获取最新的 ejabberd 模块

yum https://svn.process-one.net/ejabberd-modules
cd ejabberd-modules/mod_archive/trunk
./build.sh

现在使用以下 cmd 进入 ebin 目录并获取 ejabberd 存档插件的所有 *.beam 文件的列表。

root@ns1 [/ejabberd_archive_plugin/ejabberd-modules/mod_archive/trunk/ebin]# ls –l

在 ejabberd 设置和配置时，使用以下 cmd，您将获得所有 ejabberd *.beam 文件列表。

root@ns1 [/usr/lib64/ejabberd/ebin]# ls -l

现在使用以下 cmd 将所有 *.beam（存档插件）文件复制到 ejabberd ebin 目录

root@ns1 [/]# cp /ejabberd_archive_plugin/ejabberd-modules/mod_archive/trunk/ebin   /usr/lib64/ejabberd/ebin

现在转到以下 URL 并复制所有 sql 表查询并在 phpmyadmin（ejabberd 数据库）中运行

https://svn.process-one.net/ejabberd-modules/mod_archive/trunk/src/mod_archive_odbc_mysql.sql

现在使用以下 cmd 配置 ejjaberd.cfg

root@ns1 [/etc/ejabberd]# vi ejabberd.cfg 
Add the following line into ejabberd.cfg file in modules configuration section
{mod_archive_odbc, [{database_type, "mysql"}, {default_auto_save, true}, {enforce_default_auto_save, true}]},

现在重启 ejabberd 服务。

root@ns1 [/etc/ejabberd]# sudo service ejabberd restart

Answer 2

您必须为此创建单独的 Web 服务。因此，为什么我们可以处理已发送消息的历史记录。我们可以管理离线消息。

XEP-198 是唯一的解决方案。为您的服务器制作插件，使管理丢失的剩余消息变得容易。除了AFAIK，可能还有其他解决方案，这将是解决方案。

Answer 3

每次重新连接到互联网后，您都应该重新登录。但是，请记住，如果您使用 相同的资源和相同的用户重新登录，即使它在线，服务器也会抛出流错误（由新连接替换），这将使您离线并且您不会收到任何信息。为此，请在重新登录之前先正确断开自己的连接。尝试搜索 mod Amp 模块。

Answer 4

您可以修改存档插件以在其中保存消息 ID。

当用户上线时，使用收到的最后一条消息 ID 调用 Web 服务。服务器可以获取保存在服务器上的所有以后的消息。我以同样的方式创建它并且工作得很好。

Answer 5

您需要启用 "Stream Management" XEP-198 的连接来实现此目的。 Georg 就该主题写了一篇很好的博客文章：http://op-co.de/blog/posts/XEP-0198/ 基本上，它允许 stanza 确认 和 流恢复，这正是您想要在例如 Wifi GSM 开关的情况下执行的操作。

我从堆栈跟踪中得出结论，您正在使用 aSmack（将 Smack 移植到 Android）。有一个在 Smack 中实现流管理的开放功能请求：SMACK-333。事实上，我最近开始着手实现，但无法命名 ETA。