- 浏览: 2145272 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (1240)
- mac/IOS (287)
- flutter (1)
- J2EE (115)
- android基础知识 (582)
- android中级知识 (55)
- android组件(Widget)开发 (18)
- android 错误 (21)
- javascript (18)
- linux (70)
- 树莓派 (18)
- gwt/gxt (1)
- 工具(IDE)/包(jar) (18)
- web前端 (17)
- java 算法 (8)
- 其它 (5)
- chrome (7)
- 数据库 (8)
- 经济/金融 (0)
- english (2)
- HTML5 (7)
- 网络安全 (14)
- 设计欣赏/设计窗 (8)
- 汇编/C (8)
- 工具类 (4)
- 游戏 (5)
- 开发频道 (5)
- Android OpenGL (1)
- 科学 (4)
- 运维 (0)
- 好东西 (6)
- 美食 (1)
最新评论
-
liangzai_cool:
请教一下,文中,shell、C、Python三种方式控制led ...
树莓派 - MAX7219 -
jiazimo:
...
Kafka源码分析-序列5 -Producer -RecordAccumulator队列分析 -
hp321:
Windows该命令是不是需要安装什么软件才可以?我试过不行( ...
ImageIO读jpg的时候出现javax.imageio.IIOException: Unsupported Image Type -
hp321:
Chenzh_758 写道其实直接用一下代码就可以解决了:JP ...
ImageIO读jpg的时候出现javax.imageio.IIOException: Unsupported Image Type -
huanghonhpeng:
大哥你真强什么都会,研究研究。。。。小弟在这里学到了很多知识。 ...
android 浏览器
mina是对nio的具体实现。是目前比较高效和流行的nio框架了。
下面是对使用mina进行通讯的一个简单demo,后面再用mina写一个RPC的简单框架。
mina主要包括:
(使用的mina版本为2.0.0.M4 core,具体可见官方网站 )
mina也分服务端和客户端(这是肯定的...)
其中服务端为:NioSocketAcceptor
客户端为:NioSocketConnector
类似于Socket的服务端跟客户端Socket。除了这些用来基本通讯的之外,还有一些可以用来处理通讯中的操作类。就是在客户端和服务端的一个个filter。这些filter可以用来进行解码,编码,可以配置日志信息,可以设定序列化类型,等等。
另外为客户端和服务端都可以绑定一个IoHnadler,用来处理连接session在打开,收到信息,关闭等状态时候可以进行的动作。
现在就来使用mina进行一个简单的客户端上传文件的demo的实现:
demo实现的思想为:
客 户端跟服务端建立起来连接,客户端每次想服务端传输一定大小的文件内容。(byte的方式),然后服务端接收这些byte,将其output出来,形成文 件。客户端发送完毕后,传递一个完毕的标志,这里可以传个字符串”finish“,然后服务器收到这个结束标志,在写文件结束后,再传输个成功的标志给客 户端,(字符串”success“)然后客户端关闭连接。
服务端:
代码比较简单。
就这样简单的完成了服务端的实现,其实可以复杂一些,其中的log跟code都可以根据需要自己来写和生成,这里只使用mina自带的。
然后是服务端的handler。
所有的handler都要继承IoHandlerAdapter,可以查看IoHandlerAdapter,其包括几个关于session状态的方法。按需进行重载即可。
然后就是公用的用来传输的DO:FileUploadRequest简单的POJO
接下来看下客户端的实现,也很简单:
客户端handler的实现。
心得:
注意其中关于文件的操作,outPutStream在传输完之后要进行flush跟close,因此需要客户端给一个结束的标志,才能进行判断。mina的结构也比较清晰,深层次的以后再研究。
PS:
有个小小疑问:在客户端对session不停的write之后,服务端在接收的时候是能保证按照我写入的顺序来读取的吗。估计这其中的传递用的是一个能同步的队列。这样才能保证客户端写的顺序跟服务端读的顺序一致。
下面是对使用mina进行通讯的一个简单demo,后面再用mina写一个RPC的简单框架。
mina主要包括:
(使用的mina版本为2.0.0.M4 core,具体可见官方网站 )
mina也分服务端和客户端(这是肯定的...)
其中服务端为:NioSocketAcceptor
客户端为:NioSocketConnector
类似于Socket的服务端跟客户端Socket。除了这些用来基本通讯的之外,还有一些可以用来处理通讯中的操作类。就是在客户端和服务端的一个个filter。这些filter可以用来进行解码,编码,可以配置日志信息,可以设定序列化类型,等等。
另外为客户端和服务端都可以绑定一个IoHnadler,用来处理连接session在打开,收到信息,关闭等状态时候可以进行的动作。
现在就来使用mina进行一个简单的客户端上传文件的demo的实现:
demo实现的思想为:
客 户端跟服务端建立起来连接,客户端每次想服务端传输一定大小的文件内容。(byte的方式),然后服务端接收这些byte,将其output出来,形成文 件。客户端发送完毕后,传递一个完毕的标志,这里可以传个字符串”finish“,然后服务器收到这个结束标志,在写文件结束后,再传输个成功的标志给客 户端,(字符串”success“)然后客户端关闭连接。
服务端:
代码比较简单。
import java.net.InetSocketAddress; 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 Main { private static final int PORT = 8080; public static void main(String[] args) throws Exception { //服务端的实例 NioSocketAcceptor accept=new NioSocketAcceptor(); //添加filter,codec为序列化方式。这里为对象序列化方式,即表示传递的是对象。 accept.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory())); //添加filter,日志信息 accept.getFilterChain().addLast("logging", new LoggingFilter()); //设置服务端的handler accept.setHandler(new FileUploadHandler()); //绑定ip accept.bind(new InetSocketAddress(PORT)); System.out.println("upload server started."); } }
就这样简单的完成了服务端的实现,其实可以复杂一些,其中的log跟code都可以根据需要自己来写和生成,这里只使用mina自带的。
然后是服务端的handler。
import java.io.BufferedOutputStream; import java.io.File; import java.io.FileOutputStream; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IoSession; public class FileUploadHandler extends IoHandlerAdapter { private BufferedOutputStream out; private int count; private String fileName = "D:/log/test.jpg"; private static final Log log = LogFactory.getLog(FileUploadHandler.class); public void sessionOpened(IoSession session) throws Exception { System.out.println("server open"); } public void exceptionCaught(IoSession session, Throwable cause) throws Exception { System.out.println("exception"); session.close(true); super.exceptionCaught(session, cause); } public void messageReceived(IoSession session, Object message) { System.out.println("server received"); try { if (message instanceof FileUploadRequest) { //FileUploadRequest 为传递过程中使用的DO。 FileUploadRequest request = (FileUploadRequest) message; System.out.println(request.getFilename()); if (out == null) { //新建一个文件输入对象BufferedOutputStream,随便定义新文件的位置 out = new BufferedOutputStream(new FileOutputStream( "D:/log/" + request.getFilename())); out.write(request.getFileContent()); } else { out.write(request.getFileContent()); } count += request.getFileContent().length; } else if (message instanceof String) { if (((String)message).equals("finish")) { System.out.println("size is"+count); //这里是进行文件传输后,要进行flush和close否则传递的文件不完整。 out.flush(); out.close(); //回执客户端信息,上传文件成功 session.write("success"); } } } catch (Exception e) { e.printStackTrace(); } } public void sessionClosed(IoSession session) throws Exception { System.out.println("server session close"); } }
所有的handler都要继承IoHandlerAdapter,可以查看IoHandlerAdapter,其包括几个关于session状态的方法。按需进行重载即可。
然后就是公用的用来传输的DO:FileUploadRequest简单的POJO
import java.io.Serializable; public class FileUploadRequest implements Serializable { private String hostname; private String filename; private byte[] fileContent; public String getHostname() { return hostname; } public void setHostname(String hostname) { this.hostname = hostname; } public String getFilename() { return filename; } public void setFilename(String filename) { this.filename = filename; } public byte[] getFileContent() { return fileContent; } public void setFileContent(byte[] fileContent) { this.fileContent = fileContent; } }
接下来看下客户端的实现,也很简单:
import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.net.InetSocketAddress; import nio.upload.server.FileUploadRequest; import org.apache.mina.core.future.ConnectFuture; import org.apache.mina.core.session.IoSession; 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 MainClient { private static final int PORT = 8080; /** * @param args * @throws IOException */ public static void main(String[] args) throws Exception { //客户端的实现 NioSocketConnector connector = new NioSocketConnector(); connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory())); connector.getFilterChain().addLast("logging", new LoggingFilter()); FileUploadClientHandler h = new FileUploadClientHandler(); connector.setHandler(h); //本句需要加上,否则无法调用下面的readFuture来从session中读取到服务端返回的信息。 connector.getSessionConfig().setUseReadOperation(true); ConnectFuture cf = connector.connect(new InetSocketAddress("localhost", PORT)); IoSession session; //等待连接成功 cf.awaitUninterruptibly(); session = cf.getSession(); System.out.println("client send begin"); //传递文件开始 String fileName = "test.jpg"; FileInputStream fis = new FileInputStream(new File(fileName)); byte[] a = new byte[1024 * 4]; FileUploadRequest request = new FileUploadRequest(); request.setFilename(fileName); request.setHostname("localhost"); while (fis.read(a, 0, a.length) != -1) { request.setFileContent(a); //像session中写入信息供服务端获得 session.write(request); } //发送完成的标志 session.write(new String("finish")); System.out.println("client send finished and wait success"); //接上面来取得服务端的信息 Object result = session.read().awaitUninterruptibly().getMessage(); if (result.equals("success")) { System.out.println("success!"); //关闭客户端 connector.dispose(); } } }
客户端handler的实现。
import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IoSession; public class FileUploadClientHandler extends IoHandlerAdapter { public void sessionOpened(IoSession session) throws Exception { System.out.println("client open"); } public void sessionClosed(IoSession session) throws Exception { System.out.println("client session close"); } public void messageReceived(IoSession session, Object message) throws Exception { System.out.println("thr result is" + message); } }
心得:
注意其中关于文件的操作,outPutStream在传输完之后要进行flush跟close,因此需要客户端给一个结束的标志,才能进行判断。mina的结构也比较清晰,深层次的以后再研究。
PS:
有个小小疑问:在客户端对session不停的write之后,服务端在接收的时候是能保证按照我写入的顺序来读取的吗。估计这其中的传递用的是一个能同步的队列。这样才能保证客户端写的顺序跟服务端读的顺序一致。
发表评论
-
小程序textarea完美填坑
2020-07-07 16:09 459相信做微信小程序的码友们都被textarea这个原生组件坑过 ... -
Nginx+Https自己敲命令生成证书
2020-05-18 09:35 896一、准备 环境:centos6.8 ... -
https证书生成环境搭建配置(基于Tomcat和Nginx)
2020-04-24 11:06 778一、基于Tomcat、JDK内置密钥工具: 1、生成服务端证 ... -
史上最强Tomcat8性能优化
2019-11-01 21:41 730授人以鱼不如授人以渔 ... -
SpringBoot配置HTTPS,并实现HTTP访问自动转HTTPS访问
2019-10-07 09:13 5181.使用jdk自带的 keytools 创建证书 打开cmd ... -
Spring Boot工程集成全局唯一ID生成器 UidGenerator
2019-09-16 09:04 808概述 流水号生成器(全局唯一 ID生成器)是服务化系统的基础 ... -
CentOS7下Redis的安装与使用
2019-08-17 11:45 556一、手动安装过程 1、准备工作(安装gcc依赖) yum ... -
Nginx与tomcat组合的简单使用
2019-08-17 10:05 365配置tomcat跳转 请求http出现400的时候在这里配置 ... -
linux下lvs+keepalived安装配置
2019-07-10 14:20 430keepalived主机:192.168.174. ... -
使用Docker搭建Tomcat运行环境
2019-02-08 21:32 4451 准备宿主系统 准备一 ... -
Netty笔记-GlobalEventExecutor
2019-02-06 23:00 5771.概念 /** * Single-thread si ... -
Netty4转发服务的实现方案
2019-02-06 15:03 1040如果用Netty做转发服务(不需要同步应答),Netty中有一 ... -
java手机号归属地查询
2018-12-25 17:16 702所需的包:carrier-1.75.jar 、geocoder ... -
基于Netty4的HttpServer和HttpClient的简单实现
2018-10-17 20:02 626Http 消息格式: Http request: Met ... -
javafx : 支持使用微调(spinner)控制的数字的文本框(NemberTextField)
2018-10-16 00:00 994最近花了一些时间学习javaFX, 要更深入地理解新GUI包, ... -
我的Java(定制你的Java/JavaFX Runtime)
2018-10-12 23:29 629最新的JDK 11发布了,撒花 新版本的JDK终于有了ope ... -
javaFX的几个新特性,让swing彻底过时
2018-10-12 22:42 605首先声明,Java的GUI曾经 ... -
mac os系统用install4j把jar包生成app
2018-10-05 23:02 1348install4j有windows版也有mac版 mac电脑 ... -
JavaFX Alert对话框
2018-10-05 22:01 22431. 标准对话框 消息对话框 Alert alert = ... -
IDEA Properties中文unicode转码问题
2017-02-17 19:54 928摘要: 如何让IDEA的properties中的中文进行uni ...
相关推荐
高性能Java网络框架 MINA
这是一个有关Mina在Java通信中运用的简单的入门实例,MIna自带一种触发机制,无需再开线程等待收发数据。这个实例中有客户端和服务端,与软件TCPUDPDbg进行文字通话测试。用的时候注意添加Mina包,此实例中用到的是...
高性能Java网络框架 MINA.7z
详细介绍mina框架的各个组成部分、服务器端的开发、客户端开发。并根据本人在工程项目中使用的代码,详细讲解了服务器端是客户端实现。实现了json格式的通信、以及文件的上传于下载等功能。图文并茂,以开发者的角度...
简单实现mina服务器框架的websocket通信(Simple implementation of websocket communication in mina server
Apache MINA 是一个开发高性能和高可伸缩性网络应用程序的网络应用框架。它提供了一个抽象的事件驱动的异步 API,可以使用 TCP/IP、UDP/IP、串口和虚拟机内部的管道等传输方式。Apache MINA 可以作为开发网络应用...
java mina组合包 非常齐全
java mina框架
Apache mina网络应用开发框架的demo。Apache mina是Java的非常优秀的网络应用开发框架。
java mina 通讯框架
java 实现的mina server client完全能用的
基于Java的米娜框架,报告对使用基于Java、websocket协议的网页聊天室的过程和技术做了详细的叙述首先,对现有网页进行了分析与评价。首先, 启动后台服务器,然后连接站点,客户端在pc端输入网站或者在手机端扫...
mina2源码
java客户端socket与mina服务端通信,保持长连接
Mina2.0框架:客户端Demo,服务器端Demo,根目录下有整理的《Mina2.0学习笔记》
NULL 博文链接:https://410063005.iteye.com/blog/1724491
基于Java的高性能Java网络框架 MINA.zip
基于java的高性能Java网络框架 MINA.zip
Java_NIO基础教程、MINA教程, 并附上基于springboot 整合mina的基础平台框架,可以直接使用,也可以借鉴下