`
yeshaoting
  • 浏览: 685947 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

[转载]Mina框架传递对象

    博客分类:
  • J2SE
 
阅读更多

接触java的Mina框架已经有很多时间了,在网上也读过了很多的相关文章,发现Mina框架的确是一个值得拿来好好研究的东西,前些日子写了一个山寨QQ项目,其中的通信部分用到了java中自带的InputStream,OutputStream,Writer,Reader等等,感觉其中的很大的一个问题就是难以将事务处理的逻辑层与解析层分离开来,造成整个项目看起来比较臃肿,繁琐,不够模块化,接触Mina后发现mina在这方面做的很是恰到好处。

 

看到文章标题,你或许会有一些疑惑:

     1、Mina框架传递对象是怎么回事

     2、Mina传递对象可以用来做什么

     3、Mina传递对象是怎么进行的

     4、Mina传递对象过程中会遇到什么问题呢

 

      在用原来的java的InputStream,OutputStream,Writer,Reader等进行通信的时候我们会将信息编码转化成字节流等进行信息传递,InputStream,OutputStream是基于字节流的,而Writer,Reader是基于字符的,我们都知道进行通信的服务器和客户端是事先必须定好通信协议,如果我们将<msg>你好吗?</msg>定义为是一条消息,<request>视频</request>定义为一条视频请求,如果客户端将这条消息和请求发送给了服务器,服务器要想得到消息和请求的真正内容(在这里分别是“你好吗?”和“视频”)并进行处理和应答就必须进行信息的解析,就要一条一条的进行判断:1、如果是信息是<msg>……</msg>格式的就将其看做是一条消息;2、如果是<request>……</request>格式的就将其看作是一条请求;3、如果是其他形式就将其视为无效信息,不予处理。当然这不失为一种办法可以进行信息的提取,但是我们会发现在这个过程中信息的发送、接受、解析、处理、应答等都是一条一条的,很是零散,比较难以统一,没有实现消息定义和解析处理过程的分离,这样写好了一个程序,如果日后想要进行改正其中的一条信息格式,就要在整个项目中Ctrl+F了,比较繁琐,还容易出错。

 

      这是我们会自然的想到要用一种东西将各个格式的信息进行分类统一起来并方便进行一些必要的信息处理,为符合这些特点,我们会想到类这个东东恰恰满足了这些性质,我们可以将信息的格式中的内容定义为类的属性,而对这些属性的处理就可以用类中的方法来予以解决,这样就对信息进行了很好的包装。

 

      这种思想有了,那就是在通信的时候直接进行形式上的对象传递(实际上在通信的时候都是最终以字节流的方式进行传递的),那么我们就要找一种工具进行这种形式的信息传递,对了,这种工具就是Mina框架,我们只看他其中的一个方法

public void messageReceived(IoSession session, Object message),这是进行消息接收是能够被 触发的一个方法,参数session代表当前的会话对象,参数message代表接收的到的信息,这时您会发现message的类型是Object型,而类 Object 是类层次结构的根类,当然可以用对象型的作为message啦!前面提到通信的时候都是最终以字节流的方式进行传递的,这样就要进行:对象(客户端)->字节流(客户端)->发送->接收->字节流(服务器)->对象(服务器)的过程,呵呵不用担心,这些繁琐的过程,Mina都提供了很好的底层默认实现所以你只需稍稍敲点代码就行了。

       光说不练还是不行,先上一个程序实例:

      服务器端(1):

Java代码  收藏代码
  1. package Mina.server;  
  2.   
  3. import java.io.IOException;  
  4. import java.net.InetSocketAddress;  
  5.   
  6. import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;  
  7. import org.apache.mina.filter.codec.ProtocolCodecFilter;  
  8. import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;  
  9. import org.apache.mina.transport.socket.SocketAcceptor;  
  10. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;  
  11.   
  12. public class MainServer {  
  13.     private static MainServer mainServer = null;  
  14.     private SocketAcceptor acceptor = new NioSocketAcceptor();  
  15.     private DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();  
  16.     private int bindPort = 8888;  
  17.   
  18.     public static MainServer getInstances() {  
  19.         if (null == mainServer) {  
  20.             mainServer = new MainServer();  
  21.         }  
  22.         return mainServer;  
  23.     }  
  24.   
  25.     private MainServer() {  
  26.         chain.addLast("myChin"new ProtocolCodecFilter(  
  27.                 new ObjectSerializationCodecFactory()));  
  28.         acceptor.setHandler(ServerHandler.getInstances());  
  29.         try {  
  30.             acceptor.bind(new InetSocketAddress(bindPort));  
  31.         } catch (IOException e) {  
  32.             e.printStackTrace();  
  33.         }  
  34.     }  
  35.   
  36.     public static void main(String[] args) throws Exception {  
  37.         MainServer.getInstances();  
  38.     }  
  39. }  

 

 服务器端(2):

Java代码  收藏代码
  1. package Mina.server;  
  2.   
  3. import org.apache.mina.core.filterchain.IoFilterAdapter;  
  4. import org.apache.mina.core.service.IoHandler;  
  5. import org.apache.mina.core.session.IdleStatus;  
  6. import org.apache.mina.core.session.IoSession;  
  7.   
  8. import Mina.Object.UserInfo;  
  9.   
  10. public class ServerHandler extends IoFilterAdapter implements IoHandler {  
  11.     private static ServerHandler samplMinaServerHandler = null;  
  12.   
  13.     public static ServerHandler getInstances() {  
  14.         if (null == samplMinaServerHandler) {  
  15.             samplMinaServerHandler = new ServerHandler();  
  16.         }  
  17.         return samplMinaServerHandler;  
  18.     }  
  19.   
  20.     private ServerHandler() {  
  21.   
  22.     }  
  23.   
  24.     // 当连接后打开时触发此方法,一般此方法与 sessionCreated 会被同时触发  
  25.     public void sessionOpened(IoSession session) throws Exception {  
  26.     }  
  27.     public void sessionClosed(IoSession session) {  
  28.     }  
  29.     public void messageReceived(IoSession session, Object message)  
  30.             throws Exception {    
  31.         if (message instanceof UserInfo) {  
  32.             UserInfo text = (UserInfo) message;  
  33.             System.out.println("服务器接收到从客户端的姓名:"+text.getName());  
  34.             System.out.println("服务器接收到从客户端的QQ:"+text.getQQNum());  
  35.         }   
  36.     }  
  37.   
  38.     public void exceptionCaught(IoSession arg0, Throwable arg1)  
  39.             throws Exception {  
  40.   
  41.     }  
  42.   
  43.     // 当消息传送到客户端后触发  
  44.     public void messageSent(IoSession arg0, Object arg1) throws Exception {  
  45.           
  46.     }  
  47.   
  48.     // 当一个新客户端连接后触发此方法.  
  49.     public void sessionCreated(IoSession arg0) throws Exception {  
  50.           
  51.     }  
  52.   
  53.     // 当连接空闲时触发此方法.  
  54.     public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception {  
  55.           
  56.     }  
  57.   
  58. }  

 

 

 

客户端(1):

Java代码  收藏代码
  1. package Mina.client;  
  2.   
  3. import java.net.InetSocketAddress;  
  4.   
  5. import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;  
  6. import org.apache.mina.core.future.ConnectFuture;  
  7. import org.apache.mina.filter.codec.ProtocolCodecFilter;  
  8. import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;  
  9. import org.apache.mina.transport.socket.nio.NioSocketConnector;  
  10.   
  11. public class MainClient {  
  12.     private static MainClient mainClient = null;  
  13.     NioSocketConnector connector = new NioSocketConnector();  
  14.     DefaultIoFilterChainBuilder chain = connector.getFilterChain();  
  15.   
  16.     public static MainClient getInstances() {  
  17.         if (null == mainClient) {  
  18.             mainClient = new MainClient();  
  19.         }  
  20.         return mainClient;  
  21.     }  
  22.   
  23.     private MainClient() {  
  24.         chain.addLast("myChin"new ProtocolCodecFilter(  
  25.                 new ObjectSerializationCodecFactory()));  
  26.         connector.setHandler(ClientHandler.getInstances());  
  27.         connector.setConnectTimeout(30);  
  28.         ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",  
  29.                 8888));  
  30.     }  
  31.   
  32.     public static void main(String args[]) {  
  33.         MainClient.getInstances();  
  34.     }  
  35. }  

 

客户端(2):

Java代码  收藏代码
  1. package Mina.client;  
  2.   
  3. import org.apache.mina.core.service.IoHandlerAdapter;  
  4. import org.apache.mina.core.session.IoSession;  
  5.   
  6. import Mina.Object.UserInfo;  
  7.   
  8. public class ClientHandler extends IoHandlerAdapter {  
  9.     private static ClientHandler samplMinaClientHandler = null;  
  10.     public static ClientHandler getInstances() {  
  11.         if (null == samplMinaClientHandler) {  
  12.             samplMinaClientHandler = new ClientHandler();  
  13.         }  
  14.         return samplMinaClientHandler;  
  15.     }  
  16.   
  17.     private ClientHandler() {  
  18.   
  19.     }  
  20.   
  21.     public void sessionOpened(IoSession session) throws Exception {  
  22.         session.write("客户端与服务器的会话打开了……");  
  23.         UserInfo text=new UserInfo();  
  24.         text.setName("梅竹寒香");  
  25.         text.setQQNum("972341215");  
  26.         session.write(text);  
  27.     }  
  28.   
  29.     public void sessionClosed(IoSession session) {  
  30.     }  
  31.   
  32.     public void messageReceived(IoSession session, Object message)  
  33.             throws Exception {  
  34.     }  
  35.   
  36.     public void messageSent(IoSession arg0, Object arg1) throws Exception {  
  37.         System.out.println("客户端已经向服务器发送了:"+(String)arg1);  
  38.     }  
  39. }  

 

公共类: 

Java代码  收藏代码
  1. package Mina.Object;  
  2.   
  3. public class UserInfo implements java.io.Serializable{  
  4.     private String name;  
  5.     private String QQNum;  
  6.     public String getName() {  
  7.         return name;  
  8.     }  
  9.     public void setName(String name) {  
  10.         this.name = name;  
  11.     }  
  12.     public String getQQNum() {  
  13.         return QQNum;  
  14.     }  
  15.     public void setQQNum(String qQNum) {  
  16.         QQNum = qQNum;  
  17.     }  
  18.       
  19.       
  20. }  

 如下建包即可:


以上就是对象的收发的简单示例,如果报错,或许会是一下原因:1、包的引进是否妥当 2、是否引入了mina的第三方包(网上有了很多的相关文章,在此就不在赘述了)

 

通过程序您会看到对象已经成功传递并进行了相关属性的输出,对于这个简单的程序我稍做些相关说明:

      1、进行传递的对象所实例化的类要实现java.io.Serializable序列化接口

      2、您会发现实例中的类尤其是相关的IoHandlerAdapter继承类都采用了单实例模式,为什么这样做呢,原因很简单,那就是要在整个通信过程中做到对象session的等实例的单一防止发生“所托非人”的现象

      3、服务器接收到message在进行类判断时用了instanceof关键字

 

如果你看到上面的实例就觉得对象传递的学习已经成功了,那就错了,细心的博友看到这个包结构:



 

 

是不是有点问题呢。

      例如客户端传了一个userinfo对象到服务器,在服务器端判断如果是userinfo对象后就打印出相关信息,我看源码文档其中有这样的建包方式


 
其中服务器和客户端共用了中间的Mina.Object包,这样在收到对象后就能通过instanceof关键字判断是不是useinfo对象,我看了一下,这个方法是可行的,现在的问题是,我们如果编写通讯软件的时候,肯定是服务器和客户端是要分开的,所以那个Mina.Object包是不能共享的,所以问题来了(1)、如果将userinfo放到客户端中,那么该怎么用instanceof进行判断是不是userinfo呢(这时你已经不能再引入服务器中的userinfo了)(2)、如果在客户端和服务器中都编写一个类定义一样的userinfo,可是他们这两个类是分属不同的包,所以是两个不同的类了,这样在用instanceof进行判断的时候也是行不通的;那么我们该用什么方法来进行判断接收到的类是不是userinfo对象呢?
         这个问题把我纠结了很久,在网上面搜了好久也没有解决,最后想了想那个(2)或许可以改动改动就可以解决,问题的关键在于两个UserInfo分属于两个不同的包,如果可以将包名一致就好了,但是在一个工程里面不能同时建立两个命名一样的包,这样你就会发现何不建立两个工程呢一个是服务器,一个是客户端,这样都可以分别建立名字都是Object的包,这样可不可行呢,经过试验果然可以,这样就就解决了上面的问题工程图如下


 
好啦,有了这个工具,您会有什么想法呢?对象传递还可以做什么?那就是可以用它来进行图片,文件的传递啦,这个只是个小小的提示具体怎么实现,就要看各位博友怎么发挥啦!呵呵
分享到:
评论

相关推荐

    Java springboot 整合mina 框架,nio通讯基础教程,mina框架基础教程.zip

    Java SpringBoot 整合Mina框架,涉及到的核心技术主要包括Java NIO(非阻塞I/O)、Mina框架以及SpringBoot的集成应用。本教程旨在帮助开发者深入理解和掌握这些技术,并提供了一个可直接使用的基础平台框架。 Java ...

    mina框架资源包

    《mina框架资源包详解——构建即时通讯服务器的关键组件》 Mina框架,全称为Apache Mina,是一款基于Java开发的网络通信应用框架,它提供了一种简单而高性能的方式来构建网络服务,尤其在处理TCP/IP、UDP/IP以及SSL...

    Mina框架+常用JAR包

    Mina框架是一个高性能、异步事件驱动的网络应用程序框架,主要用Java语言编写,用于简化开发TCP、UDP和SSL/TLS协议服务器和客户端的过程。它广泛应用于构建网络服务,如FTP、SMTP、NNTP等协议的服务器,以及任何基于...

    MiNA框架新人指导

    - **创建IoAcceptor对象**:这是MiNA框架中的核心组件之一,用于接收客户端的连接请求。 - **配置过滤器链**:定义一系列过滤器来处理数据流,例如编解码操作等。 - **绑定端口**:将IoAcceptor对象绑定到特定的端口...

    apache mina 框架实例

    Apache Mina是一个高性能、异步事件驱动的网络应用程序框架,主要用在开发网络通信应用,如TCP/IP和UDP/IP协议的服务器和客户端。这个框架允许开发者以一种简单、高效的方式处理I/O操作,同时提供了丰富的功能,如多...

    java mina框架全套

    Java Mina框架是一款高度可扩展且高性能的网络应用开发框架,专为开发网络服务和协议处理应用程序而设计。它提供了一种简洁、高效的API,使得开发者可以轻松地创建基于TCP/IP和UDP/IP协议的服务器和客户端应用。Mina...

    Mina框架入门介绍

    Apache Mina 框架是一个强大的网络通信框架,它的核心目标是简化开发高效且可扩展的网络应用程序。Mina 提供了基于事件驱动和异步IO的编程模型,特别是利用了Java NIO作为其默认的底层支持,这使得开发者能够构建高...

    mina 框架学习文档

    apache mina 框架的学习文档,通过此文档可以基本了解mina框架。

    Mina框架使用demo

    Mina框架是一个强大的网络应用开发框架,主要用于构建高性能、高可用性的网络服务器。在Java世界里,Mina因其异步事件驱动模型而受到广泛的青睐,它简化了TCP/IP和UDP协议编程,使得开发者可以专注于业务逻辑,而...

    mina框架开发完整架包下载!

    Mina框架是一个高性能、事件驱动的网络应用框架,主要用于简化Java网络编程,特别是TCP和UDP协议的处理。它被广泛应用于开发服务器端应用,如FTP、SMTP、HTTP等协议的服务,以及任何基于TCP或UDP协议的应用。Mina的...

    mina框架的demo 入门,开发

    Mina框架是一个基于Java的网络通信应用框架,它为高性能、高可用性的网络应用程序提供了强大的支持。本教程将深入探讨Mina框架的入门与开发,帮助你快速掌握这个框架的关键概念和技术。 首先,理解Mina的核心概念至...

    Apache MINA框架相关资料

    Apache MINA(Multipurpose Infrastructure for Network Applications)是一个高性能、异步事件驱动的网络应用程序框架,主要用于简化开发高质量的网络服务。这个框架适用于多种协议,如TCP/IP和UDP/IP,以及NIO(非...

    MINA长连接框架实现通讯

    MINA(Java Mini Asynchronous Network Application Framework)是一个高性能、异步事件驱动的网络应用程序框架,主要用于简化开发服务器和客户端的网络应用,特别是TCP和UDP协议的应用。MINA为开发者提供了高度抽象...

    高性能网络架构Mina框架 下载

    ### 高性能网络架构Mina框架简介 #### 一、Mina框架概述 Mina(Multithreaded Internet Network Application)框架是由Apache软件基金会提供的一个高性能、可伸缩的网络编程框架,它主要应用于Java NIO环境下的...

    mina框架使用总结.doc

    mina 框架使用总结 mina 框架是对 Java 的 NIO 包的一个封装,简化了 NIO 程序开发的难度,封装了很多底层的细节,使开发者把精力集中到业务逻辑上来。下面是对 mina 框架使用的总结。 1. MINA 框架概述 MINA ...

    Apache mina框架入门教程

    Apache Mina 框架是一个强大的网络通信应用框架,它主要针对基于TCP/IP和UDP/IP的协议栈,同时也支持Java对象序列化和其他通信方式。Mina 的核心设计目标是帮助开发者快速构建高性能、高可扩展性的网络应用。它采用...

    Mina 框架研究与实现

    ### Mina框架研究与实现 #### 引言 在当今高度网络化的世界中,服务器端程序面临着前所未有的挑战,特别是当需要同时处理成百上千的客户端连接时。这不仅要求服务器具备高性能,还必须保证高可用性。Mina框架正是...

    mina框架的jar包

    《Mina框架与SLF4J日志库的深度解析》 Mina框架是一个高度可扩展的网络通信应用框架,广泛应用于开发高性能、高效率的服务端应用,如TCP/IP、UDP以及HTTP等协议的服务器。它提供了一种事件驱动、异步处理的编程模型...

    mina框架使用总结

    MINA (Multipurpose Infrastructure for Network Applications) 是一个基于 Java 的网络应用框架,主要利用了 Java NIO (Non-blocking I/O) 技术。NIO 相比于传统的 BIo (Blocking I/O),提供了更高效的数据传输能力...

Global site tag (gtag.js) - Google Analytics