Apache Mina 入门Demo
什么是Mina，用Mina可以干什么？官网：http://mina.apache.org/
看不懂英文？那就随便百度，大概了解一下。
最终效果：
项目目录结构：
pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.royal</groupId>
<artifactId>minaDemo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>minaDemo</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<!-- mina需要用到的包 -->
<dependency>
<groupId>org.apache.mina</groupId>
<artifactId>mina-core</artifactId>
<version>2.0.4</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-nop</artifactId>
<version>1.6.1</version>
</dependency>
</dependencies>
</project>
User.java
package com.royal.model;
import java.io.Serializable;
public class User implements Serializable {
private static final long serialVersionUID = 1L;
private String name;
private int age;
public User() {
}
public User(String name, int age) {
this.name = name;
this.age = age;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
Mina服务端编写：
MinaServer.java
package com.royal.service;
import java.io.IOException;
import java.net.InetSocketAddress;
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.transport.socket.nio.NioSocketAcceptor;
/**
* mina服务端
* @author Royal
*
*/
public class MinaServer {
public static void main(String[] args) throws IOException {
// 创建一个非阻塞的Server端 Socket,用NIO
IoAcceptor acceptor = new NioSocketAcceptor();
// 创建接收数据的过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
// 设定这个过滤器将以对象为单位读取数
ProtocolCodecFilter filter = new ProtocolCodecFilter(new ObjectSerializationCodecFactory());
chain.addLast("objectFilter", filter);
// 设定服务器端的消息处理器:一个ObjectMinaServerHandler对象,
acceptor.setHandler(new ObjectMinaServerHandler());
// 服务器端绑定的端口
int bindPort = 9988;
// 绑定端口,启动服务器
acceptor.bind(new InetSocketAddress(bindPort));
System.out.println("Mina Server is Listing on:= " + bindPort);
}
}
ObjectMinaServerHandler.java
package com.royal.service;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import com.royal.model.User;
/**
* 对象服务接受处理类
*
* @author Royal
*
*/
public class ObjectMinaServerHandler extends IoHandlerAdapter {
// 记录接受数据的次数
private int count = 0;
/**
* 当客户端 发送 的消息到达时
*/
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
// 我们己设定了服务器解析消息的规则一个User对象为单位传输:
User u = (User) message;
System.out.println("这里是服务器(" + session.getLocalAddress() + ")\t收到客户机(" + session.getRemoteAddress() + ")发来的用户对象：" + u.toString() + "---------" + count);
count++;
if (count == 1000) {
count = 0;
// 服务器主动断开与客户端的连接
session.close(true);
}
// 发送到客户端
session.write(u);
}
/**
* 当一个客户端连接进入时
*/
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("incomming client: " + session.getRemoteAddress());
}
/**
* 当一个客户端关闭时
*/
@Override
public void sessionClosed(IoSession session) throws Exception {
System.out.println(session.getRemoteAddress() + " client Disconnect!");
}
/**
* 当捕获到异常的时候
*/
@Override
public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
System.err.println("error!!!!!!!!!!!!!");
super.exceptionCaught(session, cause);
}
}
Mina客户端测试编写：
MinaClient.java
package com.royal.client;
import java.net.InetSocketAddress;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
/**
* mina测试客户端
* @author Royal
*
*/
public class MinaClient {
public static void main(String[] args) {
// Create TCP/IP connector.
IoConnector connector = new NioSocketConnector();
// 创建接收数据的过滤器
DefaultIoFilterChainBuilder chain = connector.getFilterChain();
// 设定这个过滤器将以对象为单位读取数
ProtocolCodecFilter filter = new ProtocolCodecFilter(new ObjectSerializationCodecFactory());
chain.addLast("objectFilter", filter);
// 设定客户端的消息处理器:一个ObjectMinaClientHandler对象,
connector.setHandler(new ObjectMinaClientHandler());
// 连结到服务器:
ConnectFuture cf = connector.connect(new InetSocketAddress("localhost", 9988));
// 等待连接创建完成
cf.awaitUninterruptibly();
// 等待连接断开
cf.getSession().getCloseFuture().awaitUninterruptibly();
// 客户端断开链接，释放资源
connector.dispose();
}
}
ObjectMinaClientHandler.java
package com.royal.client;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import com.royal.model.User;
/**
* 对象客户端接受处理类
*
* @author Royal
*
*/
public class ObjectMinaClientHandler extends IoHandlerAdapter {
// 当一个服务端连结进入时
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("connect server : " + session.getRemoteAddress());
session.write(new User("mina", 18));
}
// 当一个服务端关闭时
@Override
public void sessionClosed(IoSession session) {
System.out.println(session.getRemoteAddress() + " server Disconnect !");
}
// 当服务器发送的消息到达时:
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
User u = (User) message;
System.out.println("这里是客户端(" + session.getLocalAddress() + ")\t服务器(" + session.getRemoteAddress() + ")发来的消息: " + u.getName() + "\t" + u.getAge());
// 发送到服务端
session.write(u);
}
}
OK，就这样。
首先运行服务端MinaServer：
接着运行客户端MinaClient：
页:
[1]