using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using UnityEngine;

/*
 * SocketServer.cs
 * ソケット通信（サーバ）
 * Unityアプリ内にサーバを立ててメッセージの送受信を行う
 */
namespace Script.SocketServer
{
    public class SocketServer : MonoBehaviour {
        private TcpListener _listener;
        private readonly List<TcpClient> _clients = new List<TcpClient>();

        // ソケット接続準備、待機
        protected void Listen(string host, int port){
            Debug.Log("ipAddress:"+host+" port:"+port);
            var ip = IPAddress.Parse(host);
            _listener = new TcpListener(ip, port);
            _listener.Start();
            _listener.BeginAcceptSocket(DoAcceptTcpClientCallback, _listener);
        }

        // クライアントからの接続処理
        private void DoAcceptTcpClientCallback(IAsyncResult ar) {
            var listener = (TcpListener)ar.AsyncState;
            var client = listener.EndAcceptTcpClient(ar);
            _clients.Add(client);
            Debug.Log("Connect: "+client.Client.RemoteEndPoint);

            // 接続が確立したら次の人を受け付ける
            listener.BeginAcceptSocket(DoAcceptTcpClientCallback, listener);

            // 今接続した人とのネットワークストリームを取得
            var stream = client.GetStream();
            var reader = new StreamReader(stream,Encoding.UTF8);

            // 接続が切れるまで送受信を繰り返す
            while (client.Connected) {
                while (!reader.EndOfStream){
                    // 一行分の文字列を受け取る
                    var str = reader.ReadLine ();
                    OnMessage(str);
                }

                // クライアントの接続が切れたら
                if (client.Client.Poll(1000, SelectMode.SelectRead) && (client.Client.Available == 0)) {
                    Debug.Log("Disconnect: "+client.Client.RemoteEndPoint);
                    client.Close();
                    _clients.Remove(client);
                    break;
                }
            }
        }


        // メッセージ受信
        protected virtual void OnMessage(string msg){
            Debug.Log(msg);
        }

        // クライアントにメッセージ送信
        protected void SendMessageToClient(string msg){
            if (_clients.Count == 0){
                return;
            }
            var body = Encoding.UTF8.GetBytes(msg);

            // 全員に同じメッセージを送る
            foreach(var client in _clients){
                try{
                    var stream = client.GetStream();
                    stream.Write(body, 0, body.Length);
                }catch {
                    _clients.Remove(client);
                }
            }
        }

        // 終了処理
        protected virtual void OnApplicationQuit() {
            if (_listener == null){
                return;
            }

            if (_clients.Count != 0){
                foreach(var client in _clients){
                    client.Close();
                }
            }
            _listener.Stop();
        }
    }
}

using UnityEngine;

/*
 * TestServer.cs
 * SocketServerを継承、開くポートを指定して、送受信したメッセージを具体的に処理する
 */
namespace Script.SocketServer
{
    public class ServerTest : SocketServer {
#pragma warning disable 0649
        // ポート指定（他で使用していないもの、使用されていたら手元の環境によって変更）
        [SerializeField]private int _port;
#pragma warning restore 0649

        private void Start(){
            // 接続中のIPアドレスを取得
            var ipAddress = Network.player.ipAddress;
            // 指定したポートを開く
            Listen(ipAddress, _port);

            // システムに接続情報をセット（表示用）
            MyViewer.Instance.SetIpAddressPort (ipAddress + ":" + _port);
        }

        // クライアントからメッセージ受信
        protected override void OnMessage(string msg){
            base.OnMessage(msg);

            // -------------------------------------------------------------
            // あとは送られてきたメッセージによって何かしたいことを書く
            // -------------------------------------------------------------

            // 今回は受信した整数値を表示用システムにセットする
            int num;
            // 整数値以外は何もしない
            if (int.TryParse (msg, out num)) {
                // 値をセットする
                MyViewer.Instance.SetNum (num);
                // クライアントに受領メッセージを返す
                SendMessageToClient ("Accept:"+ num+"\n");
            } else {
                // クライアントにエラーメッセージを返す
                SendMessageToClient ("Error\n");
            }
        }
    }
}

using UnityEngine;
using UnityEngine.UI;

/*
 * MyViewer.cs
 * 受信したメッセージを元に情報の管理・UIへの表示などをする
 * 通信用の非同期スレッドから直接Unityのメインスレッド呼ぶとエラーになるので一枚噛ませている
 */
namespace Script
{
    public class MyViewer : MonoBehaviour {
        // 受信した値など集約用のシステム
        public static MyViewer Instance;

        private int _num = -9999;  // 安易な初期値
        private string _ipPort = "none"; // 接続先情報保持用

#pragma warning disable 0649
        // 画面表示用
        [SerializeField]private Text _ipportField;
        [SerializeField]private Text _textField;
#pragma warning restore 0649

        private void Awake(){
            Instance = this;
        }

        private void Update () {
            // 接続先表示
            _ipportField.text = _ipPort;

            // 初期値なら更新しない
            if(_num == -9999){
                return;
            }

            // 例）数字が送られてきたらその温度帯の燗酒の温度表現を表示する
            string str;
            if (_num > -5 && _num < 0) {
                str = "雪どけ";
            } else if (_num >= 0 && _num < 7) {
                str = "雪冷え";
            } else if (_num >= 7 && _num < 12) {
                str = "花冷え";
            } else if (_num >= 12 && _num < 17) {
                str = "涼冷え";
            } else if (_num >= 17 && _num < 30) {
                str = "冷や";
            } else if (_num >= 30 && _num < 35) {
                str = "日向燗";
            } else if (_num >= 35 && _num < 38) {
                str = "人肌燗";
            } else if (_num >= 38 && _num < 42) {
                str = "ぬる燗";
            } else if (_num >= 42 && _num < 48) {
                str = "上燗";
            } else if (_num >= 48 && _num < 53) {
                str = "熱燗";
            } else if (_num >= 53 && _num < 80) {
                str = "飛び切り燗";
            } else if (_num >= 80 && _num < 90) {
                // 玉川酒造のフィリップ・ハーパー杜氏が好きな温度で正式なものではない
                // 著者もハーパー氏に倣ってここまで上げて飲んでみるなどして楽しんでいる
                str = "ハーパー燗"; 
            } else {
                str = "オススメしない";
            }

            _textField.text = _num + "℃は...\n"+str;

        }

        // 受信した数値セット
        public void SetNum(int n){
            _num = n;
        }

        // 接続情報セット
        public void SetIpAddressPort(string ipport){
            _ipPort = ipport;
        }
    }
}