0906月

又玩了一下jabber

▧ 2006.06.09

jive改名了 . 新的版本叫:Wildfire 金山词霸这么解释的:

wildfire [简明英汉词典] [5waildfaiE] n.古时攻打敌船所用的燃料剂, 磷火, 鬼火, 散布(或传播)极快的事物 感觉和老的jive没什么区别..嗯.这个版本把serach插件集成了.安装还是那么的简单. 导入resources\database里和数据库对应的脚本.在Wildfire\bin里找到一个帅的就可以开始安装了:) wildfire.exe可以用来启动服务,关闭,开启web管理面版. 注:web管理面版支持中文,因此可以很方便的管理. 偶然在jivesoftware找到了.一个java的类库.使用起来非常方便. 相关链接:http://dugan.blogchina.com/blog/1461121.html [newpage]

Jabber的架构    Jabber从结构上来,更类似于一个邮件服务器,它是分布式的,也就是说,并不象其他即时通讯软件那样,所有的即时通讯用户都连接到同一个服务器上,而是象邮件服务器那样,不同的用户连接到自己的服务器上,在服务器之间通过一个标准协议来交换信息 一个实体在Jabber网络上被称为一个接点,它有唯一的标识,被称为JID,统称用来表示一个Jabber用户,但是也可以表示其他内容,例如一个聊天室。它的格式是node@domain/resource, node@domain有点类似电子邮件的地址格式,resource用来表示node不同的设备或位置,这个是可选的,例如我在Server1上注册了一个用户,用户名为doom,那么我的JID就是doom@server1, 在发送消息时,指明doom@server1就可以了,resource可以不用指定,但我在登录到这个Server时,我的JID可能是doom@server1/exodus(如果我用Exodus软件登录),也可能是doom@server1/psi(如果我用psi登录)   Jabber是一个典型的C/S 架构,而不是象大多数即时通讯软件一样,使用P2P的架构,也就是说在大多数情况下,在两个Client进行通讯时,他们的消息都是通过Server传递的(也有例外,例如在两个Client传输文件时)。采用这种架构,是为了简化Client端,将大多数工作放在Server段进行,这样,Client端的工作就比较简单,而且,当增加功能时,多数是在Server端进行。   Jabber是一套基于XML Stream的协议,当一个Jabber Client连接到一个Jabber Server上时,Client建立了一个从Client到Server的XML流,Server也同时建立了一个从XML到Server的XML流,这个流看起来像这个样子:   |——————–|   |            |   |——————–|   |          |   |             |   |         |   |——————–|   | |   |        |   |      |   |——————–|   |      |   |        |   |           |   |——————–|   | …             |   |——————–|   |       | 所有的信息都是以XML格式加入到这个流中(这些信息被称为stanzas),例如如下的消息: from='juliet@capulet.comto='romeo@montague.net ’>   Wherefore art thou, Romeo?

   因为是XML格式的数据,用户可以自己对数据进行扩充,加入自己的基于XML的私有数据。 五. XMPP协议简单介绍   XMPP在2004年10 月被IETF认定为标准协议,它包括RFCS 3920和RFCS 3921,其中,3920被称为Extensible Messaging and Presence Protocol (XMPP): Core,描述了Jabber 中XML Stream的核心技术,包括安全和国际化的一些技术; 3921被称为Extensible Messaging and Presence Protocol (XMPP): Instant Messaging and Presence,主要是基于即时通讯的一些技术,例如通讯列表,黑名单等。 IETF还制定了两个扩展协议,3922,被称为Mapping the Extensible Messaging and Presence Protocol (XMPP) to Common Presence and Instant Messaging (CPIM);3923,被称为 End-to-End Signing and Object Encryption for the Extensible Messaging and Presence Protocol (XMPP)。 同时,JSF还制定了一系列有关Jabber的扩展协议,称为JEPS(Jabber Enhancement Proposals) ,用来制定一些Jabber的扩展功能,这些协议虽然还没有称为XMPP的一部分,但估计也是迟早的事情。 以下是XMPP中的一些需要特殊说明概念: Message:Stream的一个子元素,,用来表示传输的消息,有一些相关属性,例如to, from, type等,来表明发送方或接受方,它可以包括一些子元素,例如,等,当用户发送一条信息时,就会在流的上下文中插入一个Message元素,中间有相关的信息。 Gateway: 用于把XMPP协议转化为非XMPP协议,或将非XMPP协议转化为XMPP协议,应用于Jabber同其他IM的通讯,或是其他系统,例如Email Presence: Stream的一个子元素, 用来表明用户的状态,如在线,离线等,当用户离线或改变自己的状态时,就会在stream的上下文中插入一个Presence元素,来表明自身的状态。 I/Q: Info/Query Stream的一个子元素,,一种请求/响应机制,从一个实体从发送请求,另外一个实体接受请求,并进行相应。例如,client在stream的上下文中插入一个元素,向Server请求得到自己的好友列表,Server返回一个,里面是请求的结果。 Subscriptions: 订阅机制,用来保证用户可以管理订阅指定用户的Presence TLS/SASL: Jabber的安全认证机制(这部分我没有太看懂,大意是,在Client和Server,Server和Server进行通讯前,必须有一套安全机制进行认证,在经过认证后,才能进行通讯 TLS和SASL就是基于认证的两种技术)

[newpage]

gtalk使用的是jabber定义的XMPP协议,所以用支持jabber的客户端都可以登录。 突发奇想是否可以找到一些封装好的类库,用比较傻瓜的方式写一个比较小的Bot. 在jabber网站上列出来好多。 http://www.jabber.org/software/libraries.shtml perl python java ruby .net的都有。 看到smack时,觉得比较感兴趣。 http://www.jivesoftware.org/smack/ 就按照提供的手册测试了一下子,还真的挺好用。 并且它继承父类直接对googletalk进行了封装,比较方便。 一下代码是在手册中凑合而来,只实现了一个类似“鹦鹉将军”的功能, 你说啥,它就重复一下,如果你说“再见”,它就退出来了。

import org.jivesoftware.smack.GoogleTalkConnection; import org.jivesoftware.smack.XMPPException; import org.jivesoftware.smack.Chat; import org.jivesoftware.smack.Roster; import org.jivesoftware.smack.packet.Message; import org.jivesoftware.smackx.*; public class TalkBot { public static void main(String args[]){ try { GoogleTalkConnection con = new GoogleTalkConnection(); con.login(“username”, “passwd”); Chat newchat = con.createChat(“sleetdrop@gmail.com ”); Message newMessage = newchat.createMessage(); newMessage.setBody(“我是学舌的鹦鹉”); newchat.sendMessage(newMessage); while (true) { // Wait for the next message the user types to us. Message message = newchat.nextMessage(); if(message.getBody().equals(“再见”)){ newchat.sendMessage(“滚蛋吧!”); break; } // Send back the same text the other user sent us. newchat.sendMessage(message.getBody()); } con.close(); } catch (XMPPException e) { System.out.println(e.getMessage()); } }

}

[newpage]

用Smack编写jabber客户端(上)-

万事都不能从零开始,XMPP规范就象webServece规范一样.我们最后选用一个库来加速开发. 所以我们选择使用Smack因为它容易使用,设计合理,还记得我们的经典jive吗,它也是他们开发 的,应该还是比较不错的. 注意是apache的licence,也就是可以应用到你的商业程序中. 下载地址: http://www.jivesoftware.org/ 使用简单,你不需要精通xmpp协议(这加快我们入门,从例子开始我们跟容易理解),创建一个xmpp 连接,并向一个用户发送信息,只需要三行代码: XMPPConnection connection = new XMPPConnection(“jabber.org”); connection.login(“mtucker”, “password”); connection.createChat(“jsmith@jivesoftware.com ”).sendMessage(“Howdy!”);

因为是tcp协议,首先必须创建一个网络连接: XMPPConnection 就是用来创建和xmpp服务器的连接的类,如果需要ssl就使用SSLXMPPConnection. // 创建连接. XMPPConnection conn1 = new XMPPConnection(“jabber.org”);

// 指定端口XMPPConnection conn2 = new XMPPConnection(“jabber.org”, 5222);

// 创建ssl连接. XMPPConnection connection = new SSLXMPPConnection(“jabber.org”); 一旦你创建了连接,你需要使用用户名和密码来登陆,你可以使用XMPPConnection.login(String username, String password) 方法.一旦你完成登陆了,你可以通过创建新的Chat或者是GroupChat对象来和其它人聊天. 操作 名册 名册让你能够跟踪其它在线的用户,用户可以被组织成为组,例如好友,同事,并且你可以发现谁在线,谁不在线.你可以使用 XMPPConnection.getRoster() 方法来取得好友名单,得到roster类.roster类允许你查找名册实体,比如他们属于那个组,和当前的状态. 读写数据包 没一个从客户端发送到xmpp服务器的包都是xml格式的文本.org.jivesoftware.smack.packet 保护了封装三种xmpp级别包:message,presence,IQ.Chat类和GroupChat类提供了高级别的类管理包自动的生成和发送,但是你也可以手动创建它们.下面例子演示了改变你的在线情况,告诉其它人你不在线"外出捕鱼"去了. //用presence.Type.UNAVILABLE作为参数创建一个presence描述你不在线.Presence presence = new Presence(Presence.Type.UNAVAILABLE); presence.setStatus(“Gone fishing”); // 发送该包.con.sendPacket(presence);

Smack 提供了两种方式来读取包: PacketListener,和 PacketCollector. 它们都使用PacketFilter实例来决定那些包需要处理.一个PacketListener使用事件风格的编程,packet collector 提供轮循和阻塞的操作.因此,packet listener用来处理随即发送来的包,packet collector用来等待指定的包.Packet collectors and listeners使用XMPPConnection 对象来创建实例. [newpage] 用Smack编写jabber客户端(中)

使用 Chat 和 GroupChat 传递消息

发送接受消息是即使通讯软件的核心功能.有两个类帮助完成这个任务.

org.jivesoftware.smack.Chat – 用来在两者之间传递信息. org.jivesoftware.smack.GroupChat – 用来加入一个组给很多人之间传递消息. 他们都是使用org.jivesoftware.smack.packet.Message 类来实现消息传递. 在某些环境下你可以绕开Chat GroupChat这两个高级的类手动传递消息或者是加入listener.

Chat

一个Chat对象在两个用户之间使用一个thread ID创建一个新的消息线程.下面的代码演示了如何 使用一个user创建一个新的Chat,然后向它发送文本消息.

// 假设我们创建了一个 XMPPConnection 对象 名称为 “connection”. Chat newChat = connection.createChat(“jsmith@jivesoftware.com ”); newChat.sendMessage(“Howdy!”); 实际上Chat.sendMessage(String) 方法是一个我们提供的创建一个Message对象的方便的方法,它使用String 参数作为body,然后发送这个message.如果你想要加入其它熟悉,请使用:

// 假设我们创建了一个 XMPPConnection 对象 名称为 “connection”. Chat newChat = connection.createChat(“jsmith@jivesoftware.com ”); Message newMessage = newChat.createMessage(); newMessage.setBody(“Howdy!”); message.setProperty(“favoriteColor”, “red”); newChat.sendMessage(newMessage);

Chat对象容许你侦听其它chat的回应.下面的代码实现了鹦鹉学舌–它会对任何人的话做出同样的回答.

// 假设我们创建了一个 XMPPConnection 对象 名称为 “connection”. Chat newChat = connection.createChat(“jsmith@jivesoftware.com ”); newMessage.setBody(“Hi, I’m an annoying parrot-bot! Type something back to me.”); while (true) {    //等待对方给我们发送消息 .    Message message = newChat.nextMessage();    // 把对方发给我们的消息原封不动的再发回去 .    newChat.sendMessage(message.getBody()); }

上面的代码使用了Chat.nextMessage()方法来得到下一个message,它是阻塞式的.当然你可以加入一个 listener来获取消息.

GroupChat

一个group chat运行你同时和一群用户聊天.你必须使用一个昵称来加入一个聊天组.下面代码演示了 如何加入聊天组,并且发送消息.

// 假设我们创建了一个 XMPPConnection 对象 名称为 “connection”. GroupChat newGroupChat = connection.createGroupChat(“test@jivesoftware.com ”); // 使用昵称 “jsmith"加入聊天组. newGroupChat.join(“jsmith”); // 发送消息给聊天组. newGroupChat.sendMessage(“Howdy!”);

发送和接受消息和Chat很类似就不详细讲述了.

聊天名单和在线状态

名单允许你跟踪其它用户的状态并且把用户分为好友,同事等等.

你可以通过XMPPConnection.getRoster()方法获取Roster对象,但是必须在你成功登陆后.

Roster 实体

每一个用户都被描述为一个Roster实体,它包包括:

一个 XMPP 地址 (e.g. jsmith@example.com ). 名称,昵称 (e.g. “Joe”). 它属于哪个列表,如好友,同事? 下面的代码打印出所有Roster实体的信息:

Roster roster = con.getRoster(); for (Iterator i=roster.getEntries(); i.hasNext(); ) {    System.out.println(i.next()); }

我们也提供了取得特定实体的方法,或者式组的方法.

在线状态

每一个用户列表中的对象都有在线状态.Roster.getPresence(String user)返回一个Presence对象描述用户的在线状态.

一个用户的presence要么是在线要么是离线.当一个用户在线时候,它他们的presence还可以包含一些额外的信息,例如当前他们 在做什么,他们是否乐于别打扰.

监听好友名单和Presence的改变

一般的来说都是用一个tree来显好友,例如,你看看下面的图:

presence信息通常都是随时变化的,当然也有可能名单的增加和删除.要监听名单和presence的改变, 必须使用RosterListener .下面的代码演示了如何监听并把任何presence改变打印出来.通常客户端 软件有显示的代码来完成更新用户名单UI的代码来反映变化.

final Roster roster = con.getRoster(); roster.addRosterListener(new RosterListener() {    public void rosterModified() {        // Ignore event for this example.    }

   public void presenceChanged(String user) {        // If the presence is unavailable then “null” will be printed,        // which is fine for this example.        System.out.println(“Presence changed: " + roster.getPresence(user));    } });

增加用户到用户列表

用户列表使用的允许模型,也就是只有对方容许你才能把他加入到你的用户名单中.这个保护了用户的 隐私.因此,你加入一个用户将会进入一个未决状态直到对方接受请求.

同时如果有一个用户请求把你加入,你必须对这个请求作出接受或反对的回应.Smack提供了三种策略:

自动接受所有请求. 自动反对所有请求. 交给用户手动处理.

你可以通过Roster.setSubscriptionMode(int subscriptionMode)来设置使用哪种策略.一个简单的客户端 可以使用自动同意模式,但是一个功能比较健全的客户端应该提供用户手动出来.在手动模式中,你必须提供 一个PacketListener 注册来诊听含有类型Presence.Type.SUBSCRIBE的Presence 包.

[newpage] Smack编写jabber客户端(下)

Smack提供了一个灵活的框架来处理接受到的数据包:

org.jivesoftware.smack.PacketCollector – 让你同步等待新的包. org.jivesoftware.smack.PacketListener – 异步通知你包的到来. 一个packet listener在事件风格的程序中使用,packet collector可以做轮循和阻塞操作.它们都可以 使用XMPPConnection 实例来创建. org.jivesoftware.smack.filter.PacketFilter 接口定义了那些包会分发到PacketCollector 或者是PacketListener.你可以在 org.jivesoftware.smack.filter 包中找到预定义的filters.

// 创建一个包 filter监听特定用户的消息.我们使用AndFilter来联合两个filters. PacketFilter filter = new AndFilter(new PacketTypeFilter(Message.class),        new FromContainsFilter(“mary@jivesoftware.com ”)); // 假设我们创建了名称为 “connection” XMPPConnection 对象.

// 首先使用上面的filter创建PacketCollector对象. PacketCollector myCollector = connection.createPacketCollector(filter);

// 接着, 我们创建一个 packet listener. 方便起见我们使用匿名内部类. PacketListener myListener = new PacketListener() {        public void processPacket(Packet packet) {            // 当包到的时候你做什么.        }    }; // 注册. connection.addPacketListener(myListener, filter);

标准Packet Filters

我们提供了一系列的filters,你可以实现 PacketFilter 接口来自定义实现. PacketTypeFilter – filters for packets that are a particular Class type. PacketIDFilter – filters for packets with a particular packet ID. ThreadFilter – filters for message packets with a particular thread ID. ToContainsFilter – filters for packets that are sent to a particular address. FromContainsFilter – filters for packets that are sent to a particular address. PacketExtensionFilter – filters for packets that have a particular packet extension. AndFilter – implements the logical AND operation over two filters. OrFilter – implements the logical OR operation over two filters. NotFilter – implements the logical NOT operation on a filter. 用Smack编写jabber客户端的基本知识都够了,更多内容请查阅官方资料和mail list请求帮助.

关联记录

暂无可公开显示的关联评论。评论与回复仍保存在本私有归档的 comments/ 目录;阅读界面默认隐藏邮箱、IP 和用户代理信息。