XMPP 的<message/>节是使用基本的”push”方法来从一个地方到另一个地方得到消息。因为消息通常是不告知的，它们是一种”fire-and-forget”(发射后自寻目的)的机制来从一个地方到另一个地方快速获取信息
消息节有五种不同的类型，通过 type 属性来进行区分：例如 chat 类型为 chat 的消息在两个实体间的实时对话中交换，例如两个朋友之间的即时通讯聊天。除了 type 属性外，消息节还包括一个 to 和 from 地址，并且也可以包含一个用于跟踪目的的 id 属性（我们在使用更为广泛的 IQ 节中详细的讨论 IDs）。to 地址是预期接收人的
JabberID，from 地址是发送者的JabberID。from 地址不由发送客户端提供，而是由发送者的服务器添加邮戳，以避免地址欺骗。
在Tigase中，有两个重要的组成,一个组件,二是插件,可以去官方网去看下他的架构介绍 upload/201811011155008126.gif" alt="复制代码" style="max-width: 900px; height: auto; border: none !important;" />
public void setProperties(Map<String, Object> props){ for (String name : msgrcv_names) { mr = conf.getMsgRcvInstance(name); if (mr instanceof MessageReceiver) { ((MessageReceiver) mr).setParent(this); ((MessageReceiver) mr).start(); } } } 1、当客户端发送的message消息到tigase服务端，每个一SOCKET连接都会被包装成IOService对象，IOService包含一系列操作socket的方法（接收发送数据等），processSocketData()接收网络数据，由tigase.net处理解析成xml对象，并将packet放到接收队列receivedPackets中再调用serviceListener.packetsReady(this)。由于ConnectionManager实现IOServiceListener接口，实现上调用的的是ConnectionManager中的packetsReady()来开始处理数据
此时的packet ：packetFrom=null，packetTo=null。
ClientConnectionManager.processSocketData方法中设置packet的一些属性：
此时: packetFrom=c2s@llooper/192.168.0.33_5222_192.168.0.33_38624, packetTo=sess-man@llooper
ClientConnectionManager.processSocketData(XMPPIOService<Object>serv) JID id = serv.getConnectionId(); //c2s@llooper/192.168.0.33_5222_192.168.0.33_38624 p.setPacketFrom(id); //packetFrom 设置为onnectionId p.setPacketTo(serv.getDataReceiver()); //packetTo 设置为sess-man --> SessionManager addOutPacket(p);//将会委托给父 MessageRouter 路由 }
//packet 被设置上一些源信息，和目的地信息，接下来，这个数据包将会委托给父 MessageRouter 帮忙路由到 SessionManager组件中进行处理
packet = (tigase.server.Message) from=c2s@llooper/192.168.0.33_5222_192.168.0.33_38624, to=sess-man@llooper, DATA=<message xmlns="jabber:client" id="44grM-176" type="chat" to="llooper@llooper"><thread>SWjZv5</thread><composing xmlns="http://jabber.org/protocol/chatstates"/></message>, SIZE=170, XMLNS=jabber:client, PRIORITY=NORMAL, PERMISSION=NONE, TYPE=chat
packet = from=c2s@llooper/192.168.0.33_5222_192.168.0.33_38624, to=sess-man@llooper, DATA=<message to="admin@llooper" type="chat" id="2jePE-253" xmlns="jabber:client"><thread>7VKMRq</thread><composing xmlns="http://jabber.org/protocol/chatstates"/></message>, SIZE=168, XMLNS=jabber:client, PRIORITY=NORMAL, PERMISSION=NONE, TYPE=chat
2、MessageRouter.processPacket(Packet packet)部分代码如下：
//我们不会处理没有目标地址的数据包,只是丢弃它们并写一个日志消息if (packet.getTo() == null) { log.log(Level.WARNING, "Packet with TO attribute set to NULL: {0}", packet); return; } //它不是一个服务发现包，我们必须找到一个处理组件 //下面的代码块是“快速”找到一个组件if //这个包TO 组件ID,格式在以下一项: // 1。组件名+“@”+默认域名 // 2。组件名+“@”+任何虚拟主机名 // 3。组件名+ "."+默认域名 // 4。组件名+ "."+任何虚拟主机名 ServerComponent comp = getLocalComponent(packet.getTo()); //SessionManagercomp.processPacket(packet, results); 3、SessionManager.processPacket(final Packet packet)处理，有要代码如下。 例如A->B,这样做的目的是为了首先确定用户A有权限发送packet，然后是确定用户B有权限接收数据。如果用户B不在线，那么离线消息处理器会把packet保存到数据库当中。
//XMPPResourceConnection session——用户会话保存所有用户会话数据，并提供对用户数据存储库的访问。它只允许在会话的生命周期内将信息存储在永久存储或内存中。如果在分组处理时没有联机用户会话，则此参数可以为空。XMPPResourceConnection conn = getXMPPResourceConnection(packet); //现在要走SessionManager的处理函数,主要是走插件流程,插件在Tigase中也是一个重要的组成,入口就是在这里,SM pluginprocessPacket(packet, conn);
插入下SM plugin 流程说明 :
这个设计有一个惊人的结果。如果你看下面的图片，显示了两个用户之间的通信，你可以看到数据包被复制了两次才送到最终目的地:
会话管理器(SessionManager)必须对数据包进行两次处理。第一次以用户A的名义将其作为传出包进行处理，第二次以用户B的名义将其作为传入包进行处理。
这是为了确保用户A有权限发送一个包，所有的processor都应用到packet上，也为了确保用户B有权限接收packet，所有的processor都应用到packet了。例如，如果用户B是脱机的，那么有一个脱机消息processor应该将包发送到数据库，而不是用户B。
