上一篇博客写的是怎样运用Mina的一些Java包来写通信的优化应用。下面是写的是客服端和服务端的代码:
/**
* 创建客户端处理器
*
* @author luozhong
*
*/
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;
public class Client_MinaTest {
public static void main(String args[]) {
// 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 ExceptionClient_mina());
// Set connect timeout.
connector.setConnectTimeout(30);
// 连结到服务器:
ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",
8888));
// Wait for the connection attempt to be finished.
cf.awaitUninterruptibly();
cf.getSession().getCloseFuture().awaitUninterruptibly();
connector.dispose();
}
}
/**
* 创建客户端处理器
*
* @author luozhong
*
*/
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
public class ExceptionClient_mina extends IoHandlerAdapter {
// 客服端连接
public void sessionOpened(IoSession session) throws Exception {
System.out.println("进入链接:" + session.getRemoteAddress());
session.write("I am coming!");
}
// 当一个客户端关闭时
@Override
public void sessionClosed(IoSession session) {
System.out.println("one Clinet Disconnect !");
}
// 当客户端发送的消息到达时:
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
// 我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:
String s = (String) message;
// Write the received data back to remote peer
System.out.println("服务器发来的收到消息: " + s);
// 测试将消息回送给客户端
session.write(s);
}
}
/**
* Mina服务端测试
* @author luozhong
*
*/
import java.net.InetSocketAddress;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
public class MinaServerTest {
public static void main(String[] args) throws IOException {
//创建一个非阻塞的Server和Socket,用NIO
SocketAcceptor acceptor=new NioSocketAcceptor();
//创建接收数据的过滤器
DefaultIoFilterChainBuilder filter=acceptor.getFilterChain();
//设定过滤器一行一行的读取数据
filter.addLast("myMina", new ProtocolCodecFilter(new TextLineCodecFactory()));
//设定服务器端的消息处理器:SamplMinaServerHandler对象
acceptor.setHandler(new ExceptionMiNa());
//服务器绑定的端口
int port=8888;
//绑定端口,启动服务器
acceptor.bind(new InetSocketAddress(port));
System.out.println("Mina Server is Listing on:= " + port);
}
}
/**
* 自定义消息处理器
*
* @author luozhong
*
*/
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
public class ExceptionMiNa extends IoHandlerAdapter {
private int count;
// 客服端进入连接时
public void sessionOpend(IoSession session) {
System.out.println("进入连接:" + session.getRemoteAddress());
}
//当一个客服端关闭时
public void sessionClosed(IoSession session){
System.out.println("关闭连接");
}
//当客服端发送的消息到达时
public void ReceivedMsg(IoSession session,Object msg){
//定规则一行一行读取,转为字符串
String str=(String)msg;
System.out.println("受到客户发来的信息:"+str);
//测试将信息回送给客户机
session.write(str+count);
count++;
}
}
分享到:
相关推荐
NULL 博文链接:https://sziitjiang.iteye.com/blog/1646625
代码利用mina框架实现了服务器端和客户端,客户端的登录请求、客户端向服务器端请求图片文件的功能。代码分为服务端和客户端,开发环境eclipse。服务器代码可在web项目中使用,客户端代码可以在Android开发时使用,...
本源码是《NIO框架入门(三):iOS与MINA2、Netty4的跨平台UDP双向通信实战》一文的服务端实现(MINA2版),详见:http://www.52im.net/thread-378-1-1.html
从github上下载的mina框架源码 Apache MINA(Multipurpose Infrastructure for Network Applications) 是 Apache 组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便 apache mina apache mina...
Mina2.0框架源码剖析,方便大家的学习,对于java网络通信的朋友很有帮助。
说明:该服务器框架试用于需要频繁修改数据库内容的游戏,没有使用数据库缓存,jdbc直接修改数据库内容。 申明: 我是个新手,有出错的...自定义通信协议 net.mina.service:网络层(MINA框架,这个不多说,你懂的)
本源码是《NIO框架入门(三):iOS与MINA2、Netty4的跨平台UDP双向通信实战》一文的服务端源码实现(Netty4版),详见:http://www.52im.net/thread-378-1-1.html
NULL 博文链接:https://aniyo.iteye.com/blog/1609337
本源码是《NIO框架入门(二):服务端基于MINA2的UDP双向通信Demo演示》一文的MINA2服务端源码实现,详见:http://www.52im.net/thread-373-1-1.html
NULL 博文链接:https://fxzcollege6.iteye.com/blog/1991174
关于apache组织的mina通信框架,可替代 java.NIO.Selector 的更好选择, 里面包括 mina 2.07版本的源码,编译好的jar文件,以及一些网络上找来的网摘资料文档 [截至2013年10月止]。 打包文件名:...
本源码是《NIO框架入门(二):服务端基于MINA2的UDP双向通信Demo演示》一文的Java客户端源码实现,详见:http://www.52im.net/thread-373-1-1.html
本源码是《NIO框架入门(三):iOS与MINA2、Netty4的跨平台UDP双向通信实战》文中的代码,详见:http://www.52im.net/thread-378-1-1.html
NULL 博文链接:https://donald-draper.iteye.com/blog/2375297
本源码是《NIO框架入门(四):Android与MINA2、Netty4的跨平台UDP双向通信实战》文中的代码,详见:http://www.52im.net/thread-388-1-1.html
Netty、Mina、Cindy都是不错的NIO开源框架,后两者都是在Netty的基础上演化出来的。所以要学习好Java的异步通信框架,这三个都是不可多得的好材料。 本资源仅供学习和参考使用,若要进行开发,请下载相应的Jar包。
资源包括: MINA笔记.docx ...Mina2.0快速入门与源码剖析.pdf MINA网络框架和RMI的对比研究.pdf 基于3G网络的移动流媒体服务器的设计与实现.pdf 高性能通信框架及智能主站技术研究.nh MINA类图.doc 等
Netty、Mina、Cindy都是不错的NIO开源框架,后两者都是在Netty的基础上演化出来的。所以要学习好Java的异步通信框架,这三个都是不可多得的好材料。 本资源仅供学习和参考使用,若要进行开发,请下载相应的Jar包
Java 源码包 Applet钢琴模拟程序java源码 2个目标文件,提供基本的音乐编辑功能。编辑音乐软件的朋友,这款实例会对你有所帮助。 Calendar万年历 1个目标文件 EJB 模拟银行ATM流程及操作源代码 6个目标文件,EJB来...