Mina简单小例

package myminaclient;

import java.net.InetSocketAddress;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

/**
 * 简单Mina Client示例
 * 
 * @author javaFound
 * @www.javaKe.com
 */
public class MainClient {
	public static void main(String[] args) throws Exception {
		// Create TCP/IP connector.
		NioSocketConnector connector = new NioSocketConnector();
		// 创建接收数据的过滤器
		DefaultIoFilterChainBuilder chain = connector.getFilterChain();
		// 设定这个过滤器将一行一行(/r/n)的读取数据
		chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
		// 设定服务器端的消息处理器:一个SamplMinaServerHandler对象,
		connector.setHandler(new SampleMinaClientHandler());
		
		// Set connect timeout.
		connector.setConnectTimeoutMillis(10000);
		ConnectFuture cf = connector.connect(new InetSocketAddress("localhost", 9988));
		// Wait for the connection attempt to be finished.
		cf.awaitUninterruptibly();
		cf.getSession().getCloseFuture().awaitUninterruptibly();
		
		Message b= new Message();  
		b.setStatus(1);  
		b.setType(2);  
		b.setMsgBody("test clinet");  
		connector.broadcast(b);  
	}
}

这是发送object的例子，其余代码在下载包中