Apache Mina入门

dengwen3

　　一：说明
　　Mina是什么？一句话就是“一个简洁易用的基于Tcp/IP通信的java框架”，什么？什么是框架？再问你就不要向下看了。
　　Mina能干什么？先拉出来溜一下：我们用它做两个小程序，一个为服务器，收到客户机的消息后，就回送给客户机；一个是简单的客户机，一连上服务器，就发一条消息报到，然后将从服务器接到的消息再发给服务器。嗯，你是否意识到这是一个死循环的C/S通信？折腾机器这叫，编程就是要先能折腾！
　　二、实践：
　　第一步：当然是下载Mina，然后在ec里建个项目，将下载后的mina-core-2.0.0-M1.jar 这个包加到你的新建的Project的lib中。
　　第二步，编写服务器代码。服务器端由两个类组成：一个是Min.java，启动服务器的主类；另一个是SamplMinaServerHandler.java，这个类负责处理连结上来的客户机，即消息处理器。看代码了：
　　处理器代码：

package com.javake.mina.sampleserver;
import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IoSession;

/**
* 自定议的消息处理器,必须实现IoHandlerAdapter类
* @author javaFound
*/
public class SamplMinaServerHandler extends IoHandlerAdapter {

//当一个客端端连结进入时
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("incomming client : "+session.getRemoteAddress());
}

//当一个客户端关闭时
@Override
public void sessionClosed(IoSession session) {
System.out.println("one Clinet Disconnect !");
}

//当客户端发送的消息到达时:
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
/ /我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:
String s=(String)message;
// Write the received data back to remote peer
System.out.println("收到客户机发来的消息: "+s);
//测试将消息回送给客户端
session.write(s+count);
count++;
}
private   int count=0;
}

　　处理器是我们重写了org.apache.mina.common.IoHandlerAdapter的一个类，其中被重写的方法，你根据方法名应可以想到这些方法的用途吧？！编程还有一点很重要，就是要会连猜带蒙。
　　启动服务器的主类：

package com.javake.mina.sampleserver;

import java.net.InetSocketAddress;

import org.apache.mina.common.DefaultIoFilterChainBuilder;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

/**
* 简单Mina Server示例
* @author javaFound
*/
public class MainServer {
public static void main(String[] args) throws Exception {
//创建一个非阻塞的Server端Socket,用NIO
SocketAcceptor acceptor = new NioSocketAcceptor();
//创建接收数据的过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
//设定这个过滤器将一行一行(/r/n)的读取数据
chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
//设定服务器端的消息处理器:一个SamplMinaServerHandler对象,
acceptor.setHandler(new SamplMinaServerHandler());
//  服务器端绑定的端口
int bindPort=9988;
//绑定端口,启动服务器
acceptor.bind(new InetSocketAddress(bindPort));
System.out.println("Mina Server is Listing on:= " + bindPort);
}
}

　　就这么简单！启动服务器，试一下!不幸的是，输出的是如下的一行异常信息：
Exception in thread "main" java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory  at org.apache.mina.common.SimpleIoProcessorPool.<init>(SimpleIoProcessorPool.java:78)  at org.apache.mina.common.SimpleIoProcessorPool.<init>(SimpleIoProcessorPool.java:90)  at org.apache.mina.common.AbstractPollingIoConnector.<init>(AbstractPollingIoConnector.java:61)    at org.apache.mina.transport.socket.nio.NioSocketConnector.<init>(
 
http://www.iyunv.com/upload/attachment/25878/d3900f5d-9fb8-3a87-8905-f9331d27621b-thumb.bmp?1212061315
 
　　
描述: 图3-Mina的体系结构
大小: 1.2 MB
http://www.iyunv.com/upload/attachment/25880/0e21a363-dbcd-3e29-9bb0-50298ea521b0-thumb.bmp?1212061316
 
描述: 图2-测试mina服务器
大小: 350.4 KB
 
http://www.iyunv.com/upload/attachment/25882/e602e936-aec1-372e-8e9a-c8b7fec5b606-thumb.bmp?1212061317
描述: 图1-测试mina服务器
大小: 595.1 KB