使用Mina框架开发 QQ Android 客户端

Apache MINA是一个网络应用程序框架，用来帮助用户简单地开发高性能和高可靠性的网络应用程序。它提供了一个通过Java NIO在不同的传输例如TCP/IP和UDP/IP上抽象的事件驱动的异步API。

　　Apache MINA 也称为:
　　● NIO 框架库
　　● 客户端服务器框架库
　　● 一个网络套接字库
　　MINA虽然简单但是仍然提供了全功能的网络应用程序框架：
　　● 为不同的传输类型提供了统一的API:
　　○ 通过Java NIO提供TCP/IP 和 UDP/IP支持
　　○ 通过RXTX提供串口通讯(RS232)
　　○ In-VM管道通讯
　　○ 你能实现你自己的API!
　　● 过滤器作为一个扩展特性; 类似Servlet过滤器
　　● 低级和高级的API:
　　○ 低级: 使用字节缓存(ByteBuffers)
　　○ 高级: 使用用户定义的消息对象(objects)和编码(codecs)
　　● 高度定制化线程模型:
　　○ 单线程
　　○ 一个线程池
　　○ 一个以上的线程池(也就是SEDA)
　　● 使用Java 5 SSL引擎提供沙盒(Out-of-the-box) SSL · TLS · StartTLS支持
　　● 超载保护和传输流量控制
　　● 利用模拟对象进行单元测试
　　● JMX管理能力
　　● 通过StreamIoHandler提供基于流的I/O支持
　　● 和知名的容器(例如PicoContainer、Spring)集成
　　● 从Netty平滑的迁移到MINA， Netty是MINA的前辈。

MINA 基本类的描述 ： 
IoAccepter 相当于网络应用程序中的服务器端 
IoConnector 相当于客户端 
IoSession 当前客户端到服务器端的一个连接实例 
IoHandler 业务处理逻辑 
IoFilter 过滤器用于悬接通讯层接口与业务层接口

要编写和运行一个基于Apache MINA 2.0的程序，需要JDK 5.0以上版本,

下面看一个domo：

准备工作：

mina-core-2.0.0-M6.jar
slf4j-api-1.5.2.jar

在官网下载到mina，找出这几个jar，添加到项目，

服务端的代码：

1. public class MainFrame {
2. private static final int PORT=5469;
3. public static void main(String[] args) throws Exception{
4. IoAcceptor acceptor=new NioSocketAcceptor();
5. IoFilter filter=new ProtocolCodecFilter(new TextLineCodecFactory());
6. acceptor.getFilterChain().addLast("vestigge", filter);
7. acceptor.setHandler(new ServerHandler());
8. acceptor.bind(new InetSocketAddress(PORT));
9. System.out.println( "服务器正在监听端口" + PORT +"...");
10. }
11. }

其中new ServerHandler()传入的是实现了IoHandler接口的类，代码如下：

1. public class ServerHandler extends IoHandlerAdapter {
2. @Override
3. public void messageReceived(IoSession session, Object message)
4. throws Exception {
5. System.out.println("收到客户端消息：" + message.toString());
6. }
7. @Override
8. public void exceptionCaught(IoSession session, Throwable cause)
9. throws Exception {
10. System.out.println("服务器出现异常：" +cause);
11. }
12. }

重写了父类中的messageReceived()和exceptionCaught()

一般在messageReceived()中对客户端的请求进行业务，逻辑处理

下面在命令行用telnet测试一下，

如果是win 7没有telnet，找到“打开或关闭Windows功能” ,找到telnet客户端和telnet服务端，勾选即可，

在命令行下输入telnet 127.0.0.1 5469

然后再telnet窗口中输入几个字符回车，在控制台可以看到服务器成功收到了消息：

上节中通过一个简单的例子，对Mina框架有了大体的了解，在上节的基础上，看看 怎样实现客户端与服务端的通信，

废话不多说了，直接看代码：

1. public class Test {
2. public static void main(String[] args) throws Exception{
3. SocketConnector connector = new NioSocketConnector();
4. IoFilter filter = new ProtocolCodecFilter(new TextLineCodecFactory());
5. connector.getFilterChain().addLast("vestigge", filter);
6. SocketAddress soketAddress = new InetSocketAddress("127.0.0.1", 5469);
7. connector.setHandler(new ClientHandler());
8. ConnectFuture future= connector.connect(soketAddress);
9. future.join();
10. if (!future.isConnected()) {
11. System.out.println("连接服务器失败");
12. return;
13. }
14. future.getSession().write("hello");
15. }
16. }

可以看到代码与服务器端的代码很像，也是非常的简单，这就是框架的好处，不用再重复发明*，省了不少事，

1. public class ClientHandler extends IoHandlerAdapter {
2. public void messageReceived(IoSession arg0, Object message) throws Exception {
3. System.out.println("收到服务器消息：" + message.toString());
4. }
5. public void exceptionCaught(IoSession arg0, Throwable arg1)
6. throws Exception {
7. }
8. }

效果演示：

登陆界面的文章 http://www.linuxidc.com/Linux/2012-11/73437.htm

就不在重复了，直接看登陆的代码，

用Mina传递字符串上节已经看过了，要实现传递对象，也非常简单，只需要修改一下过滤器：

chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));

在Android客户端，登陆的Activity中：

1. public class LoginActivity extends Activity{
2. private EditText accountEditText;
3. private EditText passwordEditText;
4. private CheckBox remeberCheckBox;
5. public void onCreate(Bundle savedInstanceState) {
6. super.onCreate(savedInstanceState);
7. requestWindowFeature(Window.FEATURE_NO_TITLE);
8. setContentView(R.layout.activity_login);
9. accountEditText=(EditText) findViewById(R.id.login_account);
10. passwordEditText=(EditText) findViewById(R.id.login_password);
11. remeberCheckBox=(CheckBox) findViewById(R.id.login_remember);
12. findViewById(R.id.login_login).setOnClickListener(new OnClickListener(){
13. public void onClick(View v) {
14. if(accountEditText.getText().toString().equals("") ||
15. passwordEditText.getText().toString().equals("")){
16. Toast.makeText(LoginActivity.this, "账号或密码不能为空！", Toast.LENGTH_SHORT).show();
17. }else{
18. User user=new User();
19. user.setAccount(Integer.parseInt(accountEditText.getText().toString()));
20. user.setPassword(passwordEditText.getText().toString());
21. user.setOperation(VQMessageType.LOGIN);
22. boolean b=new VQClient().sendLoginInfo(user);
23. //如果登录成功
24. if(b){
25. Toast.makeText(LoginActivity.this, "登陆成功！", Toast.LENGTH_SHORT).show();
26. startActivity(new Intent(LoginActivity.this,MainActivity.class));
27. }else{
28. Toast.makeText(LoginActivity.this, "连接超时，登陆失败！", Toast.LENGTH_SHORT).show();
29. }
30. }
31. }
32. });
33. }
34. }

可以看到会调用VQClient这个类中的方法去发送登陆请求，VQClient的实现：

1. public class VQClient {
2. private static int PORT=5469;
3. public boolean sendLoginInfo(User u){
4. boolean b=false;
5. System.setProperty("java.net.preferIPv6Addresses", "false");//2.2会有ipv6的问题，
6. SocketConnector connector = new NioSocketConnector();
7. connector.setConnectTimeoutMillis(300000);
8. DefaultIoFilterChainBuilder chain=connector.getFilterChain();
9. chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
10. SocketSessionConfig cfg = connector.getSessionConfig();
11. cfg.setUseReadOperation(true);
12. IoSession session = connector.connect(new InetSocketAddress("10.0.2.2", PORT))
13. .awaitUninterruptibly().getSession();
14. //发送并等待完成
15. session.write(u).awaitUninterruptibly();
16. //接收
17. ReadFuture readFuture = session.read();
18. //接收超时
19. if (readFuture.awaitUninterruptibly(30000,TimeUnit.SECONDS)) {
20. VQMessage message = (VQMessage) readFuture.getMessage();
21. //如果是登陆成功的信息
22. if(message.getType().equals(VQMessageType.SUCCESS)){
23. b= true;
24. }
25. } else {
26. b= false;
27. }
28. //断开连接
29. session.close(true);
30. session.getService().dispose();
31. return b;
32. }
33. }

然后服务器端变化不大，在收到登陆请求后，会查询数据库，返回一个信息，来表明登陆成功或者失败。

1. public void messageReceived(IoSession session, Object message)
2. throws Exception {
3. User user=(User) message;
4. if(user.getOperation().equals(VQMessageType.LOGIN)){
5. //操作数据库
6. boolean b=new UserDao().login(user.getAccount(), user.getPassword());
7. if(b){
8. System.out.println(">> ["+user.getAccount()+"] 上线了");
9. //告诉客户端登陆成功
10. VQMessage m=new VQMessage();
11. m.setType(VQMessageType.SUCCESS);
12. session.write(m);
13. }
14. }
15. }

最后附上测试效果：