上篇部落格介紹了Socket Socket的基本講解以及對於內部的方法使用做了一些簡單的整理，並且通過ServerSocket自己做了一個通過服務端（PC主機）與多臺手機進行通訊的Demo，實現了群發功能、指定手機發送訊息功能、顯示已連線的手機數量以及IP地址和埠號，通過這些功能的實現，就可以實現無線群控功能的一個雛形，自己也有想過能否通過ServerSocket來實現模擬聊天功能的一個Demo，所以就趁熱打鐵做了一個簡易聊天室的App，Server充當終端伺服器，來起到接收訊息並把訊息轉發給其它裝置，因為真正的聊天功能都是攜帶具體訊息和一個指定客戶的地址等資訊，來起到客戶將訊息傳送給特定的一個好友，而不是發給了不該收到的人，但是時間有限就只寫了一個類似於微信群或是qq討論組的這樣一個聊天功能，希望能夠加深自己對ServerSocket的認識瞭解，同時也能夠幫助他人。

1.話不多說進入正題，先建立服務端，在Android Studio中建立Java程式碼，如下圖所示：

選擇Java Library 需要改名字的自己隨意

2.建立Client Manager客戶端管理類來管理客戶端的訊息，因為省時間就直接從我上篇部落格的程式碼基礎上進行的修改~程式碼如下所示：（自己編寫程式碼塊提交後總有亂碼...所以只能把自己的程式碼複製貼上進來啦~格式有點奇怪，但是沒有亂碼~）

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
 
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
/**
 * Created by sp01 on 2017/4/28.
 */
// 客戶端的管理類
public class ClientManager {

    private static Map<String,Socket> clientList = new HashMap<>();
    private static ServerThread serverThread = null;
    private static class 
 
ServerThread implements Runnable {

        private int port = 10010;
        private boolean isExit = false;
        private ServerSocket server;
        public ServerThread() {
            try {
                server = new ServerSocket(port);
System.out.println("啟動服務成功" + "port:" + port);
} catch (IOException e) {
                System.out.println("啟動server失敗，錯誤原因：" + e.getMessage());
}
        }

        @Override
public void run() {
            try {
                while (!isExit) {
                    // 進入等待環節
System.out.println("等待手機的連線... ... ");
                    final Socket socket = server.accept();
// 獲取手機連線的地址及埠號
final String address = socket.getRemoteSocketAddress().toString();
System.out.println("連線成功，連線的手機為：" + address);
                    new Thread(new Runnable() {
                        @Override
public void run() {
                            try {
                                // 單執行緒索鎖
synchronized (this){
                                    // 放進到Map中儲存
clientList.put(address,socket);
}
                                // 定義輸入流
InputStream inputStream = socket.getInputStream();
                                byte[] buffer = new byte[1024];
                                int len;
                                while ((len = inputStream.read(buffer)) != -1){
                                    String text = new String(buffer,0,len);
System.out.println("收到的資料為：" + text);
// 在這裡群發訊息
sendMsgAll(text);
}

                            }catch (Exception e){
                                System.out.println("錯誤資訊為：" + e.getMessage());
}finally {
                                synchronized (this){
                                    System.out.println("關閉連結：" + address);
clientList.remove(address);
}
                            }
                        }
                    }).start();
}
            } catch (IOException e) {
                e.printStackTrace();
}
        }

        public void Stop(){
            isExit = true;
            if (server != null){
                try {
                    server.close();
System.out.println("已關閉server");
} catch (IOException e) {
                    e.printStackTrace();
}
            }
        }
    }

    public static ServerThread startServer(){
        System.out.println("開啟服務");
        if (serverThread != null){
            showDown();
}
        serverThread = new ServerThread();
        new Thread(serverThread).start();
System.out.println("開啟服務成功");
        return serverThread;
}

    // 關閉所有server socket 和 清空Map
public static void showDown(){
        for (Socket socket : clientList.values()) {
            try {
                socket.close();
} catch (IOException e) {
                e.printStackTrace();
}
        }
        serverThread.Stop();
clientList.clear();
}

    // 群發的方法
public static boolean sendMsgAll(String msg){
        try {
            for (Socket socket : clientList.values()) {
                OutputStream outputStream = socket.getOutputStream();
outputStream.write(msg.getBytes("utf-8"));
}
            return true;
}catch (Exception e){
            e.printStackTrace();
}
        return false;
}

}

程式碼看起來比較簡單，用了儘可能方便理解的書寫，也寫好了一些註釋，應該不難理解所以就不具體解釋了，對Server Socket有不理解的地方，請參考我的上篇部落格~希望能有所幫助，但需要解釋的地方可能只有一點吧，群發的方法對收到的訊息全部進行廣播式的傳送，那麼不就傳送的人也會收到訊息了嘛？（可能有人感覺會有資料顯示重複的情況）我想說的是，真正歷史記錄都會在服務端進行資料儲存和處理這樣想就行了，我在Android端做了一個RecyclerView的載入不同行佈局實現模擬聊天介面，傳送和接收的歷史訊息都會顯示在列表上，本人傳送的內容在左側，其他人傳送的訊息被顯示在右側。

3.在MaClass.java（主入口類）中開啟服務：

public class MyClass {

    public static void main(String[]args){
        // 開啟伺服器
ClientManager.startServer();
}

}

tasks.withType(JavaCompile) {
    options.encoding = "UTF-8"
}

複製程式碼塊，放進藍色的gradle位置中（Java lib包內）dependencies{}下方位置，在Rebuild一下就好了。

5.新建並編寫Android客戶端工程，大致內容就是一個EditText輸入框，點選按鈕傳送資料，上方為一個載入不同行佈局的RecyclerView，實現歷史記錄閱覽，下面是activity_main.xml的內容：

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:id="@+id/activity_main"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"
tools:context="sq.test_socketchat.MainActivity">
    <android.support.v7.widget.RecyclerView
android:id="@+id/rv"
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="9"/>
    <LinearLayout
android:orientation="horizontal"
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="1">
        <EditText
android:id="@+id/et"
android:layout_weight="8"
android:layout_width="0dp"
android:hint="輸入內容"
android:layout_height="match_parent" />
        <Button
android:id="@+id/btn"
android:text="傳送"
android:layout_margin="3dp"
android:layout_weight="2"
android:layout_width="0dp"
android:layout_height="match_parent" />
    </LinearLayout>
</LinearLayout>

顯示效果如上圖所示。

6.接下來是準備工作，首先寫一個MyBean，用來儲存名字，訊息內容，訊息時間，以及載入哪種佈局：

/**
 * Created by sp01 on 2017/4/28.
 */
public class MyBean {
    private String data;
    private String time,name;
    private int number;
    public MyBean() {
    }

    public MyBean(String data, int number,String time,String name) {
        this.data = data;
        this.number = number;
        this.name = name;
        this.time = time;
}

    public String getTime() {
        return time;
}

    public void setTime(String time) {
        this.time = time;
}

    public String getName() {
        return name;
}

    public void setName(String name) {
        this.name = name;
}

    public String getData() {
        return data;
}

    public void setData(String data) {
        this.data = data;
}

    public int getNumber() {
        return number;
}

    public void setNumber(int number) {
        this.number = number;
}
}

7.同樣是準備工作，兩個不同佈局的item的書寫，第一種內容顯示在左側第二種則在右側，直接複製我的就好：

第一個item：

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:orientation="vertical"
android:background="#c8fffa"
android:layout_margin="5dp"
android:layout_width="match_parent"
android:layout_height="wrap_content">
    <TextView
android:id="@+id/tv"
android:layout_gravity="left"
android:textSize="20sp"
android:text="lalala"
android:layout_margin="5dp"
android:textColor="#000000"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
    <LinearLayout
android:layout_gravity="left"
android:orientation="horizontal"
android:layout_width="wrap_content"
android:layout_height="wrap_content">
        <TextView
android:id="@+id/tv_name"
android:text="name_xx"
android:layout_margin="5dp"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
        <TextView
android:id="@+id/tv_time"
android:layout_margin="5dp"
android:text="1993-09-28"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
    </LinearLayout>
</LinearLayout>

第二個item：

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:orientation="vertical"
android:background="#fcfdd9"
android:layout_margin="5dp"
android:layout_width="match_parent"
android:layout_height="wrap_content">
    <TextView
android:id="@+id/tv2"
android:layout_gravity="right"
android:textSize="20sp"
android:text="lalala"
android:layout_margin="5dp"
android:textColor="#000000"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
    <LinearLayout
android:layout_gravity="right"
android:orientation="horizontal"
android:layout_width="wrap_content"
android:layout_height="wrap_content">
        <TextView
android:id="@+id/tv_name2"
android:text="name_xx"
android:layout_margin="5dp"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
        <TextView
android:id="@+id/tv_time2"
android:layout_margin="5dp"
android:text="1993-09-28"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
    </LinearLayout>
</LinearLayout>

8.接下來是書寫MyAdapter內的程式碼（RecyclerView載入不同行佈局很簡單就不過多強調了）：

import android.content.Context;
import android.support.v7.widget.RecyclerView;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.TextView;
import java.util.ArrayList;
/**
 * Created by sp01 on 2017/4/28.
 */
public class MyAdapter extends RecyclerView.Adapter {

    private Context context;
    private ArrayList<MyBean> data;
    private static final int TYPEONE = 1;
    private static final int TYPETWO = 2;
    public MyAdapter(Context context) {
        this.context = context;
}

    public void setData(ArrayList<MyBean> data) {
        this.data = data;
notifyDataSetChanged();
}

    @Override
public int getItemViewType(int position) {
        return data.get(position).getNumber();
}

    @Override
public RecyclerView.ViewHolder onCreateViewHolder(ViewGroup parent, int viewType) {
        RecyclerView.ViewHolder holder = null;
        switch (viewType){
            case TYPEONE:
                View view = LayoutInflater.from(context).inflate(R.layout.item,parent,false);
holder = new OneViewHolder(view);
                break;
            case TYPETWO:
                View view1 = LayoutInflater.from(context).inflate(R.layout.item2,parent,false);
holder = new TwoViewHolder(view1);
                break;
}
        return holder;
}

    @Override
public void onBindViewHolder(RecyclerView.ViewHolder holder, int position) {
        int itemViewType = getItemViewType(position);
        switch (itemViewType){
            case TYPEONE:
                OneViewHolder oneViewHolder = (OneViewHolder) holder;
oneViewHolder.tv1.setText(data.get(position).getData());
oneViewHolder.name1.setText(data.get(position).getName());
oneViewHolder.time1.setText(data.get(position).getTime());
                break;
            case TYPETWO:
                TwoViewHolder twoViewHolder = (TwoViewHolder) holder;
twoViewHolder.tv2.setText(data.get(position).getData());
twoViewHolder.name2.setText(data.get(position).getName());
twoViewHolder.time2.setText(data.get(position).getTime());
                break;
}
    }

    @Override
public int getItemCount() {
        return  data != null && data.size() > 0 ? data.size() : 0;
}
    
    class OneViewHolder extends RecyclerView.ViewHolder{
       private TextView tv1;
        private TextView name1,time1;
       public OneViewHolder(View itemView) {
           super(itemView);
tv1 = (TextView) itemView.findViewById(R.id.tv);
name1 = (TextView) itemView.findViewById(R.id.tv_name);
time1 = (TextView) itemView.findViewById(R.id.tv_time);
}
   }

    class TwoViewHolder extends RecyclerView.ViewHolder{
        private TextView tv2;
        private TextView name2,time2;
        public TwoViewHolder(View itemView) {
            super(itemView);
tv2 = (TextView) itemView.findViewById(R.id.tv2);
name2 = (TextView) itemView.findViewById(R.id.tv_name2);
time2 = (TextView) itemView.findViewById(R.id.tv_time2);
}
    }
    
}

9.下面終於進入到了正題~進入到MainActivity中，程式碼如下所示：

import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
public class MainActivity extends AppCompatActivity {

    private RecyclerView rv;
    private EditText et;
    private Button btn;
    private Socket socket;
    private ArrayList<MyBean> list;
    private MyAdapter adapter;
@Override
protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
rv = (RecyclerView) findViewById(R.id.rv);
et = (EditText) findViewById(R.id.et);
btn = (Button) findViewById(R.id.btn);
list = new ArrayList<>();
adapter = new MyAdapter(this);
        final Handler handler = new MyHandler();
        new Thread(new Runnable() {
            @Override
public void run() {
                try {
                    socket = new Socket("192.168.1.111", 10010);
InputStream inputStream = socket.getInputStream();
                    byte[] buffer = new byte[1024];
                    int len;
                    while ((len = inputStream.read(buffer)) != -1) {
                        String data = new String(buffer, 0, len);
// 發到主執行緒中 收到的資料
Message message = Message.obtain();
message.what = 1;
message.obj = data;
handler.sendMessage(message);
}

                } catch (IOException e) {
                    e.printStackTrace();
}
            }
        }).start();
btn.setOnClickListener(new View.OnClickListener() {
            @Override
public void onClick(View v) {
                final String data = et.getText().toString();
                new Thread(new Runnable() {
                    @Override
public void run() {
                        try {
                            OutputStream outputStream = socket.getOutputStream();
SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss");    //設定日期格式
outputStream.write((socket.getLocalPort() + "//" + data + "//" + df.format(new Date())).getBytes("utf-8"));
outputStream.flush();
} catch (IOException e) {
                            e.printStackTrace();
}
                    }
                }).start();
}
        });
}

    private class MyHandler extends Handler {
        @Override
public void handleMessage(Message msg) {
            super.handleMessage(msg);
            if (msg.what == 1) {
                //
int localPort = socket.getLocalPort();
String[] split = ((String) msg.obj).split("//");
                if (split[0].equals(localPort + "")) {
                    MyBean bean = new MyBean(split[1],1,split[2],"我：");
list.add(bean);
} else {
                    MyBean bean = new MyBean(split[1],2,split[2],("來自：" + split[0]));
list.add(bean);
}

                // 向介面卡set資料
adapter.setData(list);
rv.setAdapter(adapter);
LinearLayoutManager manager = new LinearLayoutManager(MainActivity.this, LinearLayoutManager.VERTICAL, false);
rv.setLayoutManager(manager);
}
        }
    }
}

程式碼很簡單，因為Socket傳送的資料只能是一個基本的資料型別，不能傳遞類似於HashMap、集合、陣列這樣的資料，所以只能通過拼接字串的形式通過加入一些特殊的符號，來起到分割資料的作用，因為傳遞的資料中帶有傳送者、接受者、時間、訊息等這樣的資料，所以通過split來區別這些資料，從而進行具體的分配來實現目的。

10.最後許可權不要忘記加入~

<uses-permission android:name="android.permission.INTERNET"/>

那麼執行實現的具體效果又是怎樣的呢？請看下面（話說CSDN加圖好麻煩啊）：

1）這是開啟伺服器之後，兩臺手機開啟聊天Demo：

2）這是客戶端傳送資料的顯示內容：

3）這是服務端在客戶端聊天時顯示的Log：

總結：在這篇部落格中，主要是對ServerSocket和Android相結合的應用場景進行了自己為是的分析，覺得聊天的通訊方式可以通過Socket來實現，但是本文沒有對ServerSocket的基礎部分進行大量的講解，因為在我的上篇部落格中已經進行的很多的講解和分析了，所以就不做過多的累贅的去寫重複性的東西了，本文的一切東西都是自己親自手寫手敲的，如果這兩篇關於socket的講解和Demo為你帶來了哪怕僅僅一點點微不足道的幫助，都希望給我留個言點個贊來讓我知道，浪費不了你幾秒鐘的時間~~雖然自己也是在最近才接觸的Socket但是有了一點心得，就總結了這兩篇部落格，寫了倆個Demo來分享自己的一些淺薄的經驗，如果需要下載我的專案請 <點選這裡> 進行下載，裡面有個下載後先進行閱讀的文件要先檢視，兩個專案我都放在一個大包中了所以不需要下載兩次。下篇可能會介紹執行緒池，我日後也有打算自學.net，因為公司需要所以想自學一下，要是有什麼問題或是總結都會以部落格的形式來見證自己的成長，歡迎大家對我提建議和批評我會一一檢視並回復的。