Android openfire smack 源码

592jsq

一些看smack时的笔记东西，和实现基本功能的源码，包括添加好友，创建群，接受邀请，聊天等，业务逻辑和UI分离，源码不知道怎么上传，这个编辑框上没有上传的按钮，怎么搞。
    一、注册
Registration reg = new Registration();
reg.setType(IQ.Type.SET);
reg.setTo(ConnectionUtils.getConnection()
                                .getServiceName());
reg.setUsername(phoneCode.getText().toString());
reg.setPassword(passwd);
reg.addAttribute("android", "geolo_createUser_android");
PacketFilter filter = new AndFilter(new PacketIDFilter(
                                reg.getPacketID()), new PacketTypeFilter(
                                IQ.class));
PacketCollector collector = ConnectionUtils.getConnection().
createPacketCollector(filter);
ConnectionUtils.getConnection().sendPacket(reg);
result = (IQ) collector.nextResult(SmackConfiguration
                                .getPacketReplyTimeout());
                        // Stop queuing results
collector.cancel();// 停止请求results（是否成功的结果）
if (result == null) {
Toast.makeText(getApplicationContext(), "服务器没有返回结果", Toast.LENGTH_SHORT).show();
} else if (result.getType() == IQ.Type.ERROR) {
if (result.getError().toString()
                        .equalsIgnoreCase("conflict(409)")) {
    Toast.makeText(getApplicationContext(), "这个账号已经存在", Toast.LENGTH_SHORT).show();
    } else {
        Toast.makeText(getApplicationContext(), "注册失败",
                                        Toast.LENGTH_SHORT).show();
    }
} else if (result.getType() == IQ.Type.RESULT) {
Toast.makeText(getApplicationContext(), "恭喜你注册成功", Toast.LENGTH_SHORT).show();
}
    二、登陆
// 无连接
if (!ConnectionUtils.getConnection().isConnected())
                        return false;
if (ConnectionUtils.getConnection().isAuthenticated()) {
                        return true;
} else {
// 用户登录
ConnectionUtils.getConnection().login(
util.getString("userCode", ""),util.getString("passwd", ""));
return ConnectionUtils.getConnection().isAuthenticated();
}
    三、发送用户状态
Presence presence = new Presence(Presence.Type.available);
presence.setStatus("Gone fishing");
ConnectionUtils.getConnection().sendPacket(presence);
    四、检索信息
Smack提供以下两种方法阅读收到的信息包：PacketListener和PacketCollector。它们都使用PacketFilter的实例来决定应该处理哪个信息包。信息包监听器（packet listener）用于事件类型的设计，而信息包收集器（packet collector）有一个信息包的结果队列，你可以对其实施polling和blocking操作。所以，信息包监听器在你收到任何一个信息包，且你想对其进行操作时是有用的，而信息包收集器在你想等待某个特殊的信息包时是有用的。信息包收集器和监听器可以通过XMPPConnection的实例来创建。
    1、PacketListener
PacketFilter packetFilter = new AndFilter(new PacketIDFilter(
                    jp.getPacketID()), new PacketTypeFilter(IQ.class));
            // 监听所有的包
            con.addPacketListener(new PacketListener() {
                public void processPacket(Packet packet) {
                    if (packet instanceof MyIQ) {
                        MyIQ iq = (MyIQ) packet;
                        if (iq.getType() == IQ.Type.RESULT) {
                            System.out.println("返回内容： "
                                    + iq.toXML());
                        }
                    } else {
                        System.out.println("其他消息:"+packet.toXML());
                    }
                }
            }, packetFilter);
2、PacketCollector
    PacketFilter filter = new AndFilter(new PacketIDFilter(
                                reg.getPacketID()), new PacketTypeFilter(
                                IQ.class));
    PacketCollector collector = ConnectionUtils
    .getConnection().createPacketCollector(filter);
    ConnectionUtils.getConnection().sendPacket(reg);
    result = (IQ) collector.nextResult(SmackConfiguration
                                .getPacketReplyTimeout());

    五、添加一个好友
        /**
         * The user and subscriber have no interest in each other's presence.
         */
        none,
none：是用户和自己roster中的好友彼此不关心，既不想把自己的presence状态告诉对方，也不愿意收到对方presence更新消息

        /**
         * The user is interested in receiving presence updates from the subscriber.
         */
        to,
to：是关心roster中好友的presence状态消息，而不将自己的消息告诉对方

        /**
         * The subscriber is interested in receiving presence updates from the user.
         */
        from,
from：是只关心，接受对方的状态消息，而不将自己的消息告诉对方

        /**
         * The user and subscriber have a mutual interest in each other's presence.
         */
        both,
both:即收取对方状态更新，又将自己的更新告知对方
        /**
         * The user wishes to stop receiving presence updates from the subscriber.
         */
        remove
Remove :将对方干掉，不再关心他的任何信息。

在申请添加一个好友，当对方Roster.setDefaultSubscriptionMode(SubscriptionMode.manual)时，此时添加的好友为“挂起”状态。对方设置监听PacketFilter filter = new PacketFilter() {

            @Override
            public boolean accept(Packet packet) {
                if (packet instanceof Presence) {
                    Presence presence = (Presence) packet;
                    if (presence.getType().equals(Presence.Type.subscribe)) {
                        return true;
                    }
                }
                return false;
            }
        };
允许添加好友则回复消息Presence presence = new Presence(Presence.Type.subscribed);
            presence.setTo(packet.getFrom());
            ConnectionUtils.getConnection().sendPacket(presence);
此时邀请人的好友状态为to。而被添加的user的subscription状态为from。如果要改为both。Both users need to subscribe to each other and accept the subscription request they received.
被邀请人应当也发送一个邀请请求。
Presence subscription = new Presence(Presence.Type.subscribe);
            subscription.setTo(packet.getFrom());
            ConnectionUtils.getConnection().sendPacket(subscription);
    六、设置昵称nickname
    RosterEntry entry = connection.getRoster().getEntry(user.getJID());
    entry.setName(nickname);这个方法会设置昵称自动发送给服务器，服务器修改后会发布一个update操作。
    七、组添加或删除成员
    添加一个好友到组，当组存在时，添加到当前存在组，不存在时则先创建一个组，再将好友添加进去，如果从组中删除一个好友，如果当前好友是组成员最后一个，则同时删除组。
/**
     * 把一个好友添加到一个组中
     *
     * @param user
     * @param groupName
     */
    public static void addUserToGroup(final User user, final String groupName,
            final XMPPConnection connection) {
        if (groupName == null || user == null)
            return;
        // 将一个rosterEntry添加到group中是PacketCollector，会阻塞线程
        new Thread() {
            public void run() {
RosterGroup group = connection.getRoster().getGroup(groupName);
                // 这个组已经存在就添加到这个组，不存在创建一个组
                RosterEntry entry = connection.getRoster().getEntry(
                        user.getJID());
                try {
                    if (group != null) {
                        if (entry != null)
                            group.addEntry(entry);
                    } else {
                        RosterGroup newGroup = connection.getRoster()
                                .createGroup(groupName);
                        if (entry != null)
                            newGroup.addEntry(entry);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }.start();
    }

    /**
     * 把一个好友从组中删除
     *
     * @param user
     * @param groupName
     */
    public static void removeUserFromGroup(final User user,
            final String groupName, final XMPPConnection connection) {
        if (groupName == null || user == null)
            return;
        new Thread() {
            public void run() {
RosterGroup group = connection.getRoster().getGroup(groupName);
                if (group != null) {
                    try {
RosterEntry entry = connection.getRoster().getEntry(
                                user.getJID());
                        if (entry != null)
                            group.removeEntry(entry);
                    } catch (XMPPException e) {
                        e.printStackTrace();
                    }
                }
            }
        }.start();
    }
    八、申请创建联系人
    public void createEntry(String user, String name, String[] groups)
    发送一个Presence.Type.subscribe邀请请求。
    九、删除联系人
    public void removeEntry(RosterEntry entry)
    十、创建chat
    每个chat对应一个线程，所有的线程都保存在ChatManager.threadChats中。Chat在ChatManager.jidChats中以jid为key保存，在ChatManager.baseJidChats中以Jid的@前半部分保存。
    获得chat的方法：
        public Chat getThreadChat(String thread)


本文来自：592网络加速器