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的例子，其余代码在下载包中
