android上的socket通信的开源框架有哪些
xmpp协议的即时通讯方案，openfire androidpn，等等。它们都是使用了apache mina开发，但是这些东西基本都需要二次改造开发。而且改动还很大，我也看过这些东西的源码，发现代码结构不太理想，耦合的情况太多，实在不好扩展。所谓XMPP 协议。只不过是别人使用mina 自定义了一个消息编码解码协议。通俗的讲就是，xml形式消息的编码与解码，我们完全没有必要在国外这套不成熟的openfire 与xmpp 上耗费过多的精力去研究，我们完全可以通过apache mina 自定义自己的通讯协议，并可以为它使用自己的名字。我们不要盲目崇拜国外的有些东西，自己掌握原理，才是最重要的，各位切记~
这套IM系统为我个人自主开发 使用了 apache mina ，主要功能为 服务端和客户端，客户端 到客户端的即时通信，可以支持包括文字 图片，语音等任何消息形式 服务端使用的 struts2+spring3和 apache mina android端 也使用的apache mina。这套IM系统结构还是非常清晰合理的，非常容易扩展和改造，下面是android版本 的 demo的目的是只是一个演示 ，可以参照它的代码，使用这套系统开发自己的东西，核心价值是一套高灵活性，相对标准化的即时通讯解决方案，即时聊天只是它的一种运用途径！
androidpn tomcat版有什么优点
在Androidpn的底层主要采用的两大框架mina和openfire两大框架，其中mina主要为底层数据传输的Socket框架。下面简单的介绍一下Socket框架 Apache Mina Server 是一个网络通信应用框架，也就是说，它主要是对基于TCP/IP、UDP/IP协议栈的通信框架(也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等),Mina 同时提供了网络通信的Server 端、Client 端的封装，无论是哪端，Mina 在整个网通通信结构中都处于如下的位置： 可见Mina 的API 将真正的网络通信与我们的应用程序隔离开来 ，你只需要关心你要发送、接收的数据以及你的业务逻辑即可。同样的，无论是哪端，Mina 的执行流程如下所示： (1). IoService：这个接口在一个线程上负责套接字的建立，拥有自己的Selector，监听是否有连接被建立。 (2). IoProcessor：这个接口在另一个线程上负责检查是否有数据在通道上读写，也就是说它也拥有自己的Selector，这是与我们使用JAVA NIO 编码时的一个不同之处，通常在JAVA NIO 编码中，我们都是使用一个Selector，也就是不区分IoService与IoProcessor 两个功能接口。另外，IoProcessor 负责调用注册在IoService 上的过滤器，并在过滤器链之后调用IoHandler。 (3). IoFilter：这个接口定义一组拦截器，这些拦截器可以包括日志输出、黑名单过滤、数据的编码（write 方向）与解码（read 方向）等功能，其中数据的encode 与decode是最为重要的、也是你在使用Mina 时最主要关注的地方。 (4). IoHandler：这个接口负责编写业务逻辑，也就是接收、发送数据的地方。 通过Mina的原理我们研究androidpn的运行流程不能看出，如下： 1.spring初始化并启动过程，调用NioSocketAcceptor。2.NioSocketAcceptor开始执行调用IoProcessor.3.IoProcessor开始调用FilterChain。FilterChain调用相关的IoFilter的。其中ProtocolCodecFilter的过滤器调用了org.androidpn.server.xmpp.codec.XmppCodecFactory进行编码。4.XmppIoHandler实现自IoHanlder并调用通过openfire 的XMLLightweightParser解析相关的业务逻辑。5.根据解析的信息调用xmpp并处理相关信息。AndroidPN(Android Push Notification) 是一个基于 XMPP 协议的 Java 开源推送通知实现，它包含了完整的客户端和服务端。AndroidPN基于 Openfire 下的一些开源项目构建。AndroidPN服务器包含两个部分， 一个是侦听在5222端口上的XMPP服务，负责与客户端的XMPPConnection类进行通信，作用是用户注册和身份认证，并发送推送通知消息。 另外一部分是Web服务器，采用一个轻量级的HTTP服务器，负责接收用户的Web请求。最上层包含四个组成部分，分别是SessionManager，Auth Manager，PresenceManager以及Notification Manager。 SessionManager负责管理客户端与服务器之间的会话。 Auth Manager负责客户端用户认证管理。 Presence Manager负责管理客户端用户的登录状态。 NotificationManager负责实现服务器向客户端推送消息功能。 IQHandler消息处理器的类： IQHandler：消息处理器抽象类。 IQAuthHandler：权限协议的消息处理类，消息的类型为：jabber:iq:auth IQRegisterHandler：用户注册的消息处理类，消息类型为： jabber:iq:register IQRosterHandler：用户消息交互类，消息类型为：jabber:iq:roster PresenceUpdateHandler：用户状态展现变化处理类。内部调用，不具有类型。
android端怎么接收openfire服务器发送过来的消息
android客户端接收 openfire 服务器发送来的消息：客户端代码如下：Java代码 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(); } else { Toast.makeText(MainActivity.this, "登陆失败！", Toast.LENGTH_SHORT).show(); } } } }); } } 然后在登陆以后添加一个监听消息的监听器，用来监听收到的消息（代码89、90行）： Java代码 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); 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 entriesGroup = roster.getGroups(); System.out.println("组的个数："+entriesGroup.size()); for(RosterGroup group: entriesGroup){ Collection 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()); //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(); } }); } } } 启动android客户端，进行登录然后在openfire的管理控制台，会话-工具中发送消息给所有在线用户即可看到打印信息：在管理控制台发送的消息
