Java - Apache Mina 简单示例

一、关于

    Apache MINA 是一个网络应用程序框架，它对Java中的socket和NIO进行了有效和清晰的封装，方便开发人员开发TCP/UDP程序，从而抛开在使用原始的socket时需要考虑的各种繁杂而又烦人问题（线程、性能、会话等），把更多精力专著在应用中的业务逻辑的开发上。

二、示例

    1、相关准备

        下载Mina，创建工程，添加mina核心的jar和slf4j的jar

    2、服务器端

        （1）Main

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
public class ServerMain {
public static void main(String[] args) throws IOException {
//	监听连接对象 基于tcp/ip
IoAcceptor acceptor = new NioSocketAcceptor();
//	绑定端口
SocketAddress address = new InetSocketAddress("localhost", 8888);
//	获取过滤器链
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
//	添加日志过滤器
chain.addLast("logger", new LoggingFilter());
//	配置数据的编解码器 这里使用了序列化编解码工厂　
chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
acceptor.setHandler(new ServerHandler());
//	绑定服务器端口　
acceptor.bind(address);
System.out.println("　服务器在 8888 端口监听.......");
}
}

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
/**
* 自定义Handler需实现IoHandler接口，可通过继承IoHandlerAdapter来完成
*/
public class ServerHandler extends IoHandlerAdapter{
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
// 接受消息
System.out.println("服务器端接接收到的消息：" + message.toString());
}
@Override
public void messageSent(IoSession session, Object message) throws Exception {
// 发送消息
super.messageSent(session, message);
}
@Override
public void sessionOpened(IoSession session) throws Exception {
// 已创建会话
System.out.println("客户端已连接...");
session.write("欢迎到连接Mina服务器!!!");
//这里也可以发送其他实现了Serializable接口的对象
}
}

        （1）Main

import java.net.InetSocketAddress;
import java.net.SocketAddress;
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.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
public class ClientMain {
public static void main(String[] args) {
//	创建连接对象，基于tcp/ip
NioSocketConnector connector = new NioSocketConnector();
SocketAddress address = new InetSocketAddress("localhost", 8888);
//	获取过滤器链
DefaultIoFilterChainBuilder chain = connector.getFilterChain();
//	添加日志过滤器
chain.addLast("logger", new LoggingFilter());
//	配置数据的编解码器　
chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
//	IoHandler的作用： 业务处理的装置
//	添加Handler
connector.setHandler(new ClientHandler());
//	连接到服务器　
ConnectFuture future = connector.connect(address);
//	等待数据发送完毕
future.awaitUninterruptibly();
//	关闭连接
//	connector.dispose();
}
}

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
public class ClientHandler extends IoHandlerAdapter{
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
// 接收
System.out.println("客户端接收到的消息：" + message);
}
@Override
public void messageSent(IoSession session, Object message) throws Exception {
// 发送
super.messageSent(session, message);
}
@Override
public void sessionOpened(IoSession session) throws Exception {
// 已创建会话
System.out.println("已经连接到了服务器....");
session.write("Mina服务器端，你好!!!");
}
}

        （1）服务器端

        （2）客户端

三、说明

    IoFilter的作用：接收数据，编/解码，将数据传递到逻辑层

    IoHandler的作用：业务处理的装置

四、资源

     http://download.csdn.net/detail/u013379717/7574657

最后

以上就是优秀蜻蜓最近收集整理的关于Java - Apache Mina 简单示例的全部内容，更多相关Java内容请搜索靠谱客的其他文章。