`

Android基于XMPP Smack Openfire开发IM【四】初步实现两个客户端通信

    博客分类:
  • xmpp
阅读更多

本博客要介绍的内容:
Openfire做服务器端,两个客户端:Spark、android模拟器。实现两个客户端之间的通信。


第一步:启动openfire服务器。(这里需要用到两个用户登录,前面的博客中已经说明如何添加用户了。)
[img]

[/img]


第二步:启动Spark客户端,如果您还没有Spark,下载请到:http://www.igniterealtime.org/downloads/index.jsp;安装简单。
我电脑的ip为:192.168.0.124,根据自己的修改。
安装后运行如下下图:
[img]





[/img]




第三步:启动eclipse中的项目(另一个客户端),代码如下:
package com.example.openfiretest;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.packet.Message;

import android.os.Bundle;
import android.os.Handler;
import android.app.Activity;
import android.content.Intent;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.Window;
import android.widget.CheckBox;
import android.widget.EditText;
import android.widget.Toast;

public class MainActivity extends Activity {
	
	
	
	private EditText accountEditText;
	private EditText passwordEditText;

	public void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		requestWindowFeature(Window.FEATURE_NO_TITLE);
		setContentView(R.layout.activity_main);
		accountEditText = (EditText) findViewById(R.id.username);
		passwordEditText = (EditText) findViewById(R.id.password);

		findViewById(R.id.login).setOnClickListener(new OnClickListener() {
			public void onClick(View v) {
				String account = accountEditText.getText().toString();
				String password = passwordEditText.getText().toString();
				if (account.equals("") || password.equals("")) {
					Toast.makeText(MainActivity.this, "账号或密码不能为空!",
							Toast.LENGTH_SHORT).show();
				} else {
					ClientConServer ccs = new ClientConServer(MainActivity.this);
					boolean b = ccs.login(account, password);
					// 如果登录成功
					if (b) {
						Toast.makeText(MainActivity.this, "登陆成功!",
								Toast.LENGTH_SHORT).show();
						
						Intent intent = new Intent(MainActivity.this,ChatActivity.class);
						startActivity(intent);
						
						
					} else {
						Toast.makeText(MainActivity.this, "登陆失败!",
								Toast.LENGTH_SHORT).show();
					}
				}
			}
		});
	}
	
}


package com.example.openfiretest;

import java.util.Collection;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.RosterGroup;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;


import android.content.Context;
import android.content.Intent;
import android.os.Handler;
import android.util.Log;
import android.widget.Toast;

public class ClientConServer {
	private static int PORT=5222;
	private Context context;
	public ClientConServer(Context context){
		this.context=context;

	}
	//这里收到消息后,通过广播将消息发送到需要的地方.哈哈,既然收到了服务器发送来的信息,如何处理自己决定。
	private Handler handler = new Handler(){  
        public void handleMessage(android.os.Message m) {  
            Message msg=new Message();  
            msg=(Message) m.obj; 
            //把从服务器获得的消息通过广播发送  
            Intent intent = new Intent("org.yhn.mes");  
            String[] message=new String[]{  
                    msg.getFrom(),  
                    msg.getBody()}; 
            System.out.println("==========收到服务器消息  From==========="+message[0].toString());
            System.out.println("==========收到服务器消息  Body==========="+message[1].toString());
            intent.putExtra("message", message);  
            context.sendBroadcast(intent);  
        };  
    };
	
	public boolean login(String a,String p){
			//ConnectionConfiguration config = new ConnectionConfiguration("192.168.0.124", PORT);
		/** 是否启用安全验证 */
			//config.setSASLAuthenticationEnabled(false);
		/** 是否启用调试 */
        //config.setDebuggerEnabled(true);
        /** 创建connection链接 */
			//XMPPConnection connection = new XMPPConnection(config);
		XMPPConnection connection = ConnUtil.getConnection();
		try {
			/** 建立连接 */
			connection.connect();
			
			
			/** 登录*/
			connection.login(a, p);
			/** 开启读写线程,并加入到管理类中*/
			//ClientSendThread cst=new ClientSendThread(connection);
			//cst.start();
			//ManageClientThread.addClientSendThread(a, cst);
			
			//获取用户组、成员信息。
			System.out.println("======开始获取组及用户==========");
			Roster roster = connection.getRoster();
			Collection<RosterGroup> entriesGroup = roster.getGroups();
			System.out.println("组的个数:"+entriesGroup.size());
			for(RosterGroup group: entriesGroup){
				Collection<RosterEntry> entries = group.getEntries();
				System.out.println("=========groupName==="+group.getName());
				for (RosterEntry entry : entries) {
					//Presence presence = roster.getPresence(entry.getUser());
					//Log.i("---", "user: "+entry.getUser());
					System.out.println("组成员的名字:"+entry.getName());
					System.out.println("组成员的user:"+entry.getUser());
					
					//Log.i("---", "tyep: "+entry.getType());
					//Log.i("---", "status: "+entry.getStatus());
					//Log.i("---", "groups: "+entry.getGroups());
				}
			}
			System.out.println("======结束获取组及用户==========");
			
			
			//在登陆以后应该建立一个监听消息的监听器,用来监听收到的消息:
			ChatManager chatManager = connection.getChatManager();
			chatManager.addChatListener(new MyChatManagerListener());
			
			
			return true;
		} catch (XMPPException e) {
			e.printStackTrace();
		}
		return false;
	 }
	/** message listener*/  
    class MyChatManagerListener implements ChatManagerListener {  
    	
    	
        public void chatCreated(Chat chat, boolean arg1) {  
            chat.addMessageListener(new MessageListener(){  
                public void processMessage(Chat arg0, Message msg) {  
                    /**通过handler转发消息*/  
                    android.os.Message m=handler.obtainMessage();  
                    m.obj=msg;  
                    m.sendToTarget(); 
                	
                	
                }  
            });  
        } 
    }
}


package com.example.openfiretest;

import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.XMPPConnection;

public class ConnUtil {
	
	
	private static XMPPConnection connection;
	public static synchronized XMPPConnection getConnection(){
		if(connection!=null){
			return connection;
		}else{
			ConnectionConfiguration config = new ConnectionConfiguration("192.168.0.124", 5222);
			/** 是否启用安全验证 */
			config.setSASLAuthenticationEnabled(false);
			/** 是否启用调试 */
	        //config.setDebuggerEnabled(true);
	        /** 创建connection链接 */
			connection = new XMPPConnection(config);
		
		}
		
		return connection;
		
	}
}


package com.example.openfiretest;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;

import android.app.Activity;
import android.content.Intent;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.Window;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

public class ChatActivity extends Activity {  
    String account;  
    String chatNick;  
    public static String chatContents;  
    TextView chatTextView;  
      
     public void onCreate(Bundle savedInstanceState) {  
            super.onCreate(savedInstanceState);  
            requestWindowFeature(Window.FEATURE_NO_TITLE);  
            setContentView(R.layout.activity_chat);  
            /** 设置top面板信息*/  
            //chatNick=getIntent().getStringExtra("nick");  
            //account=getIntent().getStringExtra("account");  
           
            //这里的用户昵称和账号是手动添加的。
            chatNick = "忍者无敌笑哈哈";
            account = "number1@admin-pc";
            TextView nick_tv=(TextView) findViewById(R.id.chat_top_nick); 
            nick_tv.setText(chatNick);  
              
            Button send_btn=(Button) findViewById(R.id.chat_btn_send);  
            send_btn.setOnClickListener(new OnClickListener(){  
                public void onClick(View arg0) {  
                    EditText input=(EditText) findViewById(R.id.chat_input);  
                    String content=input.getText().toString();  
                    try {  
                    	XMPPConnection connection = ConnUtil.getConnection();
                        ChatManager cm = connection.getChatManager();  
                        Chat chat=cm.createChat(account, new MessageListener(){  
                            public void processMessage(Chat arg0, Message msg) {  
                                Log.i("---", msg.getFrom()+"说:"+msg.getBody());  
                                //添加消息到聊天窗口  ,
                            }  
                        });  
                        Message m=new Message();  
                        m.setBody(content);  
                        chat.sendMessage(m);  
                    } catch (XMPPException e) {  
                        e.printStackTrace();  
                    }  
                }  
            });  
     }  
}  


启动后如下图:
[img]



[/img]



第四步:这时,Spark客户端的篮球组中多了一个人。(不清楚组添加、用户添加的请看前面的博客);
[img]

[/img]



第五步:手机模拟器发送消息给Spark,输入信息后点击发送,
[img]

[/img]


第六步:Spark给手机模拟器发送消息,输入消息后按Ctrl+Enter发送,手机端把收到的消息,通过控制台打印。
[img]



[/img]


第七步:openfire服务器端发送消息给所有的客户端:
[img]





[/img]


over

菜鸟学习openfire,如有不妥之处,多多批评。
  • 大小: 29 KB
  • 大小: 50 KB
  • 大小: 64 KB
  • 大小: 16.6 KB
  • 大小: 27.3 KB
  • 大小: 25.4 KB
  • 大小: 24.2 KB
  • 大小: 63.8 KB
  • 大小: 26.8 KB
  • 大小: 27.5 KB
  • 大小: 24.7 KB
  • 大小: 19.2 KB
  • 大小: 37.1 KB
6
0
分享到:
评论
4 楼 tangyunliang 2014-05-14  
      
大哥
你太历害了
谢谢
3 楼 u013015029 2014-05-08  
LZ,请问下,在// 添加消息到聊天窗口   , 这里获取EditText的内容 msg.getBody() 为什么是空的呢?
2 楼 Silence222 2013-09-22  
LZ有没有发现,客户端搁置时间长的话会收不到消息?怎么解决的?
1 楼 wangyezidong 2013-09-15  
请问LZ有demo吗发给我看看

相关推荐

    Android 基于xmpp协议,smack包,openfire服务端的高仿QQ的即时通讯实现.zip

    这个项目就是基于XMPP(Extensible Messaging and Presence Protocol)协议,使用Smack库,并结合Openfire服务器实现的。现在,我们将深入探讨这些关键组件以及如何将它们整合到Android应用中。 1. **XMPP协议**:...

    Android-XMPP-openfire-实现IM

    在Android平台上实现即时通讯(Instant Messaging,简称IM)系统,XMPP(Extensible Messaging and Presence Protocol)是一种常用的标准协议,而Openfire是一款基于XMPP的开源服务器软件。本项目"Android-XMPP-...

    基于openfire为服务器的xmpp即时通信 Android客户端

    综上所述,基于openfire的XMPP即时通信Android客户端开发涉及到服务器配置、协议理解、Android编程等多个技术领域,开发者需要具备扎实的技术基础和实践经验,才能成功构建一个高效、稳定的即时通讯系统。

    Android代码-基于openfire和smack的安卓xmpp客户端

    【Android代码-基于openfire和smack的安卓xmpp客户端】是一个项目,它实现了使用XMPP协议在Android设备上创建一个客户端应用。XMPP(Extensible Messaging and Presence Protocol)是一种实时通信协议,常用于实现...

    XMPP_OPenfire即时通讯IM-android版

    在这个“XMPP_OPenfire即时通讯IM-android版”项目中,我们关注的是在Android平台上利用Smack库实现与Openfire服务器的交互。 Smack是一个流行的Java库,支持XMPP协议,允许开发者在Java应用程序中实现IM功能。在这...

    Android 基于XMPP协议IM聊天实现(客户端+服务端) 源码

    在本文中,我们将深入探讨如何使用XMPP协议在Android平台上实现一个完整的即时通讯(IM)系统,包括客户端和服务器端的实现。XMPP(Extensible Messaging and Presence Protocol)是一种基于XML的开放标准,广泛用于...

    Android 基于xmpp协议,smack包,openfire服务端的高仿QQ的即时通讯实现.

    Android 基于xmpp协议,smack包,openfire服务端的高仿QQ的即时通讯实现。实现了注册,登录,读取好友列表,搜索好友,添加分组,添加好友,删除好友,修改心情,两个客户端之间的信息发送与接收,监听发送来的好友...

    基于openfire 的android IM 即时通讯smack的android IM

    本教程将聚焦于如何利用Openfire服务器和Smack库构建一个基于Android的IM应用。 Openfire是一款开源的、基于XMPP协议的实时通讯服务器。XMPP(Extensible Messaging and Presence Protocol)是一种标准通信协议,...

    基于Smack3.0.4+ Openfire3.10.2开发之Android 客户端之三

    总之,基于Smack 3.0.4和Openfire 3.10.2的Android客户端开发涉及用户认证、服务器交互等多个环节,开发者需要熟练掌握这两个工具的用法,并了解XMPP协议的相关知识,才能构建出高效稳定的即时通讯应用。

    Android使用XMPP协议、OpenFire服务器和Smack类库实现即时通信

    在Android平台上实现即时通信(Instant Messaging,IM)功能,开发者常常会选择使用XMPP(Extensible Messaging and Presence Protocol)协议。XMPP是一种基于XML的开放标准,用于即时消息传递和在线状态跟踪,它...

    Android XMPP 即时通讯 Openfire二次开发资料,非常齐

    Android XMPP 即时通讯 Openfire 二次开发是基于 XMPP 协议的即时通讯解决方案,使用 Openfire 作为服务器端,Spark 作为客户端,Smack 作为 XMPP 传输协议的实现。XMPP 协议是一个基于 XML 的消息传递协议,...

    android使用smack,openfire通信

    Android上最常用的组合asmack +openfire。Asmack是smack的android版,是对xmpp协议进行...Openfire是一个开源的IM服务器,基于Xmpp实现。换句话说使用xmpp开发即时通讯应用的话,服务器端已经开发好了,就是openfire。

    IM(Spark+Smack+Openfire)开发资料详细说明文档

    总之,IM(Spark+Smack+Openfire)开发涉及到多个层次的技术,包括客户端开发、服务器搭建、协议处理和安全性等。通过深入学习提供的文档和支持文件,开发者可以构建出稳定、高效的即时通讯系统。

    android XMPP openfire

    Android XMPP(Extensible Messaging and Presence Protocol)是用于在Android平台上实现即时通讯(IM)的一种技术,它基于开放源码的XMPP协议栈。Openfire是XMPP服务器的一个实现,用Java编写,提供了实时、双向的...

    android openfire xmpp smack即时通讯,包括:聊天发生文字,表情,图片,语音等.zip

    本项目聚焦于Android平台上的即时通讯实现,利用了开源的服务器端软件Openfire以及客户端库Smack。Openfire基于XMPP(Extensible Messaging and Presence Protocol)协议,这是一种开放标准,被广泛用于构建即时通讯...

    Android XMPP例子(Openfire+asmack+spark)

    综上所述,这个例子涵盖了Android即时通讯应用开发的关键环节,从选择合适的服务器和客户端库,到具体实现客户端功能,再到测试和优化,都涉及到一系列的技术点,对于学习和理解Android IM应用的开发流程有着重要的...

    openfire+smack开发webim笔记

    Smack是IgniteRealtime组织开发的一个Java库,专门用于实现XMPP协议。它提供了与XMPP服务器交互的各种组件和工具,使得开发者可以轻松构建基于XMPP的Java应用程序,包括WebIM。 【五】WebIM的实现技术 1. Ajax无...

    openfire+spark+smack开发流程.pdf

    在本文中,我们将详细介绍OpenFire、Spark和Smack三个组件在XMPP IM开发中的作用,以及如何使用它们来开发一个完整的XMPP IM系统。 首先,让我们了解一下XMPP是什么?Extensible Messaging and Presence Protocol,...

    Android IM之基于Openfire+Smack的聊天服务器的搭建与测试

    总结来说,通过Openfire和Smack,我们可以轻松地搭建一个基础的Android IM应用,实现用户登录、聊天、文件传输等功能。不过,实际项目中还需要考虑性能优化、用户体验、错误处理等多方面因素,以打造一个稳定、高效...

    android基于xmpp即时通信-高仿QQ

    在Android平台上实现基于XMPP(Extensible Messaging and Presence Protocol)的即时通信系统,可以让你创建一个类似QQ的应用,实现用户间的实时消息传递、在线状态显示等功能。以下是对这个主题的详细解析: 一、...

Global site tag (gtag.js) - Google Analytics