apache的MINA框架简单使用方法,教不会你算我输
来源:专注JavaWeb开发     阅读:678
二分熟
发布于 2019-01-26 01:52
查看主页

主要的包:mina-core-2.0.0.jar【到官网上下载完整项目包里面还有文档和依赖包】,jcl-over-slf4j-1.5.11.jar,slf4j-api-1.5.11.jar,slf4j-nop-1.5.11.jar这三个是mina使用的日志包。前面二个mina项目包里有。最后一个到官网上下吧,或者者加群找我要!

mina服务类:

package com.mina;

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.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import java.io.IOException;
import java.net.InetSocketAddress;

public class MinaServer {
private static final int PORT = 22222;// 定义监听端口
public static void main(String[] args) throws IOException {
//创立一个非阻塞的Server端socket,用NIO
IoAcceptor acceptor = new NioSocketAcceptor();
//创立接受数据的过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
//设定这个过滤器将一行一行的读取数据
chain.addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory()));// 指定编码过滤器
// 指定业务逻辑解决器
acceptor.setHandler(new Handler());
// 设置端口号
acceptor.setDefaultLocalAddress(new InetSocketAddress(PORT));
acceptor.bind(); //启动监听
System.out.println("Mina Server is Listen on:"+PORT);
}
}

解决类。用来解决请求连接的。

package com.mina;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

import java.text.SimpleDateFormat;
import java.util.Date;

public class Handler extends IoHandlerAdapter {

//当一个用户端连接进入时
@Override
public void sessionOpened(IoSession session)throws Exception {
System.out.println("incoming client:"+session.getRemoteAddress());
}
//当用户端发送消息到达时
@Override
public void messageReceived(IoSession session, Object message)throws Exception {
String s = message.toString();
System.out.println("client send message is:"+s);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd mm:hh:ss");
Date date = new Date();
session.write(sdf.format(date));// 返回当前时间的字符串
System.out.println("message written...");
}
//当一个用户端连接关闭时
@Override
public void sessionClosed(IoSession session)throws Exception {
System.out.println("one client closed");
}
}

完事了,

运行MinaServer就行了。

而后测试下。在命令行运行“telnet 127.0.0.1 22222”,当服务器端出现“incoming client:/127.0.0.1:2333”,表示你连接成功了

apache的MINA框架简单使用方法,教不会你算我输

而后你在命令行随意写个字符,而后回车。假如可以看到由服务器返回来的时间串就OK了。假如输入的是中文,服务器会收不到!这个问题还没仔细处理!还有就是你可以开多个命令行去连接!

免责声明:本文为用户发表,不代表网站立场,仅供参考,不构成引导等用途。 系统环境 软件环境
相关推荐
ipa和apk简易瘦身
金三银四面试季—19道精选Dubbo面试问题(含答案分析)!
Mariadb基于GTID的双主复制配置
编写更好的CSS的三个技巧
13、优化轮播图组件与vue深度解决器
首页
搜索
订单
购物车
我的