大家好,又见面了,我是你们的朋友全栈君。
一、mina简介
mina框架是对nio进行的一个封装,可用于java的网络编程,包括TCP/IP和UTP/IP编程,主要屏蔽了网络通信的一些细节,对socket进行封装,并且是用nio的一个实现框架,mina的主要类如下:
1、IoService接口
用于描述客户端和服务端的接口,子类有IoConnector(客户端)和IoAcceptor(服务端)。
1.1 IoConnector接口
该接口用于描述客户端,链接远程服务端,实现类是NioSocketConnector。
-
NioSocketConnector
该类具体实现了链接远程网络的方法。
1.2 IoAcceptor接口
该接口定义了作为服务端 要干的事情,具体实现类是NioSocketAcceptor。
-
NioSocketAcceptor
该类具体实现了监听远程发送过来的链接后的各种操作。
2、IoProceser
多线程环境来处理我们的链接请求流程。
3、IoFilter
提供数据的过滤工作,包括编码和解码、日志等信息的过滤。
4、Hanlder
处理具体的业务对象,默认的实现类有IoHanlderAcceptor,自定义的业务处理类,需要继承IoHanlderAcceptor类。
5、IoSession
描述客户端和服务端建立链接的会话,通过该会话,可接收和发送信息。
6、流程总结
客户端:IoConnector—>IoProcessor–>IoFilter—>Hanlder,
服务端:IoConnector—>IoProcessor–>IoFilter—>Hanlder。
二、简单的客户端和服务端实例
1、服务端
package mina.demo1;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
/**
* @author:zhangfd
* @version:1.0
* @date:2017年12月9日 下午10:32:41
* @description:
*/
public class MinaServer {
public static int port=3333;
private static IoAcceptor server = null;
public static void main(String[] args) throws IOException {
//1、创建服务器
server = new NioSocketAcceptor();
//2、设置编码过滤器
server.getFilterChain().addLast("codec",
new ProtocolCodecFilter(
new TextLineCodecFactory(
Charset.forName("utf-8"),
LineDelimiter.WINDOWS.getValue(),
LineDelimiter.WINDOWS.getValue())));
//3、设置一次读取数据的大小
server.getSessionConfig().setReadBufferSize(1024);
//4、设置网络闲置时间
server.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 1000);
//5、处理具体的业务信息
server.setHandler(new MyIoHandlerAdapterServer());
//6、绑定对本地端口的监听
server.bind(new InetSocketAddress(port));
}
}
总结:创建服务端步骤:
- 创建NioSocketAcceptor对象,
NioSocketAcceptor server = new NioSocketAcceptor();
2、设置编码、解码处理器链。
server.getFilterChain().addLast(处理器名, ProtocolCodecFilter对象)
(ProtocolCodecFilter对象的创建需要编码和解码器)
解码器类一般继承CumulativeProtocolDecoder
编码器类一般继承ProtocolEncoderAdapter
3、设置网络闲置时间
server.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 1000);
4、处理具体的业务信息
server.setHandler(new MyIoHandlerAdapterServer());
MyIoHandlerAdapterServer需要继承IoHandler类
5、绑定对本地端口的监听
server.bind(new InetSocketAddress(port));
2、客户端
package mina.demo2;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
/**
* @author:zhangfd
* @version:1.0
* @date:2017年12月10日 下午2:06:44
* @description:
*/
public class MinaClinet {
static int port=3333;
static String ip="localhost";
private static IoConnector client = null ;
static IoSession ioSession = null;
public static void main(String[] args) {
//1、创建客户端对象
client = new NioSocketConnector();
//2、设置编码过滤器
client.getFilterChain().addLast("coderc",
new ProtocolCodecFilter(
new TextLineCodecFactory(
Charset.forName("utf-8"),
LineDelimiter.WINDOWS.getValue(),
LineDelimiter.WINDOWS.getValue())));
//3、处理具体的业务
client.setHandler(new MyIoHandlerAdapterClient());
//4、设置链接超时时间
client.setConnectTimeoutMillis(3000);
//5、链接远程网络
ConnectFuture conncetFuture = client.connect(new InetSocketAddress(ip, port));
//6、等到链接
conncetFuture = conncetFuture.awaitUninterruptibly();
//7、获取当前链接远程会话
ioSession = conncetFuture.getSession();
//8、客户端发出消息
ioSession.write("客户端发出消息:你好,服务端");
//9、等待关闭会话
ioSession.getCloseFuture().awaitUninterruptibly();
//10、关闭客户端
client.dispose();
}
}
package mina.demo2;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
/**
* @author:zhangfd
* @version:1.0
* @date:2017年12月9日 下午10:54:56
* @description:
*/
public class MyIoHandlerAdapterClient extends IoHandlerAdapter{
@Override
public void sessionCreated(IoSession session) throws Exception {
System.out.println("sessionCreated");
}
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("sessionOpened");
}
@Override
public void sessionClosed(IoSession session) throws Exception {
// TODO Auto-generated method stub
super.sessionClosed(session);
}
@Override
public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
System.out.println("sessionIdle");
}
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
//接收来自服务端的消息
String msg = (String) message;
System.out.println("接收到来自服务端的消息为:"+msg);
//接收完后给客户端提供反馈消息
/*String s = "Thank you ,we had received your message";
session.write(s);*/
}
@Override
public void messageSent(IoSession session, Object message) throws Exception {
String msg = (String) message;
System.out.println("发送出去的信息为:"+msg);
}
}
步骤:
1、创建NioSocketConnector对象
//创建客户端对象
NioSocketConnector client = new NioSocketConnector();
2、//设置编码过滤器
client.getFilterChain().addLast(处理器名, ProtocolCodecFilter对象)
(ProtocolCodecFilter对象的创建需要编码和解码器)
解码器类一般继承CumulativeProtocolDecoder
编码器类一般继承ProtocolEncoderAdapter
3、//处理具体的业务
client.setHandler(new MyIoHandlerAdapterClient());
4、//设置链接超时时间
client.setConnectTimeoutMillis(3000);
5、//链接远程网络
ConnectFuture conncetFuture = client.connect(new InetSocketAddress(ip, port));
6、//等到链接
conncetFuture = conncetFuture.awaitUninterruptibly();
7、//获取当前链接远程会话
IoSession ioSession = conncetFuture.getSession();
8、//客户端发出消息
ioSession.write(“客户端发出消息:你好,服务端“);
9、//等待关闭会话
ioSession.getCloseFuture().awaitUninterruptibly();
10、//关闭客户端
client.dispose();
三、实际项目上的使用
在真实的项目中,经常拿mina与spring结合一起使用。
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/125896.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...