socket框架netty-socket android客戶端方式，內(nèi)含心跳重連等

之前自己寫了socket建立的連接，但是涉及到一些需要完善的地方，表示自己有點(diǎn)懶。然后就在網(wǎng)上找了一個(gè)socket框架， 拿來(lái)直接用。


hh 你好懶

閱讀測(cè)試后，個(gè)人認(rèn)為NettyClient 主要分為幾個(gè)部分：
1，異步端口連接 Bootstrap
2，NettyClient的解碼方式等 pipeline
3，配套的HandlerAdapter ： ChannelInboundHandlerAdapter等。
4，計(jì)算斷開(kāi)后重新調(diào)用連接。

提供一下jar包下載，不知道怎么設(shè)置免費(fèi)下載，沒(méi)分的可以網(wǎng)上自行找資源，資源一堆的說(shuō)！ 我就直接上代碼了，上的代碼都是簡(jiǎn)單的封裝了一下的。使用的時(shí)候直接調(diào)用指定的方法就可以。 （這字一放大，變色的字就沒(méi)了，真是不知道怎么用?。?/code>

  • 我先把定義的接口寫了，下面的代碼里面有用到。
public interface NettyListener {

    public final static byte STATUS_CONNECT_SUCCESS = 1;//連接成功

    public final static byte STATUS_CONNECT_CLOSED = 0;//關(guān)閉連接

    public final static byte STATUS_CONNECT_ERROR = 0;//連接失敗


    /**
     * 當(dāng)接收到系統(tǒng)消息
     */
    void onMessageResponse(Object msg);

    /**
     * 當(dāng)連接狀態(tài)發(fā)生變化時(shí)調(diào)用 
     */
    public void onServiceStatusConnectChanged(int statusCode);
}
  • NettyClient 類的書寫
public class NettyClient {

    private static final String TAG = "NettyClient";

    private EventLoopGroup group;//Bootstrap參數(shù)

    private NettyListener listener;//寫的接口用來(lái)接收服務(wù)端返回的值

    private Channel channel;//通過(guò)對(duì)象發(fā)送數(shù)據(jù)到服務(wù)端

    private boolean isConnect = false;//判斷是否連接了

    private static int reconnectNum = Integer.MAX_VALUE;//定義的重連到時(shí)候用
    private boolean isNeedReconnect = true;//是否需要重連
    private boolean isConnecting = false;//是否正在連接
    private long reconnectIntervalTime = 5000;//重連的時(shí)間

    public String host;//ip
    public int tcp_port;//端口

    /*
    構(gòu)造 傳入 ip和端口
     */
    public NettyClient(String host, int tcp_port) {
        this.host = host;
        this.tcp_port = tcp_port;
    }

    /*
    連接方法
     */
    public void connect() {

        if (isConnecting) {
            return;
        }
        //起個(gè)線程
        Thread clientThread = new Thread("client-Netty") {
            @Override
            public void run() {
                super.run();
                isNeedReconnect = true;
                reconnectNum = Integer.MAX_VALUE;
                connectServer();
            }
        };
        clientThread.start();
    }

    //連接時(shí)的具體參數(shù)設(shè)置
    private void connectServer() {
        synchronized (NettyClient.this) {
            ChannelFuture channelFuture = null;//連接管理對(duì)象
            if (!isConnect) {
                isConnecting = true;
                group = new NioEventLoopGroup();//設(shè)置的連接group
                Bootstrap bootstrap = new Bootstrap().group(group)//設(shè)置的一系列連接參數(shù)操作等
                        .option(ChannelOption.TCP_NODELAY, true)//屏蔽Nagle算法試圖
                        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
                        .channel(NioSocketChannel.class)
                        .handler(new ChannelInitializer<SocketChannel>() { // 5
                            @Override
                            public void initChannel(SocketChannel ch) throws Exception {
//                                ch.pipeline().addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));//服務(wù)端最后以"\n"作為結(jié)束標(biāo)識(shí)
//                                ch.pipeline().addLast(new StringEncoder(CharsetUtil.UTF_8));//解碼
//                                ch.pipeline().addLast(new StringDecoder(CharsetUtil.UTF_8));//解碼
                                ch.pipeline().addLast(new NettyClientHandler(listener));//需要的handlerAdapter
                            }
                        });

                try {
                    //連接監(jiān)聽(tīng)
                    channelFuture = bootstrap.connect(host, tcp_port).addListener(new ChannelFutureListener() {
                        @Override
                        public void operationComplete(ChannelFuture channelFuture) throws Exception {
                            if (channelFuture.isSuccess()) {
                                Log.e(TAG, "連接成功");
                                isConnect = true;
                                channel = channelFuture.channel();
                            } else {
                                Log.e(TAG, "連接失敗");
                                isConnect = false;
                            }
                            isConnecting = false;
                        }
                    }).sync();

                    // 等待連接關(guān)閉
                    channelFuture.channel().closeFuture().sync();
                    Log.e(TAG, " 斷開(kāi)連接");
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    isConnect = false;
                    listener.onServiceStatusConnectChanged(NettyListener.STATUS_CONNECT_CLOSED);//STATUS_CONNECT_CLOSED 這我自己定義的 接口標(biāo)識(shí)
                    if (null != channelFuture) {
                        if (channelFuture.channel() != null && channelFuture.channel().isOpen()) {
                            channelFuture.channel().close();
                        }
                    }
                    group.shutdownGracefully();
                    reconnect();//重新連接
                }
            }
        }
    }

    //斷開(kāi)連接
    public void disconnect() {
        Log.e(TAG, "disconnect");
        isNeedReconnect = false;
        group.shutdownGracefully();
    }

    //重新連接
    public void reconnect() {
        Log.e(TAG, "reconnect");
        if (isNeedReconnect && reconnectNum > 0 && !isConnect) {
            reconnectNum--;
            SystemClock.sleep(reconnectIntervalTime);
            if (isNeedReconnect && reconnectNum > 0 && !isConnect) {
                Log.e(TAG, "重新連接");
                connectServer();
            }
        }
    }

    //發(fā)送消息到服務(wù)端。 Bootstrap設(shè)置的時(shí)候我沒(méi)有設(shè)置解碼，這邊才轉(zhuǎn)的
    public boolean sendMsgToServer(String data, ChannelFutureListener listener) {
        boolean flag = channel != null && isConnect;
        if (flag) {
            ByteBuf byteBuf = Unpooled.copiedBuffer(data + System.getProperty("line.separator"), //2
                    CharsetUtil.UTF_8);
            channel.writeAndFlush(byteBuf).addListener(listener);
        }
        return flag;
    }

    //重連時(shí)間
    public void setReconnectNum(int reconnectNum) {
        this.reconnectNum = reconnectNum;
    }

    public void setReconnectIntervalTime(long reconnectIntervalTime) {
        this.reconnectIntervalTime = reconnectIntervalTime;
    }
    //現(xiàn)在連接的狀態(tài)
    public boolean getConnectStatus() {
        return isConnect;
    }

    public boolean isConnecting() {
        return isConnecting;
    }

    public void setConnectStatus(boolean status) {
        this.isConnect = status;
    }

    public void setListener(NettyListener listener) {
        this.listener = listener;
    }

}
累成狗！.png

好累，感覺(jué)我要睡著了。
我要原諒我太菜，沒(méi)有時(shí)間休息，公司開(kāi)展的新項(xiàng)目的技術(shù)點(diǎn)不會(huì)，哈哈，沒(méi)辦法。。。太菜，抓把勁攻克！

  • netty socket 配套的handlerAdapter,直接上代碼直接上
public class NettyClientHandler extends ChannelInboundHandlerAdapter {

    private static final String TAG = "NettyClientHandler";
    private NettyListener listener;

    public NettyClientHandler(NettyListener listener) {
        this.listener = listener;
    }

    //每次給服務(wù)器發(fā)送的東西， 讓服務(wù)器知道我們?cè)谶B接中哎
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent event = (IdleStateEvent) evt;
            if (event.state() == IdleState.WRITER_IDLE) {
                ctx.channel().writeAndFlush("Heartbeat" + System.getProperty("line.separator"));
            }
        }
    }

    /**
     * 連接成功
     */
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        Log.e(TAG, "channelActive");
        super.channelActive(ctx);
        listener.onServiceStatusConnectChanged(NettyListener.STATUS_CONNECT_SUCCESS);
    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        super.channelInactive(ctx);
        Log.e(TAG, "channelInactive");
    }

    //接收消息的地方， 接口調(diào)用返回到activity了
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("客戶端開(kāi)始讀取服務(wù)端過(guò)來(lái)的信息");
        listener.onMessageResponse(msg);
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // 當(dāng)引發(fā)異常時(shí)關(guān)閉連接。
        Log.e(TAG, "exceptionCaught");
        listener.onServiceStatusConnectChanged(NettyListener.STATUS_CONNECT_ERROR);
        cause.printStackTrace();
        ctx.close();
    }

}

我覺(jué)得我注釋寫的還挺多的，哈哈，
對(duì)了，還有個(gè)定義的host和port類。雖然就幾行，但我還是決定寫上

public class Const { //百度找的markdown語(yǔ)法框框，表示有點(diǎn)丑
public static final String HOST = "192.168.0.46";
public static final int TCP_PORT = 5212;
public static final int LIVE_PORT = 5500;
}

              • 最重要的來(lái)襲了， 使用！

布局沒(méi)什么東西， 就是個(gè)Button發(fā)送消息的，連接我寫成進(jìn)入app后默認(rèn)連接了，失敗和成功會(huì)有提示的昂， 失敗了會(huì)一直重連。

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical">

    <Button
        android:id="@+id/btn_send"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="發(fā)送消息" />
</LinearLayout>

其他核心的使用代碼：?。。?！

public class MainActivity extends BaseActivitiy implements NettyListener {

    private Button btn_send;//發(fā)送
    private NettyClient nettyClient;//socket操作連接對(duì)象
    private final String TAG = "MainActivity.class";

    @Override
    protected int getContentView() {//這我自己的基類抽象的
        return R.layout.activity_main;
    }

    @Override
    protected void initView() {//這我自己的基類抽象的
        initSocketTcp();//默認(rèn)自動(dòng)連接socket

        btn_send = findViewById(R.id.btn_send);//發(fā)送
        btn_send.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if (!nettyClient.getConnectStatus()) {//獲取連接狀態(tài)，必須連接才能點(diǎn)。
                    Toast.makeText(MainActivity.this, "先連接", Toast.LENGTH_SHORT).show();
                } else {
                    JSONObject jsonObject = new JSONObject();//傳個(gè)jsonobject給服務(wù)器
                    long l = System.currentTimeMillis();
                    try {
                        jsonObject.put("msgType", "infomation");
                        jsonObject.put("msgValue", "status");
                        jsonObject.put("msgTime", l + "");

                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                    /*
                    調(diào)用的發(fā)送。
                     */
                    nettyClient.sendMsgToServer(jsonObject.toString(), new ChannelFutureListener() {
                        @Override
                        public void operationComplete(ChannelFuture channelFuture) throws Exception {
                            if (channelFuture.isSuccess()) {                //4
                                Log.d(TAG, "Write auth successful");
                            } else {
                                Log.d(TAG, "Write auth error");
                            }
                        }
                    });
                }
            }
        });
    }

    /*
     socket 端口號(hào)以及開(kāi)始連接，配置接口監(jiān)聽(tīng)
     */
    private void initSocketTcp() {
        nettyClient = new NettyClient(Const.HOST, Const.TCP_PORT);
        if (!nettyClient.getConnectStatus()) {
            nettyClient.setListener(MainActivity.this);
            nettyClient.connect();
        } else {
            nettyClient.disconnect();
        }
    }


    /*
       回調(diào)客戶端接收的信息  解析 數(shù)據(jù)流， 轉(zhuǎn)換為string
       */
    @Override
    public void onMessageResponse(final Object msg) {
        ByteBuf result = (ByteBuf) msg;
        byte[] result1 = new byte[result.readableBytes()];
        result.readBytes(result1);
        result.release();
        final String ss = new String(result1);

        runOnUiThread(new Runnable() {
            @Override
            public void run() {

                Toast.makeText(MainActivity.this, "接收成功" + ss, Toast.LENGTH_SHORT).show();
            }
        });
    }

    //連接狀態(tài)變化的時(shí)候 會(huì)走這
    @Override
    public void onServiceStatusConnectChanged(final int statusCode) {
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                if (statusCode == NettyListener.STATUS_CONNECT_SUCCESS) {
                    Log.e(TAG, "STATUS_CONNECT_SUCCESS:");
                    if (nettyClient.getConnectStatus()) {
                        Toast.makeText(MainActivity.this, "連接成功", Toast.LENGTH_SHORT).show();
                    }
                } else {
                    Log.e(TAG, "onServiceStatusConnectChanged:" + statusCode);
                    if (!nettyClient.getConnectStatus()) {
                        Toast.makeText(MainActivity.this, "網(wǎng)路不好，正在重連", Toast.LENGTH_SHORT).show();
                    }
                }
            }
        });
    }
}

基本就這些了，我覺(jué)得我寫非常清楚， 按照步驟的話直接就可以實(shí)現(xiàn)，
如果想知道到底能不能使用，能不能行。
可以使用工具..等等，肯定是能用的，好嗎？？？！

哈哈，模擬服務(wù)端的話，可以下載個(gè) ，windows還是mac都有，網(wǎng)上找就有，我沒(méi)有提供鏈接。

sokit
sokit.png

好了好了，可算寫完了，技術(shù)太菜望見(jiàn)諒，我是一名又懶又菜的猿。

是我.png
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容