简单的TCP Server，接收数据并利用消息进行处理

/*
原文链接：https://blog.csdn.net/taoerit/article/details/79754404

用法:
    Handler serverHandle = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            TcpServerThread.SocketData data = (TcpServerThread.SocketData)msg.obj;
            try {
                data.outputStream.write(data.data.getBytes());
                if (data.data == "a")
                    powerControl(false);
                else if (data.data == "b")
                    powerControl(true);
            } catch (IOException e) {
                Log.e(TAG, "远程控制错误: " + e.getMessage());
            }
        }
    };

    TcpServerThread tcpServerTread = new TcpServerThread(serverHandle, 8888);
    tcpServerThread.start();
 */
package com.kingron.tcpserver;

import android.os.Bundle;
import android.os.Handler;
import android.os.Message;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

class TcpServerThread extends Thread {

    static String TAG = "TCP Server";

    class SocketData {
        Socket socket;
        InputStream inputStream;
        OutputStream outputStream;
        String data;
    }

    Handler handler = null;
    private int port;
    private byte buffer[] = new byte[1500];
    ServerSocket serverSocket;

    public TcpServerThread(Handler handler, int port) {
        this.port = port;
        this.handler = handler;
    }

    @Override
    public void run() {
        super.run();

        try {
            serverSocket = new ServerSocket(port);//监听8080端口，这个程序的通信端口就是8080了
        } catch (IOException e) {
            Log.e(TAG, "监听端口" + port + "失败: " + e.getMessage());
            return;
        }

        while (true) {
            try {
                Socket socket = serverSocket.accept();

                Log.i(TAG, "客户端连接: " + socket.getInetAddress().getHostAddress() + ":" + socket.getPort());
                //启动接收线程
                ReceiveThread receive_Thread = new ReceiveThread();
                receive_Thread.client = socket;
                receive_Thread.inputStream = socket.getInputStream();
                receive_Thread.outputStream = socket.getOutputStream();
                receive_Thread.start();
            } catch (IOException e) {
                Log.d(TAG, "服务器错误: " + e.getMessage());
            }
        }
    }

    /**
     * 接收线程
     */
    class ReceiveThread extends Thread//继承Thread
    {
        public Socket client;
        public InputStream inputStream;
        public OutputStream outputStream;

        public void sendData(String msg) {
            if (outputStream != null && client != null && client.isConnected()) {
                try {
                    outputStream.write(msg.getBytes());
                } catch (IOException e) {
                    Log.d(TAG, String.format("发送数据错误: %s:%d, %s", client.getInetAddress().getHostAddress(), client.getPort(), e.getMessage()));
                    try {
                        client.close();
                    } catch (IOException e1) {
                    }
                }
            }
        }

        public void run()//重写run方法
        {
            BufferedReader br=new BufferedReader(new InputStreamReader(inputStream));
            while (true)
                try {
                    final String text = br.readLine();
                    if (text == null || client.isClosed()) {
                        Log.d(TAG, String.format("连接断开: %s:%d", client.getInetAddress().getHostAddress(), client.getPort()));
                        break;
                    }
                    Message msg = new Message();
                    SocketData data = new SocketData();
                    data.data = text;
                    data.inputStream = inputStream;
                    data.outputStream = outputStream;
                    data.socket = client;
                    msg.obj = data;
                    handler.sendMessage(msg);
                } catch (Exception e) {
                    Log.d(TAG, String.format("客户端错误，断开连接: %s:%d, %s", client.getInetAddress().getHostAddress(), client.getPort(), e.getMessage()));
                    return;
                }
        }
    }
}