Java Socket框架Apache MINA：实现Socket服务器端

现在用Apache MINA实现一个简单的Socket服务器端Server，服务器端实现一个简单的功能，当有Socket客户端连接过来后，发送一个简单的字符串“zhangphil”给客户端。服务器端程序代码如下：

import java.net.InetSocketAddress;
import java.nio.charset.Charset;import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;public class MINATest {public static void main(String[] args) {try {MINATest test = new MINATest();} catch (Exception e) {e.printStackTrace();}}public MINATest() throws Exception {IoAcceptor acceptor = new NioSocketAcceptor();// 过滤链。acceptor.getFilterChain().addLast("logger", new LoggingFilter());acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));// 处理。acceptor.setHandler(new SocketServerHandler());// 服务器端绑定80端口，等待客户端连接请求。acceptor.bind(new InetSocketAddress(80));}// Apache MINA的Socket服务器端。private class SocketServerHandler extends IoHandlerAdapter {// 会话创建。@Overridepublic void sessionCreated(IoSession session) throws Exception {super.sessionCreated(session);System.out.println("#sessionCreated#");}// 会话打开时触发（第一次连接时先触发sessionCreated函数，后触发本函数）。@Overridepublic void sessionOpened(IoSession session) throws Exception {super.sessionOpened(session);System.out.println("#sessionOpened#");sendDataToClient(session);}@Overridepublic void messageSent(IoSession session, Object message) throws Exception {super.messageSent(session, message);System.out.println("#messageSent#");System.out.println("=============");System.out.println(message.toString());System.out.println("=============");}// 接收到消息时触发。@Overridepublic void messageReceived(IoSession session, Object message) throws Exception {super.messageReceived(session, message);// System.out.println("messageReceived");System.out.print(message.toString());}@Overridepublic void sessionClosed(IoSession session) throws Exception {super.sessionClosed(session);System.out.println("\n#sessionClosed#");}@Overridepublic void sessionIdle(IoSession session, IdleStatus status) throws Exception {super.sessionIdle(session, status);System.out.println("#sessionIdle#");}@Overridepublic void exceptionCaught(IoSession session, Throwable cause) throws Exception {super.exceptionCaught(session, cause);System.out.println("#exceptionCaught#");cause.printStackTrace();}}private void sendDataToClient(IoSession session) {String string = "zhangphil";session.write(string);}
}

服务器端程序运行后，当有客户端Socket连接过来，服务器端程序输出结果：