Apache Mina简单实例客户端篇
package com.heming.apache.mina.samplesclient;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
/**
* 消息处理类
* @author 何明
*
*/
public class SamplMinaClientHander extends IoHandlerAdapter {
@Override
public void exceptionCaught(IoSession arg0, Throwable arg1)
throws Exception {
// TODO Auto-generated method stub
}
/**
* 当客户端接受到消息时
*/
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
//我们已设定了服务器的消息规则是一行一行读取，这里就可以转为String:
String s = (String)message;
//Writer the received data back to remote peer
System.out.println("服务器发来的收到消息: " + s);
//测试将消息回送给客户端
session.write(s);
}
@Override
public void messageSent(IoSession arg0, Object arg1) throws Exception {
// TODO Auto-generated method stub
}
/**
* 当一个客户端被关闭时
*/
@Override
public void sessionClosed(IoSession session) throws Exception {
System.out.println("one client Disconnect");
}
@Override
public void sessionCreated(IoSession arg0) throws Exception {
// TODO Auto-generated method stub
}
@Override
public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception {
// TODO Auto-generated method stub
}
/**
* 当一个客户端连接进入时
*/
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("incomming client:" + session.getRemoteAddress());
session.write("我来啦");
}
}
package com.heming.apache.mina.samplesclient;
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;
/**
* 启动客户端
* @author 何明
*
*/
public class MainClient {
public static void main(String []args)throws Exception{
//Create TCP/IP connection
NioSocketConnector connector = new NioSocketConnector();
//创建接受数据的过滤器
DefaultIoFilterChainBuilder chain = connector.getFilterChain();
//设定这个过滤器将一行一行(/r/n)的读取数据
chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
//服务器的消息处理器：一个SamplMinaServerHander对象
connector.setHandler(new SamplMinaClientHander());
//set connect timeout
connector.setConnectTimeout(30);
//连接到服务器：
ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",8899));
//Wait for the connection attempt to be finished.
cf.awaitUninterruptibly();
cf.getSession().getCloseFuture().awaitUninterruptibly();
connector.dispose();
}
}
1 楼 youyang 2010-02-01
哥们，问一个问题。
我用你的这个程序，客户端接收不到服务器发送来的数据是怎么回事。
2 楼 youyang 2010-02-01
如果你在了，一定要给回复一下。
这个问题快搞死我了。
3 楼 ＷＩＮ 2010-02-01
youyang 写道
如果你在了，一定要给回复一下。
这个问题快搞死我了。
不可能的哈，我都是经过测试了的啊，发现什么错误没哦
4 楼 youyang 2010-02-08
没错，但是也没有回。
留下你的E—MAIL，我把项目发给你，
你帮我看一下吧
5 楼 ＷＩＮ 2010-02-08
youyang 写道
没错，但是也没有回。
留下你的E—MAIL，我把项目发给你，
你帮我看一下吧
你把附件下下来看吧
6 楼 fjlyxx 2010-02-25
免责声明： 本文仅代表作者个人观点，与无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
