Apache Mina的学习应用（四）

在客户端和服务端的调用如下：

 

客户端；

package cn.com.unutrip.java.opensource.mina.sumup;

import java.net.InetSocketAddress;

import org.apache.mina.core.RuntimeIoException;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
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 cn.com.unutrip.java.opensource.mina.sumup.codec.SumUpProtocolCodecFactory;
/**
 * TCP/ID 客户端的应用
 * @author longgangbai
 *
 */
public class Client {
          private static final String HOSTNAME = "localhost";
          private static final int PORT = 8123;
     
          private static final long CONNECT_TIMEOUT = 30*1000L; // 30 seconds
     
          // Set this to false to use object serialization instead of custom codec.
          private static final boolean USE_CUSTOM_CODEC = true;
     
          public static void main(String[] args) throws Throwable {
              // prepare values to sum up
              int[] values = new int[10];
              for (int i = 0; i < args.length; i++) {
                  values[i] = Integer.parseInt(args[i]);
              }
              //创建一个客户端对象
              NioSocketConnector connector = new NioSocketConnector();
     
              // Configure the service.
              //设置连接超时时间
              connector.setConnectTimeoutMillis(CONNECT_TIMEOUT);
              //获取过滤器链工厂
              DefaultIoFilterChainBuilder filterchain=connector.getFilterChain();
              //添加相应的过滤链
              if (USE_CUSTOM_CODEC) {
           //采用自定义的协议编码工厂类过滤器连
           filterchain.addLast("codec",new ProtocolCodecFilter(new SumUpProtocolCodecFactory(false)));
              } else {
           //采用对象序列化编码工厂类过滤器连
           filterchain.addLast("codec",new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
              }
              //添加日志过滤器连
              filterchain.addLast("logger", new LoggingFilter());
              //进行业务处理逻辑
              connector.setHandler(new ClientSessionHandler(values));
     
              IoSession session=null;
              for (;;) {
                  try {
                     ConnectFuture future = connector.connect(new InetSocketAddress(
                              HOSTNAME, PORT));
                      future.awaitUninterruptibly();
                      session = future.getSession();
                      break;
                  } catch (RuntimeIoException e) {
                      System.err.println("Failed to connect.");
                      e.printStackTrace();
                      Thread.sleep(5000);
                  }
              }
              // wait until the summation is done
              session.getCloseFuture().awaitUninterruptibly();
              connector.dispose();
          }
      }

 

服务端使用如下：

 

package cn.com.unutrip.java.opensource.mina.sumup;

import java.net.InetSocketAddress;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
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.NioSocketAcceptor;

import cn.com.unutrip.java.opensource.mina.sumup.codec.SumUpProtocolCodecFactory;
/**
 *TCP /IP 服务端的代码的应用
 * @author longgangbai
 *
 */
public class Server {
    private static final int SERVER_PORT = 8123;
          // Set this to false to use object serialization instead of custom codec.
          private static final boolean USE_CUSTOM_CODEC = true;
     
          public static void main(String[] args) throws Throwable {
              //创建服务端
              NioSocketAcceptor acceptor = new NioSocketAcceptor();
              //获取过滤链的信息
              DefaultIoFilterChainBuilder filterchain=acceptor.getFilterChain();
              // Prepare the service configuration.
              if (USE_CUSTOM_CODEC) {
           filterchain.addLast("codec",new ProtocolCodecFilter(new SumUpProtocolCodecFactory(true)));
              } else {
           filterchain.addLast("codec",new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
              }
              filterchain.addLast("logger", new LoggingFilter());
              //业务处理
              acceptor.setHandler(new ServerSessionHandler());
              //绑定服务端口
              acceptor.bind(new InetSocketAddress(SERVER_PORT));
              System.out.println("Listening on port " + SERVER_PORT);
          }

}

 

希望大家交流。