Java MiNa 实现多人聊天室程序 源码

开发环境:

System:Windows

JavaSDK:1.6

IDE:eclipse、MyEclipse 6.6

 

开发依赖库:

Jdk1.4+、mina-core-2.0.4.jar、slf4j-api-1.5.11.jar、slf4j-log4j12-1.5.11.jar

 

Email:hoojo_@126.com

Blog:http://blog.csdn.net/IBM_hoojo

http://hoojo.cnblogs.com/

http://hoojo.blogjava.net


前不久用Socket写的聊天程序,主要是手机端程序通过Socket连接服务器端的ServerSocket,然后服务器端根据客户端发送过来统 一规范的报文。进行解析再用smack框架转发到openfire服务器,最后由openfire服务器向客户端程序发送聊天信息。

最近发现socket服务器资源消耗比较大。我是采用阻塞式多线程通信方式,这种方式会造成大量的服务器资源浪费、长期的占用服务器的CUP调度权,并且会长时间阻塞程序,等待客户端连接、发送消息等。

为了解决上面的状况,Apache MiNa能很好的解决这个问题。Mina采用的是非阻塞式、单线程、NIO通信方式。

非阻塞式通信的思想是:让一个线程同时完成多件事,这个线程会利用完成这件事的空余时间去完成另一件事,一刻也不闲着。这个线程同时也会不断监控每件事情中需要处理时间的发生,发生一个就处理一件,然后继续监听各自事情。

一、介绍

首先,Mina是个什么东西?看下官方网站(http://mina.apache.org/)对它的解释:

Apache的Mina(Multipurpose Infrastructure Networked Applications)是一个网络应用框架,可以帮助用户开发高性能和高扩展性的网络应用程序;它提供了一个抽象的、事件驱动的异步API,使 Java NIO在各种传输协议(如TCP/IP,UDP/IP协议等)下快速高效开发。

Apache Mina也称为:

NIO框架

网络套接字(networking socket)类库

事件驱动的异步API(注意:在JDK7中也新增了异步API)

总之:我们简单理解它是一个封装底层IO操作,提供高级操作API的通讯框架!

二、服务器端编码工作

第一步:

使用Apache MiNa框架,你需要下载jar

下载地址:http://mina.apache.org/dyn/closer.cgi/mina/2.0.4/apache-mina-2.0.4-bin.zip

你需要添加jar如下

如果你使用日志,需要添加日志配置文件log4j.properties

第二步:

编写通信要用的解码工厂和编码器、解码器类,代码如下

  1. package com.hoo.mina.code.factory;
  2. import org.apache.mina.core.session.IoSession;
  3. import org.apache.mina.filter.codec.ProtocolCodecFactory;
  4. import org.apache.mina.filter.codec.ProtocolDecoder;
  5. import org.apache.mina.filter.codec.ProtocolEncoder;
  6. import com.hoo.mina.code.CharsetDecoder;
  7. import com.hoo.mina.code.CharsetEncoder;
  8. /**
  9.  * <b>function:</b> 字符编码、解码工厂类,编码过滤工厂
  10.  * @author hoojo
  11.  * @createDate 2012-6-26 下午01:08:50
  12.  * @file CharsetCodecFactory.java
  13.  * @package com.hoo.mina.code.factory
  14.  * @project ApacheMiNa
  15.  * @blog http://blog.csdn.net/IBM_hoojo
  16.  * @email hoojo_@126.com
  17.  * @version 1.0
  18.  */
  19. public class CharsetCodecFactory implements ProtocolCodecFactory {
  20.     @Override
  21.     public ProtocolDecoder getDecoder(IoSession session) throws Exception {
  22.         return new CharsetDecoder();
  23.     }
  24.     @Override
  25.     public ProtocolEncoder getEncoder(IoSession session) throws Exception {
  26.         return new CharsetEncoder();
  27.     }
  28. }

解码类

  1. package com.hoo.mina.code;
  2. import java.nio.charset.Charset;
  3. import org.apache.log4j.Logger;
  4. import org.apache.mina.core.buffer.IoBuffer;
  5. import org.apache.mina.core.session.IoSession;
  6. import org.apache.mina.filter.codec.ProtocolDecoder;
  7. import org.apache.mina.filter.codec.ProtocolDecoderOutput;
  8. /**
  9.  * <b>function:</b> 字符解码
  10.  * @author hoojo
  11.  * @createDate 2012-6-26 上午11:14:18
  12.  * @file CharsetDecoder.java
  13.  * @package com.hoo.mina.code
  14.  * @project ApacheMiNa
  15.  * @blog http://blog.csdn.net/IBM_hoojo
  16.  * @email hoojo_@126.com
  17.  * @version 1.0
  18.  */
  19. public class CharsetDecoder implements ProtocolDecoder {
  20.     private final static Logger log = Logger.getLogger(CharsetDecoder.class);
  21.     private final static Charset charset = Charset.forName(“UTF-8″);
  22.     // 可变的IoBuffer数据缓冲区
  23.     private IoBuffer buff = IoBuffer.allocate(100).setAutoExpand(true);
  24.     @Override
  25.     public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception {
  26.         log.info(“#########decode#########”);
  27.         // 如果有消息
  28.         while (in.hasRemaining()) {
  29.             // 判断消息是否是结束符,不同平台的结束符也不一样;
  30.             // windows换行符(\r\n)就认为是一个完整消息的结束符了; UNIX 是\n;MAC 是\r
  31.             byte b = in.get();
  32.             if (b == ’\n’) {
  33.                 buff.flip();
  34.                 byte[] bytes = new byte[buff.limit()];
  35.                 buff.get(bytes);
  36.                 String message = new String(bytes, charset);
  37.                 buff = IoBuffer.allocate(100).setAutoExpand(true);
  38.                 // 如果结束了,就写入转码后的数据
  39.                 out.write(message);
  40.                 //log.info(“message: ” + message);
  41.             } else {
  42.                 buff.put(b);
  43.             }
  44.         }
  45.     }
  46.     @Override
  47.     public void dispose(IoSession session) throws Exception {
  48.         log.info(“#########dispose#########”);
  49.         log.info(session.getCurrentWriteMessage());
  50.     }
  51.     @Override
  52.     public void finishDecode(IoSession session, ProtocolDecoderOutput out) throws Exception {
  53.         log.info(“#########完成解码#########”);
  54.     }
  55. }

上面的decode方法是解码方法,它主要是把读取到数据中的换行符去掉。因为在mina通信协议中以换行符为结束符,如果不定义结束符那么程序会在那里一直等待下一条发送的数据。这里用到了IoBuffer,MiNa中传输的所有二进制信息都存放在IoBuffer中,IoBuffer是对Java NIO中ByteBuffer的封装(Mina2.0以前版本这个接口也是ByteBuffer),提供了更多操作二进制数据,对象的方法,并且存储空间 可以自增长,用起来非常方便;简单理解,它就是个可变长度的byte字节数组!

1. static IoBuffer allocate(int capacity,boolean useDirectBuffer)

创建IoBuffer实例,第一个参数指定初始化容量,第二个参数指定使用直接缓冲区还是JAVA 内存堆的缓存区,默认为false。

2.IoBuffer setAutoExpand(boolean autoExpand)

这个方法设置IoBuffer 为自动扩展容量,也就是前面所说的长度可变,那么可以看出长度可变这个特性默认是不开启的。

3. IoBuffer flip()

limit=position, position=0,重置mask,为了读取做好准备,一般是结束buffer操作,将buffer写入输出流时调用;这个必须要调用,否则极有可能 position!=limit,导致position后面没有数据;每次写入数据到输出流时,必须确保position=limit。

4. IoBuffer clear()与IoBuffer reset()

clear:limit=capacity , position=0,重置mark;它是不清空数据,但从头开始存放数据做准备—相当于覆盖老数据。

reset就是清空数据

5. int remaining()与boolean hasRemaining()

这两个方法一般是在调用了flip方法后使用的,remaining()是返回limt-position的值!hasRemaining()则是判断当前是否有数据,返回position < limit的boolean值!

编码类

 

  1. package com.hoo.mina.code;
  2. import java.nio.charset.Charset;
  3. import org.apache.log4j.Logger;
  4. import org.apache.mina.core.buffer.IoBuffer;
  5. import org.apache.mina.core.session.IoSession;
  6. import org.apache.mina.filter.codec.ProtocolEncoder;
  7. import org.apache.mina.filter.codec.ProtocolEncoderOutput;
  8. import org.apache.mina.filter.codec.textline.LineDelimiter;
  9. /**
  10.  * <b>function:</b> 字符编码
  11.  * @author hoojo
  12.  * @createDate 2012-6-26 上午11:32:05
  13.  * @file CharsetEncoder.java
  14.  * @package com.hoo.mina.code
  15.  * @project ApacheMiNa
  16.  * @blog http://blog.csdn.net/IBM_hoojo
  17.  * @email hoojo_@126.com
  18.  * @version 1.0
  19.  */
  20. public class CharsetEncoder implements ProtocolEncoder {
  21.     private final static Logger log = Logger.getLogger(CharsetEncoder.class);
  22.     private final static Charset charset = Charset.forName(“UTF-8″);
  23.     @Override
  24.     public void dispose(IoSession session) throws Exception {
  25.         log.info(“#############dispose############”);
  26.     }
  27.     @Override
  28.     public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
  29.         log.info(“#############字符编码############”);
  30.         IoBuffer buff = IoBuffer.allocate(100).setAutoExpand(true);
  31.         buff.putString(message.toString(), charset.newEncoder());
  32.         // put 当前系统默认换行符
  33.         buff.putString(LineDelimiter.DEFAULT.getValue(), charset.newEncoder());
  34.         // 为下一次读取数据做准备
  35.         buff.flip();
  36.         out.write(buff);
  37.     }
  38. }

第三步:

编写IoHandler实现类代码,IoHander这里是Io读写的事件驱动类,这里的Io操作都会触发里面的事件。你所有的业务逻辑都应当在这个类中完成。

  1. package com.hoo.mina.server.message;
  2. import java.text.SimpleDateFormat;
  3. import java.util.Collection;
  4. import java.util.Date;
  5. import org.apache.mina.core.future.CloseFuture;
  6. import org.apache.mina.core.future.IoFuture;
  7. import org.apache.mina.core.future.IoFutureListener;
  8. import org.apache.mina.core.service.IoHandler;
  9. import org.apache.mina.core.session.IdleStatus;
  10. import org.apache.mina.core.session.IoSession;
  11. import org.slf4j.Logger;
  12. import org.slf4j.LoggerFactory;
  13. /**
  14.  * <b>function:</b> 处理服务器端消息
  15.  * @author hoojo
  16.  * @createDate 2012-6-26 下午01:12:34
  17.  * @file ServerMessageHandler.java
  18.  * @package com.hoo.mina.server.message
  19.  * @project ApacheMiNa
  20.  * @blog http://blog.csdn.net/IBM_hoojo
  21.  * @email hoojo_@126.com
  22.  * @version 1.0
  23.  */
  24. public class ServerMessageHandler implements IoHandler {
  25.     private final static Logger log = LoggerFactory.getLogger(ServerMessageHandler.class);
  26.     @Override
  27.     public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
  28.         log.info(“服务器发生异常: {}”, cause.getMessage());
  29.     }
  30.     @Override
  31.     public void messageReceived(IoSession session, Object message) throws Exception {
  32.         log.info(“服务器接收到数据: {}”, message);
  33.         String content = message.toString();
  34.         SimpleDateFormat sdf = new SimpleDateFormat(“yyyy-MM-dd hh:mm:ss”);
  35.         String datetime = sdf.format(new Date());
  36.         log.info(“转发 messageReceived: ” + datetime + ”\t” + content);
  37.         // 拿到所有的客户端Session
  38.         Collection<IoSession> sessions = session.getService().getManagedSessions().values();
  39.         // 向所有客户端发送数据
  40.         for (IoSession sess : sessions) {
  41.             sess.write(datetime + ”\t” + content);
  42.         }
  43.     }
  44.     @Override
  45.     public void messageSent(IoSession session, Object message) throws Exception {
  46.         log.info(“服务器发送消息: {}”, message);
  47.     }
  48.     @Override
  49.     public void sessionClosed(IoSession session) throws Exception {
  50.         log.info(“关闭当前session:{}#{}”, session.getId(), session.getRemoteAddress());
  51.         CloseFuture closeFuture = session.close(true);
  52.         closeFuture.addListener(new IoFutureListener<IoFuture>() {
  53.             public void operationComplete(IoFuture future) {
  54.                 if (future instanceof CloseFuture) {
  55.                     ((CloseFuture) future).setClosed();
  56.                     log.info(“sessionClosed CloseFuture setClosed–>{},”, future.getSession().getId());
  57.                 }
  58.             }
  59.         });
  60.     }
  61.     @Override
  62.     public void sessionCreated(IoSession session) throws Exception {
  63.         log.info(“创建一个新连接:{}”, session.getRemoteAddress());
  64.         session.write(“welcome to the chat room !”);
  65.     }
  66.     @Override
  67.     public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
  68.         log.info(“当前连接{}处于空闲状态:{}”, session.getRemoteAddress(), status);
  69.     }
  70.     @Override
  71.     public void sessionOpened(IoSession session) throws Exception {
  72.         log.info(“打开一个session:{}#{}”, session.getId(), session.getBothIdleCount());
  73.     }
  74. }

sessionCreated:当一个新的连接建立时,由I/O processor thread调用;sessionOpened:当连接打开是调用;

messageReceived: 当接收了一个消息时调用;

messageSent:当一个消息被(IoSession#write)发送出去后调用;

sessionIdle:当连接进入空闲状态时调用;

sessionClosed:当连接关闭时调用;

exceptionCaught:实现IoHandler的类抛出异常时调用;

一般情况下,我们最关心的只有messageReceived方法,接收消息并处理,然后调用IoSession的write方法发送出消息!(注 意:这里接收到的消息都是Java对象,在IoFilter中所有二进制数据都被解码)一般情况下很少有人实现IoHandler接口,而是继承它的一个 实现类IoHandlerAdapter,这样不用覆盖它的7个方法,只需要根据具体需求覆盖其中的几个方法就可以!

Iohandler的7个方法其实是根据session的4个状态值间变化来调用的:

 Connected:会话被创建并使用;

 Idle:会话在一段时间(可配置)内没有任何请求到达,进入空闲状态;

 Closing:会话将被关闭(剩余message将被强制flush);

 Closed:会话被关闭;

状态转换图如下:

第四步:

编写server启动类,bind端口、设置编码过程和核心业务处理器

  1. package com.hoo.mina.server;
  2. import java.io.IOException;
  3. import java.net.InetSocketAddress;
  4. import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
  5. import org.apache.mina.core.session.IdleStatus;
  6. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  7. import org.apache.mina.transport.socket.SocketAcceptor;
  8. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  9. import com.hoo.mina.code.factory.CharsetCodecFactory;
  10. import com.hoo.mina.server.message.ServerMessageHandler;
  11. /**
  12.  * <b>function:</b> 服务器启动类
  13.  * @author hoojo
  14.  * @createDate 2012-6-29 下午07:11:00
  15.  * @file MinaServer.java
  16.  * @package com.hoo.mina.server
  17.  * @project ApacheMiNa
  18.  * @blog http://blog.csdn.net/IBM_hoojo
  19.  * @email hoojo_@126.com
  20.  * @version 1.0
  21.  */
  22. public class MinaServer {
  23.     private SocketAcceptor acceptor;
  24.     public MinaServer() {
  25.         // 创建非阻塞的server端的Socket连接
  26.         acceptor = new NioSocketAcceptor();
  27.     }
  28.     public boolean start() {
  29.         DefaultIoFilterChainBuilder filterChain = acceptor.getFilterChain();
  30.         // 添加编码过滤器 处理乱码、编码问题
  31.         filterChain.addLast(“codec”, new ProtocolCodecFilter(new CharsetCodecFactory()));
  32.         /*LoggingFilter loggingFilter = new LoggingFilter();
  33.         loggingFilter.setMessageReceivedLogLevel(LogLevel.INFO);
  34.         loggingFilter.setMessageSentLogLevel(LogLevel.INFO);
  35.         // 添加日志过滤器
  36.         filterChain.addLast(“loger”, loggingFilter);*/
  37.         // 设置核心消息业务处理器
  38.         acceptor.setHandler(new ServerMessageHandler());
  39.         // 设置session配置,30秒内无操作进入空闲状态
  40.         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 30);
  41.         try {
  42.             // 绑定端口3456
  43.             acceptor.bind(new InetSocketAddress(3456));
  44.         } catch (IOException e) {
  45.             e.printStackTrace();
  46.             return false;
  47.         }
  48.         return true;
  49.     }
  50.     public static void main(String[] args) {
  51.         MinaServer server = new MinaServer();
  52.         server.start();
  53.     }
  54. }

上面的代码主要完成启动参数的设置,如端口、session参数;消息核心业务处理器,这个比较关键,我们所有的业务都要在这里完成;然后就是日志、编码 过滤器,我们可以对发送或接收到的消息进行处理、编码操作,在网络中传递数据都是字节流传递的,我们要获取消息必须把二进制的字节流转换的字符串来处理, 所以这个也是必须的;同时你还可以对服务器添加日志过滤器,来显示日志。这样服务器端程序就已经完成,你可以用socket或mina client等方式连接服务器,进行通信。

启动服务器,在浏览器中输入http://localhost:3456 这里的服务器绑定的端口是3456

然后你在控制台中可以看到当前浏览器的一些基本信息,如果你看到这些信息就表示你服务器代码编写没有什么问题,应该可以成功建立客户端连接。信息如下:

  1. 2012-08-01 09:55:56,046 INFO [com.hoo.mina.server.message.ServerMessageHandler:75-NioProcessor-1] - 创建一个新连接:/127.0.0.1:2542
  2. 2012-08-01 09:55:56,046 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-1] - #############字符编码############
  3. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:86-NioProcessor-1] - 打开一个session:3#0
  4. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:55- NioProcessor-1] - 服务器发送消息: welcome to the chat room !
  5. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-1] - #########decode#########
  6. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:38-NioProcessor-1] - 服务器接收到数据: GET / HTTP/1.1
  7. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-1] - 转发 messageReceived: 2012-08-01 09:55:56 GET / HTTP /1.1
  8. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-1] - #############字符编码############
  9. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:38- NioProcessor-1] - 服务器接收到数据: Host: localhost:3456
  10. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-1] - 转 发 messageReceived: 2012-08-01 09:55:56 Host: localhost:3456
  11. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-1] - #############字符编码############
  12. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:38- NioProcessor-1] - 服务器接收到数据: User- Agent: Mozilla/5.0 (Windows NT 5.1; rv:14.0) Gecko/20100101 Firefox/14.0.1
  13. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-1] - 转发 messageReceived: 2012-08-01 09:55:56 User- Agent: Mozilla/5.0 (Windows NT 5.1; rv:14.0) Gecko/20100101 Firefox/14.0.1
  14. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-1] - #############字符编码############
  15. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:38- NioProcessor-1] - 服务器接收到数据: Accept: text/html,application /xhtml+xml,application/xml;q=0.9,*/*;q=0.8
  16. 2012-08-01 09:55:56,062 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-1] - 转 发 messageReceived: 2012-08-01 09:55:56 Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8
  17. 其他内容省略……

三、客户端编码工作

第一步:

编写客户端消息核心处理业务类型,消息处理器

  1. package com.hoo.mina.client.message;
  2. import org.apache.mina.core.service.IoHandlerAdapter;
  3. import org.apache.mina.core.session.IoSession;
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6. /**
  7.  * <b>function:</b> 客户端消息处理类
  8.  * @author hoojo
  9.  * @createDate 2012-6-29 下午07:24:22
  10.  * @file ClientMessageHandlerAdapter.java
  11.  * @package com.hoo.mina.client.message
  12.  * @project ApacheMiNa
  13.  * @blog http://blog.csdn.net/IBM_hoojo
  14.  * @email hoojo_@126.com
  15.  * @version 1.0
  16.  */
  17. public class ClientMessageHandlerAdapter extends IoHandlerAdapter {
  18.     private final static Logger log = LoggerFactory.getLogger(ClientMessageHandlerAdapter.class);
  19.     public void messageReceived(IoSession session, Object message) throws Exception {
  20.         String content = message.toString();
  21.         log.info(“client receive a message is : ” + content);
  22.     }
  23.     public void messageSent(IoSession session , Object message) throws Exception{
  24.         log.info(“messageSent 客户端发送消息:” + message);
  25.     }
  26.     @Override
  27.     public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
  28.         log.info(“服务器发生异常: {}”, cause.getMessage());
  29.     }
  30. }

这里我们没有实现IoHandler这个接口,而是继承了IoHandlerAdapter这类,覆盖了messageReceived、 messageSent这两个方法。IoHandlerAdapter是IoHandler接口的一个实现,我们这里没有必要实现IoHandler的所 有方法。

第二步:

编写连接服务器的代码,设置核心消息处理器

  1. package com.hoo.mina.client;
  2. import java.net.InetSocketAddress;
  3. import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
  4. import org.apache.mina.core.future.CloseFuture;
  5. import org.apache.mina.core.future.ConnectFuture;
  6. import org.apache.mina.core.session.IoSession;
  7. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  8. import org.apache.mina.transport.socket.SocketConnector;
  9. import org.apache.mina.transport.socket.nio.NioSocketConnector;
  10. import com.hoo.mina.client.message.ClientMessageHandlerAdapter;
  11. import com.hoo.mina.code.factory.CharsetCodecFactory;
  12. /**
  13.  * <b>function:</b> mina客户端
  14.  * @author hoojo
  15.  * @createDate 2012-6-29 下午07:28:45
  16.  * @file MinaClient.java
  17.  * @package com.hoo.mina.client.message
  18.  * @project ApacheMiNa
  19.  * @blog http://blog.csdn.net/IBM_hoojo
  20.  * @email hoojo_@126.com
  21.  * @version 1.0
  22.  */
  23. public class MinaClient {
  24.     private SocketConnector connector;
  25.     private ConnectFuture future;
  26.     private IoSession session;
  27.     public boolean connect() {
  28.         // 创建一个socket连接
  29.         connector = new NioSocketConnector();
  30.         // 设置链接超时时间
  31.         connector.setConnectTimeoutMillis(3000);
  32.         // 获取过滤器链
  33.         DefaultIoFilterChainBuilder filterChain = connector.getFilterChain();
  34.         // 添加编码过滤器 处理乱码、编码问题
  35.         filterChain.addLast(“codec”, new ProtocolCodecFilter(new CharsetCodecFactory()));
  36.         /*
  37.         // 日志
  38.         LoggingFilter loggingFilter = new LoggingFilter();
  39.         loggingFilter.setMessageReceivedLogLevel(LogLevel.INFO);
  40.         loggingFilter.setMessageSentLogLevel(LogLevel.INFO);
  41.         filterChain.addLast(“loger”, loggingFilter);*/
  42.         // 消息核心处理器
  43.         connector.setHandler(new ClientMessageHandlerAdapter());
  44.         // 连接服务器,知道端口、地址
  45.         future = connector.connect(new InetSocketAddress(3456));
  46.         // 等待连接创建完成
  47.         future.awaitUninterruptibly();
  48.         // 获取当前session
  49.         session = future.getSession();
  50.         return true;
  51.     }
  52.     public void setAttribute(Object key, Object value) {
  53.         session.setAttribute(key, value);
  54.     }
  55.     public void send(String message) {
  56.         session.write(message);
  57.     }
  58.     public boolean close() {
  59.         CloseFuture future = session.getCloseFuture();
  60.         future.awaitUninterruptibly(1000);
  61.         connector.dispose();
  62.         return true;
  63.     }
  64.     public SocketConnector getConnector() {
  65.         return connector;
  66.     }
  67.     public IoSession getSession() {
  68.         return session;
  69.     }
  70. }

第三步:

完成启动、在控制台输入你发送的内容

  1. package com.hoo.mina.client.main;
  2. import java.util.Scanner;
  3. import com.hoo.mina.client.MinaClient;
  4. /**
  5.  * <b>function:</b> 运行客户端程序
  6.  * @author hoojo
  7.  * @createDate 2012-6-29 下午07:36:44
  8.  * @file RunClient.java
  9.  * @package com.hoo.mina.client.main
  10.  * @project ApacheMiNa
  11.  * @blog http://blog.csdn.net/IBM_hoojo
  12.  * @email hoojo_@126.com
  13.  * @version 1.0
  14.  */
  15. public class RunClient {
  16.     public static void main(String[] args) {
  17.         MinaClient client = new MinaClient();
  18.         if (client.connect()) {
  19.             client.send(“连接服务器成功!”);
  20.             Scanner scanner = new Scanner(System.in);
  21.             while (scanner.hasNext()) {
  22.                 client.send(scanner.next());
  23.             }
  24.         }
  25.     }
  26. }

启动服务器,运行客户端程序可以看到控制台:

  1. 2012-08-01 10:01:15,953 INFO [com.hoo.mina.code.CharsetEncoder:34-main] - #############字符编码############
  2. 2012-08-01 10:01:15,953 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-2] - #########decode#########
  3. 2012-08-01 10:01:15,953 INFO [com.hoo.mina.client.message.ClientMessageHandlerAdapter:25-NioProcessor-2] - client receive a message is : welcome to the chat room !
  4. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.client.message.ClientMessageHandlerAdapter:29- NioProcessor-2] - messageSent 客户端发送消息:连接服务器成功!
  5. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-2] - #########decode#########
  6. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.client.message.ClientMessageHandlerAdapter:25-NioProcessor-2] - client receive a message is : 2012-08-01 10:01:15

 

服务器控制台:

  1. 2012-08-01 10:01:15,921 INFO [com.hoo.mina.server.message.ServerMessageHandler:75-NioProcessor-2] - 创建一个新连接:/192.168.8.22:2644
  2. 2012-08-01 10:01:15,937 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-2] - #############字符编码############
  3. 2012-08-01 10:01:15,937 INFO [com.hoo.mina.server.message.ServerMessageHandler:86-NioProcessor-2] - 打开一个session:1#0
  4. 2012-08-01 10:01:15,937 INFO [com.hoo.mina.server.message.ServerMessageHandler:55- NioProcessor-2] - 服务器发送消息: welcome to the chat room !
  5. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-2] - #########decode#########
  6. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.server.message.ServerMessageHandler:38-NioProcessor-2] - 服务器接收到数据: 连接服务器成功!
  7. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-2] - 转发 messageReceived: 2012-08-01 10:01:15 连接服务器成功!
  8. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-2] - #############字符编码############
  9. 2012-08-01 10:01:15,984 INFO [com.hoo.mina.server.message.ServerMessageHandler:55- NioProcessor-2] - 服务器发送消息: 2012-08-01 10:01:15    连接服务器成功!
  10. 2012-08-01 10:01:45,984 INFO [com.hoo.mina.server.message.ServerMessageHandler:81- NioProcessor-2] - 当前连接/192.168.8.22:2644处于空闲状态:both idle

 

在客户端控制台输入聊天内容

  1. hello,MiNaChat~!
  2. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.code.CharsetEncoder:34-main] - #############字符编码############
  3. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.client.message.ClientMessageHandlerAdapter:29- NioProcessor-2] - messageSent 客户端发送消息:hello,MiNaChat~!
  4. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-2] - #########decode#########
  5. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.client.message.ClientMessageHandlerAdapter:25-NioProcessor-2] - client receive a message is : 2012-08-01 10:03:49

 

服务器端接收到内容

  1. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.code.CharsetDecoder:31-NioProcessor-2] - #########decode#########
  2. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.server.message.ServerMessageHandler:38-NioProcessor-2] - 服务器接收到数据: hello,MiNaChat~!
  3. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.server.message.ServerMessageHandler:43- NioProcessor-2] - 转 发 messageReceived: 2012-08-01 10:03:49 hello,MiNaChat~!
  4. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.code.CharsetEncoder:34-NioProcessor-2] - #############字符编码############
  5. 2012-08-01 10:03:49,093 INFO [com.hoo.mina.server.message.ServerMessageHandler:55- NioProcessor-2] - 服务器发送消息: 2012-08-01 10:03:49    hello,MiNaChat~!
  6. 2012-08-01 10:04:19,093 INFO [com.hoo.mina.server.message.ServerMessageHandler:81- NioProcessor-2] - 当前连接/192.168.8.22:2644处于空闲状态:both idle


发表评论

电子邮件地址不会被公开。 必填项已用 * 标注

*

您可以使用这些 HTML 标签和属性: <a href="" title=""> <abbr title=""> <acronym title=""> <b> <blockquote cite=""> <cite> <code> <del datetime=""> <em> <i> <q cite=""> <strike> <strong>

(Spamcheck Enabled)