继续上文。
在客户端和服务端的调用如下：
客户端；
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);
}
}
希望大家交流。
