springboot 深度整合mina开箱即用

springboot 深度整合mina开箱即用,适合新手上来研究。希望下载过的同学能来评论。

package com.mm.mina;

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;


/**
 * Created by Administrator on 2018/11/1.
 */
@Component
public class BossMinaHandle  extends IoHandlerAdapter {
    private final Logger logger = LoggerFactory.getLogger（getClass（））;

    @Override
    public void messageReceived（IoSession session object message）
            throws Exception {
        //super.messageReceived（session message）;

        String  rtuStr= （String）message;
        System.out.println（rtuStr）;
        byte[] bt = getCMDBytes（“AA“）;
        session.write（IoBuffer.wrap（bt））;
        logger.info（“message :“ + message）;
    }
    private static byte[] getCMDBytes（String cmd） {
        String[] cmds = cmd.split（“ “）;
        byte[] bytes = new byte[cmds.length];
        int i=0;
        try {
            for （String b : cmds） {
                if （b.equals（“FF“）） {
                    bytes[i++] = -1;
                } else {
                    bytes[i++] = （byte） Integer.parseInt（b 16）;
                    //= Byte.parseByte（b 16）;
                }
            }
        }catch（Exception e）{
            e.printStackTrace（）;
        }
        return bytes;
    }
    public String convertStringToHex（String str）{

        char[] chars = str.toCharArray（）;

        StringBuffer hex = new StringBuffer（）;
        for（int i = 0; i < chars.length; i++）{
            hex.append（Integer.toHexString（（int）chars[i]））;
        }

        return hex.toString（）;
    }

    public static String convertHexToString（String hexs）{

        StringBuilder sb = new StringBuilder（）;
        StringBuilder temp = new StringBuilder（）;
        String [] hexArr =hexs.split（“ “）;
        for（String hex:hexArr）{
            int decimal = Integer.parseInt（hexs 16）;
            sb.append（（char）decimal）;
            temp.append（decimal）;
        }
        return sb.toString（）;
    }
    @Override
    public void sessionClosed（IoSession session） throws Exception {
        super.sessionClosed（session）;
    }

    @Override
    public void sessionIdle（IoSession session IdleStatus status）
            throws Exception {
        super.sessionIdle（session status）;
    }

    @Override
    public void messageSent（IoSession session object message） throws Exception {
        logger.info（“发送的消息是：“ + message.toString（））;
    }

    @Override
    public void sessionCreated（IoSession session） throws Exception {
        logger.info（“session is create“+session.getId（））;
        super.sessionCreated（session）;
    }

    @Override
    public void sessionOpened（IoSession session） throws Exception {
        logger.info（“session is opened“+session.getId（））

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件           0  2019-04-22 16:25  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?
     文件        6148  2019-04-22 16:24  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?.DS_Store
     目录           0  2019-04-22 16:25  __MACOSX\
     文件           0  2019-04-22 16:25  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?
     文件         120  2019-04-22 16:24  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._.DS_Store
     文件         742  2018-11-06 09:10  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?pom.txt
     文件         212  2018-11-06 09:10  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._pom.txt
     文件          14  2018-11-06 09:10  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?application.txt
     文件         268  2018-11-06 09:10  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._application.txt
     文件        2113  2018-11-01 13:22  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?SessionMap.java
     文件         212  2018-11-01 13:22  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._SessionMap.java
     文件         371  2019-04-22 16:25  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?REMDEME.rtf
     文件         266  2019-04-22 16:25  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._REMDEME.rtf
     目录           0  2018-11-06 09:07  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\
     文件        1301  2018-11-01 15:10  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\MyProtocolEncoder.java
     目录           0  2019-04-22 16:25  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\
     文件         212  2018-11-01 15:10  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\._MyProtocolEncoder.java
     文件        1119  2018-11-01 15:01  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\MyProtocolCodecFactory.java
     文件         212  2018-11-01 15:01  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\._MyProtocolCodecFactory.java
     文件        3757  2018-11-01 15:34  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\MyProtocolDecoder.java
     文件         212  2018-11-01 15:34  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?codes\._MyProtocolDecoder.java
     文件         212  2018-11-06 09:07  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._codes
     文件        1397  2018-11-01 15:05  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?MyKeepAliveMessageFactory.java
     文件         212  2018-11-01 15:05  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._MyKeepAliveMessageFactory.java
     文件        3066  2018-11-06 09:07  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?BossMinaHandle.java
     文件         212  2018-11-06 09:07  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._BossMinaHandle.java
     文件        2666  2018-11-01 15:02  springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?MinaSocketConfig.java
     文件         212  2018-11-01 15:02  __MACOSX\springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?._MinaSocketConfig.java
     文件         212  2019-04-22 16:25  __MACOSX\._springboot 娣卞害鏁村悎mina寮€绠卞嵆鐢?