天冷，少打幾個字吧，這次主要 以unity作為 客戶端，同時  服務端和客戶端  採用執行緒方式 接收和傳送。不廢話了，上程式碼。

服務端

   class Program
    {
        private static NetServer s_server;
        private static Thread ReciveMsg;
        static void Main(string[] args)
        {
            NetPeerConfiguration config = new NetPeerConfiguration("
 
chat");
            config.MaximumConnections = 100;
            config.Port = 14242;
            s_server = new NetServer(config);
            s_server.Start();

            ReciveMsg = new Thread(SocketReceive);
            ReciveMsg.Start();
        }

        public static void SocketReceive()
        {
            
 
while (true)
            {
                NetIncomingMessage msg;
                while ((msg = s_server.ReadMessage()) != null)
                {
                    switch (msg.MessageType)
                    {
                        case NetIncomingMessageType.StatusChanged:
                            NetConnectionStatus status 
 
= (NetConnectionStatus)msg.ReadByte();

                            string reason = msg.ReadString();
                            Output(NetUtility.ToHexString(msg.SenderConnection.RemoteUniqueIdentifier) + "===== " + status + ": " + reason);

                            if (status == NetConnectionStatus.Connected)
                                Output("Remote hail: " + msg.SenderConnection.RemoteHailMessage.ReadString());

                            UpdateConnectionsList();
                            break;
                        case NetIncomingMessageType.WarningMessage:
                        case NetIncomingMessageType.VerboseDebugMessage:
                            string text = msg.ReadString();
                            Output(text);
                            break;
                        case NetIncomingMessageType.ErrorMessage:
                        case NetIncomingMessageType.DebugMessage:

                            var str = msg.ReadString();
                            if (str.StartsWith("Malformed packet; stated") ||
                                str.StartsWith("Received unhandled library message") ||
                                str.StartsWith("Unexpected NetMessageType"))
                                break; // we'll get a bunch of these and we're fine with that

                            Console.WriteLine(msg.MessageType + ": " + str);
                            break;
                        case NetIncomingMessageType.Data:
                            string chat = msg.ReadString();

                            Output("Broadcasting '" + chat + "'");

                            List<NetConnection> all = s_server.Connections; // get copy
                            all.Remove(msg.SenderConnection);

                            if (all.Count > 0)
                            {
                                NetOutgoingMessage om = s_server.CreateMessage();
                                om.Write(NetUtility.ToHexString(msg.SenderConnection.RemoteUniqueIdentifier) + " said: " + chat);
                                s_server.SendMessage(om, all, NetDeliveryMethod.ReliableOrdered, 0);
                            }
                            break;
                        case NetIncomingMessageType.UnconnectedData:
                            Console.WriteLine("Received " + msg.LengthBits + " bits of unconnected data");
                            break;
                        default:
                            Output("Unhandled type: " + msg.MessageType + " " + msg.LengthBytes + " bytes " + msg.DeliveryMethod + "|" + msg.SequenceChannel);
                            break;
                    } s_server.Recycle(msg);
                } Thread.Sleep(1);
            }
        }

        private static void Output(string text)
        {
            Console.WriteLine(text);
        }
        private static void UpdateConnectionsList()
        {
            foreach (NetConnection conn in s_server.Connections)
            {
                string str = NetUtility.ToHexString(conn.RemoteUniqueIdentifier) + " from " + conn.RemoteEndPoint.ToString() + " [" + conn.Status + "]";
                Output(str);
            }
        }
    }

客戶端

public class lidgrenClients : MonoBehaviour
{
    private static Thread ReciveMsg;
    private static Thread SendMsg;
    private static NetClient s_client;
    public Text texts;
    void Start()
    {
        NetPeerConfiguration config = new NetPeerConfiguration("chat");
        config.AutoFlushSendQueue = false;
        s_client = new NetClient(config);
        s_client.Shutdown("Bye");
        s_client.Start();
        NetOutgoingMessage hail = s_client.CreateMessage("This is the hail message");
        s_client.Connect("192.168.1.101", 14242, hail);
        ReciveMsg = new Thread(SocketReceive);
        ReciveMsg.Start();
    }
    void Update()
    {
     
    }
    public void Greet(string msg)
    {
        texts.text += msg + "\n";
        NetOutgoingMessage om = s_client.CreateMessage(msg);
        s_client.SendMessage(om, NetDeliveryMethod.ReliableOrdered);
        s_client.FlushSendQueue();//排隊 
    }

這是2個客戶端 相互發送。

下一篇，開始 寫 P2P 互動。大家期待