- 浏览: 516545 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
tangyunliang:
大哥你太历害了谢谢
Android基于XMPP Smack Openfire开发IM【四】初步实现两个客户端通信 -
u013015029:
LZ,请问下,在// 添加消息到聊天窗口 , 这里获取Ed ...
Android基于XMPP Smack Openfire开发IM【四】初步实现两个客户端通信 -
endual:
怎么保持会话,我搞不懂啊
Android基于XMPP Smack Openfire开发IM【一】登录openfire服务器 -
donala_zq:
显示:[2013-11-30 11:50:36 - Andro ...
android-----------新浪微博 -
donala_zq:
哥,运行不了啊
android-----------新浪微博
本博客要介绍的内容:
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,如有不妥之处,多多批评。
评论
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开发IM【三】客户端接收服务器发送的消息
2013-03-26 16:12 8858Demo需求:android客户端接收服务器发送来的消息。 ... -
Android基于XMPP Smack Openfire开发IM 【二】获取好友列表
2013-03-26 11:28 3594第一步,在openfire后台中创建一些用户,并添加两个组。我 ... -
Android基于XMPP Smack Openfire开发IM【一】登录openfire服务器
2013-03-25 17:41 5856第一,安装好openfire后,启动openfire进入后台。 ... -
Openfire 的安装和配置
2013-02-05 13:07 14121、 下载最新的openfire安装文件 官方下载站点:ht ... -
本文介绍AndroidPn项目实现推送的使用过程
2013-02-05 12:41 1721在上一篇文章中提到在A ...
相关推荐
Android上最常用的组合asmack +openfire。Asmack是smack的android版,是对xmpp协议进行...Openfire是一个开源的IM服务器,基于Xmpp实现。换句话说使用xmpp开发即时通讯应用的话,服务器端已经开发好了,就是openfire。
android下的XMPP对应smack4.1.4下实现注册,登录,单聊文本,语音,图片发送,添加好友,修改密码,注销等功能(Androidstuido开发环境)
搭建openfire后,用 smack api 连接服务的测试demo。运行官网范例,发现其实不易,smack4.1.4中缺少很多依赖于第3方的jar包。不断debug甚是痛苦,终于跑起来了。分享出来给只是想要个初体验的同学。
主题:一个简单的即时通信客户端,由MySQL数据库 + Openfire服务器 + Android客户端 ( Smack 4.19 ) 组成 功能:注册账号、登录和退出系统、获取好友列表、添加和删除好友、收发文本消息、分享位置(基于百度地图SDK...
jxmpp-core-0.5.0-alpha7 jxmpp-util-cache-0.5.0-alpha7 smack-android-4.1.6 smack-core-4.1.6 smack-extensions-4.1.6 smack-im-4.1.6 smack-sasl-provided-4.1.6 smack-tcp-4.1.6
smack用于android移动端的开发,可以结合openfire / tiger 使用,进行im通信
OpenFire是开源的、基于可拓展通讯和表示协议(XMPP)、采用Java编程语言开发的实时协作服务器。 Openfire安装和使用都非常简单,并利用Web进行管理。单台服务器可支持上万并发用户。 1、首先到网址 下载OpenFire...
openfire4.5.3版本下载!!openfire是基于XMPP协议的即时通讯框架,spark是pc客户端应用,类似qq客户端。smack提供了与XMPP服务通信的开发库。在实际应用中,可以用openfire做二次开发!
Smack主要是xmpp协议的实现,提供了一套很好的api,所以下面操作xmpp都是通过使用Smack的api来实现,从4.1.0开始,它就支持Android了,所以我们直接使用Smack即可,当然在这不支持之前是使用Asmack这个包的,里面...
java smack源码 xmpp-push-notification ...开源组件的一套整合方案,服务端基于Openfire、客户端基于Smack。详细的实现方式网上有不少文章。 androidpn 客户端需要用到一个基于java的开源XMPP协议包asmack,这个包同
使用smack实现xmpp聊天工具的一些细节和笔记,整理了下,供大家参考吧 版本1.0 会陆续更新加入新的
smack源码
1. 提供最新的2014-6-20的asmack jar包。 2. 可以参考smack的API文档进行开发。 3. 只是简单地针对openfire服务器进行connect和Login,并下拉了局域网用户数据信息。 4. Demo待完善中……
xmpp聊天IM开发android使用jar,
资料中详细分析SMACK类库的指令,是IM即时通讯编程的开源api
openfire+spark+red5的详细安装指南.