简单明了的android 长连接Socket

【实例简介】
【实例截图】
【核心代码】

服务端代码：

package com.shandiangou.sdgprotocol.lib.demo;

import com.shandiangou.sdgprotocol.lib.Config;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * Created by linwenbin on 16/11/28.
 */
public class Server {

    private int port = Config.PORT;
    private ServerSocket serverSocket;

    public Server() throws Exception {
        serverSocket = new ServerSocket(port, 3);//显式设置连接请求队列的长度为3
        System.out.println("服务器启动!");
    }

    public void service() {
        while (true) {
            Socket socket = null;
            try {
                socket = serverSocket.accept();
                System.out.println("New connection accepted "   socket.getInetAddress()   ":"   socket.getPort());
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (socket != null) {
                    try {
                        socket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

    public static void main(String[] args) throws Exception {
        Server server = new Server();
        Thread.sleep(10000);
        server.service();
    }
}

android端代码：

package com.shandiangou.sdgprotocol.demo;


import android.graphics.Color;
import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.support.v7.widget.DefaultItemAnimator;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.text.TextUtils;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ImageButton;
import android.widget.Toast;

import com.shandiangou.sdgprotocol.lib.ConnectionClient;
import com.shandiangou.sdgprotocol.lib.RequestCallBack;
import com.shandiangou.sdgprotocol.lib.protocol.BasicProtocol;
import com.shandiangou.sdgprotocol.lib.protocol.DataAckProtocol;
import com.shandiangou.sdgprotocol.lib.protocol.DataProtocol;
import com.shandiangou.sdgprotocol.lib.protocol.PingAckProtocol;

import java.util.ArrayList;
import java.util.List;

public class MainActivity extends AppCompatActivity implements RequestCallBack {

    private RecyclerView recyclerView;
    private ChatAdapter chatAdapter;
    private RecyclerView.LayoutManager layoutManager;
    private List<ChatContent> chatContentList = new ArrayList<>();

    private Button btn_connect;
    private Button btn_close;
    private ImageButton ib_send;
    private EditText et_messageData;

    private ConnectionClient tcpLongConnect;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        intiView();
    }

    private void intiView() {
        btn_connect = (Button) findViewById(R.id.connect_btn);
        btn_connect.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                tcpLongConnect = new ConnectionClient(MainActivity.this);
            }
        });

        btn_close = (Button) findViewById(R.id.close_btn);
        btn_close.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                tcpLongConnect.closeConnect();
            }
        });

        setConnStatus(false);

        ib_send = (ImageButton) findViewById(R.id.ib_send);
        ib_send.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                String msg = et_messageData.getText().toString().trim();
                chatAdapter.addMessage(new ChatContent(ChatContent.MYSELF, msg)); //往对话列表中添加一行

                if (tcpLongConnect == null) {
                    return;
                }

                int msgId = (int) (Math.random() * 2147483647);
                Log.e("linwb", "msgId: "   msgId);
                DataProtocol protocol = new DataProtocol();
                protocol.setPattion(0);   //业务类型为push
                protocol.setDtype(0);     //业务数据格式为json
                protocol.setMsgId(msgId);
                protocol.setData(msg);
                tcpLongConnect.addNewRequest(protocol); //往对话列表中添加一行

                recyclerView.scrollToPosition(chatAdapter.getAdapterSize() - 1);
                et_messageData.setText("");
            }
        });

        et_messageData = (EditText) findViewById(R.id.et_messageData);

        layoutManager = new LinearLayoutManager(this, LinearLayoutManager.VERTICAL, false);
        recyclerView = (RecyclerView) findViewById(R.id.rv_recycleviewAdapter);
        recyclerView.setLayoutManager(layoutManager);
        recyclerView.setItemAnimator(new DefaultItemAnimator());

        chatAdapter = new ChatAdapter(this, chatContentList);
        recyclerView.setAdapter(chatAdapter);

        setTitle("未连接");
    }

    private void setConnStatus(boolean connected) {
        btn_connect.setClickable(!connected);
        btn_close.setClickable(connected);
        if (connected) {
            btn_connect.setBackgroundColor(Color.LTGRAY);
            btn_close.setBackgroundColor(Color.YELLOW);
        } else {
            btn_connect.setBackgroundColor(Color.YELLOW);
            btn_close.setBackgroundColor(Color.LTGRAY);
        }
    }

    @Override
    public void onSuccess(BasicProtocol protocol) {
        if (protocol.getProtocolType() == 1) {
            String response = ((DataAckProtocol) protocol).getUnused();
            chatAdapter.addMessage(new ChatContent(ChatContent.GUEST, response));
            Log.e("linwb", "msgAck: "   response);
        } else if (protocol.getProtocolType() == 3) {
            String response = ((PingAckProtocol) protocol).getUnused();
            if (!TextUtils.equals("连接成功", getTitle())) {
                setTitle("连接成功");
                setConnStatus(true);
            }
            Log.e("linwb", "pingAck: "   response);
            Toast.makeText(this, response, Toast.LENGTH_LONG).show();
        }
        Log.e("linwb", "-------------------------------------------");
    }

    @Override
    public void onFailed(int errorCode, String msg) {
        setTitle(msg);
        setConnStatus(false);
    }
}