淺談Java的Mina框架傳遞對(duì)象
接觸java的Mina框架已經(jīng)有很多時(shí)間了，在網(wǎng)上也讀過(guò)了很多的相關(guān)文章，發(fā)現(xiàn)Mina框架的確是一個(gè)值得拿來(lái)好好研究的東西，前些日子寫(xiě)了一個(gè)山寨QQ項(xiàng)目，其中的通信部分用到了java中自帶的InputStream，OutputStream，Writer，Reader等等，感覺(jué)其中的很大的一個(gè)問(wèn)題就是難以將事務(wù)處理的邏輯層與解析層分離開(kāi)來(lái)，造成整個(gè)項(xiàng)目看起來(lái)比較臃腫，繁瑣，不夠模塊化，接觸Mina后發(fā)現(xiàn)mina在這方面做的很是恰到好處。
看到文章標(biāo)題，你或許會(huì)有一些疑惑：
1、Mina框架傳遞對(duì)象是怎么回事
2、Mina傳遞對(duì)象可以用來(lái)做什么
3、Mina傳遞對(duì)象是怎么進(jìn)行的
4、Mina傳遞對(duì)象過(guò)程中會(huì)遇到什么問(wèn)題呢
在用原來(lái)的java的InputStream，OutputStream，Writer，Reader等進(jìn)行通信的時(shí)候我們會(huì)將信息編碼轉(zhuǎn)化成字節(jié)流等進(jìn)行信息傳遞，InputStream，OutputStream是基于字節(jié)流的，而Writer，Reader是基于字符的，我們都知道進(jìn)行通信的服務(wù)器和客戶(hù)端是事先必須定好通信協(xié)議，如果我們將
這是我們會(huì)自然的想到要用一種東西將各個(gè)格式的信息進(jìn)行分類(lèi)統(tǒng)一起來(lái)并方便進(jìn)行一些必要的信息處理，為符合這些特點(diǎn)，我們會(huì)想到類(lèi)這個(gè)東東恰恰滿(mǎn)足了這些性質(zhì)，我們可以將信息的格式中的內(nèi)容定義為類(lèi)的屬性，而對(duì)這些屬性的處理就可以用類(lèi)中的方法來(lái)予以解決，這樣就對(duì)信息進(jìn)行了很好的包裝。
這種思想有了，那就是在通信的時(shí)候直接進(jìn)行形式上的對(duì)象傳遞(實(shí)際上在通信的時(shí)候都是最終以字節(jié)流的方式進(jìn)行傳遞的)，那么我們就要找一種工具進(jìn)行這種形式的信息傳遞，對(duì)了，這種工具就是Mina框架，我們只看他其中的一個(gè)方法
public void messageReceived(IoSession session, Object message)，這是進(jìn)行消息接收是能夠被 觸發(fā)的一個(gè)方法，參數(shù)session代表當(dāng)前的會(huì)話(huà)對(duì)象，參數(shù)message代表接收的到的信息，這時(shí)您會(huì)發(fā)現(xiàn)message的類(lèi)型是Object型，而類(lèi) Object 是類(lèi)層次結(jié)構(gòu)的根類(lèi)，當(dāng)然可以用對(duì)象型的作為message啦!前面提到通信的時(shí)候都是最終以字節(jié)流的方式進(jìn)行傳遞的，這樣就要進(jìn)行：對(duì)象(客戶(hù)端)->字節(jié)流(客戶(hù)端)->發(fā)送->接收->字節(jié)流(服務(wù)器)->對(duì)象(服務(wù)器)的過(guò)程，呵呵不用擔(dān)心，這些繁瑣的過(guò)程，Mina都提供了很好的底層默認(rèn)實(shí)現(xiàn)所以你只需稍稍敲點(diǎn)代碼就行了。
光說(shuō)不練還是不行，先上一個(gè)程序?qū)嵗?/P>
服務(wù)器端(1)：
Java代碼
- package Mina.server;
- import java.io.IOException;
- import java.net.InetSocketAddress;
- import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
- import org.apache.mina.filter.codec.ProtocolCodecFilter;
- import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
- import org.apache.mina.transport.socket.SocketAcceptor;
- import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
- public class MainServer {
- private static MainServer mainServer = null;
- private SocketAcceptor acceptor = new NioSocketAcceptor();
- private DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
- private int bindPort = 8888;
- public static MainServer getInstances() {
- if (null == mainServer) {
- mainServer = new MainServer();
- }
- return mainServer;
- }
- private MainServer() {
- chain.addLast("myChin", new ProtocolCodecFilter(
- new ObjectSerializationCodecFactory()));
- acceptor.setHandler(ServerHandler.getInstances());
- try {
- acceptor.bind(new InetSocketAddress(bindPort));
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- public static void main(String[] args) throws Exception {
- MainServer.getInstances();
- }
- }
服務(wù)器端(2)：
Java代碼
- package Mina.server;
- import org.apache.mina.core.filterchain.IoFilterAdapter;
- import org.apache.mina.core.service.IoHandler;
- import org.apache.mina.core.session.IdleStatus;
- import org.apache.mina.core.session.IoSession;
- import Mina.Object.UserInfo;
- public class ServerHandler extends IoFilterAdapter implements IoHandler {
- private static ServerHandler samplMinaServerHandler = null;
- public static ServerHandler getInstances() {
- if (null == samplMinaServerHandler) {
- samplMinaServerHandler = new ServerHandler();
- }
- return samplMinaServerHandler;
- }
- private ServerHandler() {
- }
- // 當(dāng)連接后打開(kāi)時(shí)觸發(fā)此方法，一般此方法與 sessionCreated 會(huì)被同時(shí)觸發(fā)
- public void sessionOpened(IoSession session) throws Exception {
- }
- public void sessionClosed(IoSession session) {
- }
- public void messageReceived(IoSession session, Object message)
- throws Exception {
- if (message instanceof UserInfo) {
- UserInfo text = (UserInfo) message;
- System.out.println("服務(wù)器接收到從客戶(hù)端的姓名："+text.getName());
- System.out.println("服務(wù)器接收到從客戶(hù)端的QQ："+text.getQQNum());
- }
- }
- public void exceptionCaught(IoSession arg0, Throwable arg1)
- throws Exception {
- }
- // 當(dāng)消息傳送到客戶(hù)端后觸發(fā)
- public void messageSent(IoSession arg0, Object arg1) throws Exception {
- }
- // 當(dāng)一個(gè)新客戶(hù)端連接后觸發(fā)此方法.
- public void sessionCreated(IoSession arg0) throws Exception {
- }
- // 當(dāng)連接空閑時(shí)觸發(fā)此方法.
- public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception {
- }
- }
客戶(hù)端(1)：
Java代碼
- package Mina.client;
- import java.net.InetSocketAddress;
- import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
- import org.apache.mina.core.future.ConnectFuture;
- import org.apache.mina.filter.codec.ProtocolCodecFilter;
- import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
- import org.apache.mina.transport.socket.nio.NioSocketConnector;
- public class MainClient {
- private static MainClient mainClient = null;
- NioSocketConnector connector = new NioSocketConnector();
- DefaultIoFilterChainBuilder chain = connector.getFilterChain();
- public static MainClient getInstances() {
- if (null == mainClient) {
- mainClient = new MainClient();
- }
- return mainClient;
- }
- private MainClient() {
- chain.addLast("myChin", new ProtocolCodecFilter(
- new ObjectSerializationCodecFactory()));
- connector.setHandler(ClientHandler.getInstances());
- connector.setConnectTimeout(30);
- ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",
- 8888));
- }
- public static void main(String args[]) {
- MainClient.getInstances();
- }
- }
客戶(hù)端(2)：
Java代碼
- package Mina.client;
- import org.apache.mina.core.service.IoHandlerAdapter;
- import org.apache.mina.core.session.IoSession;
- import Mina.Object.UserInfo;
- public class ClientHandler extends IoHandlerAdapter {
- private static ClientHandler samplMinaClientHandler = null;
- public static ClientHandler getInstances() {
- if (null == samplMinaClientHandler) {
- samplMinaClientHandler = new ClientHandler();
- }
- return samplMinaClientHandler;
- }
- private ClientHandler() {
- }
- public void sessionOpened(IoSession session) throws Exception {
- session.write("客戶(hù)端與服務(wù)器的會(huì)話(huà)打開(kāi)了……");
- UserInfo text=new UserInfo();
- text.setName("梅竹寒香");
- text.setQQNum("972341215");
- session.write(text);
- }
- public void sessionClosed(IoSession session) {
- }
- public void messageReceived(IoSession session, Object message)
- throws Exception {
- }
- public void messageSent(IoSession arg0, Object arg1) throws Exception {
- System.out.println("客戶(hù)端已經(jīng)向服務(wù)器發(fā)送了："+(String)arg1);
- }
- }
公共類(lèi)：
Java代碼
- package Mina.Object;
- public class UserInfo implements java.io.Serializable{
- private String name;
- private String QQNum;
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- public String getQQNum() {
- return QQNum;
- }
- public void setQQNum(String qQNum) {
- QQNum = qQNum;
- }
- }
如下建包即可：
以上就是對(duì)象的收發(fā)的簡(jiǎn)單示例，如果報(bào)錯(cuò)，或許會(huì)是一下原因：1、包的引進(jìn)是否妥當(dāng) 2、是否引入了mina的第三方包(網(wǎng)上有了很多的相關(guān)文章，在此就不在贅述了)
通過(guò)程序您會(huì)看到對(duì)象已經(jīng)成功傳遞并進(jìn)行了相關(guān)屬性的輸出，對(duì)于這個(gè)簡(jiǎn)單的程序我稍做些相關(guān)說(shuō)明：
1、進(jìn)行傳遞的對(duì)象所實(shí)例化的類(lèi)要實(shí)現(xiàn)java.io.Serializable序列化接口
2、您會(huì)發(fā)現(xiàn)實(shí)例中的類(lèi)尤其是相關(guān)的IoHandlerAdapter繼承類(lèi)都采用了單實(shí)例模式，為什么這樣做呢，原因很簡(jiǎn)單，那就是要在整個(gè)通信過(guò)程中做到對(duì)象session的等實(shí)例的單一防止發(fā)生“所托非人”的現(xiàn)象
3、服務(wù)器接收到message在進(jìn)行類(lèi)判斷時(shí)用了instanceof關(guān)鍵字
如果你看到上面的實(shí)例就覺(jué)得對(duì)象傳遞的學(xué)習(xí)已經(jīng)成功了，那就錯(cuò)了，細(xì)心的博友看到這個(gè)包結(jié)構(gòu)：
是不是有點(diǎn)問(wèn)題呢。
例如客戶(hù)端傳了一個(gè)userinfo對(duì)象到服務(wù)器，在服務(wù)器端判斷如果是userinfo對(duì)象后就打印出相關(guān)信息，我看源碼文檔其中有這樣的建包方式
其中服務(wù)器和客戶(hù)端共用了中間的Mina.Object包，這樣在收到對(duì)象后就能通過(guò)instanceof關(guān)鍵字判斷是不是useinfo對(duì)象，我看了一下，這個(gè)方法是可行的，現(xiàn)在的問(wèn)題是，我們?nèi)绻帉?xiě)通訊軟件的時(shí)候，肯定是服務(wù)器和客戶(hù)端是要分開(kāi)的，所以那個(gè)Mina.Object包是不能共享的，所以問(wèn)題來(lái)了(1)、如果將userinfo放到客戶(hù)端中，那么該怎么用instanceof進(jìn)行判斷是不是userinfo呢(這時(shí)你已經(jīng)不能再引入服務(wù)器中的userinfo了)(2)、如果在客戶(hù)端和服務(wù)器中都編寫(xiě)一個(gè)類(lèi)定義一樣的userinfo，可是他們這兩個(gè)類(lèi)是分屬不同的包，所以是兩個(gè)不同的類(lèi)了，這樣在用instanceof進(jìn)行判斷的時(shí)候也是行不通的;那么我們?cè)撚檬裁捶椒▉?lái)進(jìn)行判斷接收到的類(lèi)是不是userinfo對(duì)象呢?
這個(gè)問(wèn)題把我糾結(jié)了很久，在網(wǎng)上面搜了好久也沒(méi)有解決，最后想了想那個(gè)(2)或許可以改動(dòng)改動(dòng)就可以解決，問(wèn)題的關(guān)鍵在于兩個(gè)UserInfo分屬于兩個(gè)不同的包，如果可以將包名一致就好了，但是在一個(gè)工程里面不能同時(shí)建立兩個(gè)命名一樣的包，這樣你就會(huì)發(fā)現(xiàn)何不建立兩個(gè)工程呢一個(gè)是服務(wù)器，一個(gè)是客戶(hù)端，這樣都可以分別建立名字都是Object的包，這樣可不可行呢，經(jīng)過(guò)試驗(yàn)果然可以，這樣就就解決了上面的問(wèn)題工程圖如下
好啦，有了這個(gè)工具，您會(huì)有什么想法呢?對(duì)象傳遞還可以做什么?那就是可以用它來(lái)進(jìn)行圖片，文件的傳遞啦，這個(gè)只是個(gè)小小的提示具體怎么實(shí)現(xiàn)，就要看各位博友怎么發(fā)揮啦!呵呵
【編輯推薦】
