Mina使用总结(四)传输对象ObjectSerializationCodecFactory

package com.bypay.mina.server;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.Executors;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.executor.ExecutorFilter;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import com.bypay.mina.server.handle.ObjectHandler;

public class MinaServer {

    private IoAcceptor acceptor ;
    
    public MinaServer() {
        acceptor = new NioSocketAcceptor();
        //设置日志过滤器
        acceptor.getFilterChain().addLast("logger", new LoggingFilter());
        //设置编码器
        acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
        acceptor.getFilterChain().addLast("threadPool",new ExecutorFilter(Executors.newCachedThreadPool()));
        //设置读缓冲
        acceptor.getSessionConfig().setReadBufferSize(2048*2048);
        //设置心跳频率
        acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 30);
        //设置Handler
        acceptor.setHandler(new ObjectHandler());
        try {
            Set<SocketAddress> addresses = new HashSet<SocketAddress>();
            //此处的host地址需注意，需要填写主机对外的ip地址或域名，不可用localhost
            addresses.add(new InetSocketAddress("localhost", 18886));
            acceptor.bind(addresses);
        } catch (IOException ioe) {
            ioe.printStackTrace();
        }
        System.out.println("--------------------------------------------------");
        System.out.println("Server Started");
        System.out.println("--------------------------------------------------");
    }
    
    public static void main(String[] args) {
        MinaServer server = new MinaServer();
        
    }
}

package com.bypay.mina.server.handle;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import com.bypay.mina.bean.TransInfo;

public class ObjectHandler extends IoHandlerAdapter {
    

    @Override
    public void sessionCreated(IoSession session) {
        //session创建时回调
        System.out.println("Session Created!");
    }

    @Override
    public void sessionClosed(IoSession session) throws Exception {    
        //session关闭时回调
        System.out.println("Session Closed!");
    }

    @Override
    public void sessionOpened(IoSession session) throws Exception {
        //session打开时回调
        System.out.println("Session Opened!");
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status) {
        //心跳
        System.out.println("sessionIdle");
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable cause) {
        //异常时回调
        cause.printStackTrace();
        //关闭session
        session.close(true);
    }

    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        //接收消息

       //TransInfo为自定义对象
        TransInfo info = (TransInfo) message;        
        //System.out.println("接收返回消息成功");        
        //System.out.println("id:"+info.getId());    
        //System.out.println("msg:"+info.getMsg());
        //Thread.sleep(100);
        session.write(info);
        //session.close(true);
    }
}

package com.bypay.mina.bean;

public class TransInfo implements java.io.Serializable{

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    private long id;
    
    private String msg;

    public long getId() {
        return id;
    }

    public void setId(long id) {
        this.id = id;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }
    
    
}

package com.bypay.mina.client;

import java.net.InetSocketAddress;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
import com.bypay.mina.handler.MyClientHandler;

/**
 * Mina客户端
 * @author 唐延波
 * @date 2015-1-20
 *
 */
public class MinaClient {
    
    private static int CONNECT_TIMEOUT = 1000;

    private static String HOSTNAME = "localhost";

    private static int PORT = 18886;

    /**
     * @author 唐延波
     * @throws InterruptedException
     * @date 2014-11-4
     */
    public static void main(String[] args) throws InterruptedException {
        NioSocketConnector connector = new NioSocketConnector();
        connector.setConnectTimeoutMillis(CONNECT_TIMEOUT);
        //设置读缓冲,传输的内容必须小于此缓冲
        connector.getSessionConfig().setReadBufferSize(2048*2048);
        //设置编码解码器
        connector.getFilterChain().addLast("codec",
                new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
        //设置日志过滤器
        connector.getFilterChain().addLast("logger", new LoggingFilter());
        //设置Handler
        connector.setHandler(new MyClientHandler());

        //获取连接，该方法为异步执行
        ConnectFuture future = connector.connect(new InetSocketAddress(
                HOSTNAME, PORT));
        //等待连接建立
        future.awaitUninterruptibly();
        //获取session
        IoSession session = future.getSession();

        //等待session关闭
        session.getCloseFuture().awaitUninterruptibly();
        //释放connector
        connector.dispose();

    }
}

package com.bypay.mina.handler;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

import com.bypay.mina.bean.TransInfo;

/**
 * ClientHandler
 * @author 唐延波
 * @date 2015-1-20
 *
 */
public class MyClientHandler extends IoHandlerAdapter {

    @Override
    public void sessionCreated(IoSession session) throws Exception {
        //session 创建时调用
        TransInfo info = new TransInfo();
        session.write(info);
    }

    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        //异步接收消息
        TransInfo info = (TransInfo) message;
        session.close(true);
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable cause)
            throws Exception {
        //出现异常
        cause.printStackTrace();
        session.close(true);
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status)
            throws Exception {
        //心跳
        System.out.println("客户端ide:");
    }
}