mina权威性能测试例子

import java.net.InetSocketAddress; import java.nio.charset.Charset; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import org.apache.mina.core.service.IoConnector; import org.apache.mina.filter.codec.ProtocolCodecFilter; import org.apache.mina.filter.executor.ExecutorFilter; import org.apache.mina.filter.executor.OrderedThreadPoolExecutor; import org.apache.mina.transport.socket.nio.NioSocketConnector; public class ClientMain { public static void main(String[] args) { try { IoConnector connector = new NioSocketConnector(Runtime.getRuntime().availableProcessors() + 1); //connector.setConnectTimeoutMillis(1000); connector.getFilterChain().addLast( "codec", new ProtocolCodecFilter(new MyCoderFactory(Charset .forName("UTF-8")))); // connector.getFilterChain() // .addLast("executor", new ExecutorFilter(Executors.newCachedThreadPool())); connector.getFilterChain() .addLast("threadPool", new ExecutorFilter( new OrderedThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS))); connector.setHandler(new ClientHandler()); int k=0; for(int i=0;i<5000;i++){ //while(true){ connector.connect(new InetSocketAddress( "192.168.0.251", 5556));// 192.168.0.202 Thread.sleep(10); ++k; //System.out.println(k); } } catch (Exception e) { e.printStackTrace(); } } }