[C#] Socket 通訊，一個簡單的聊天窗口小程序

　　Socket，這玩意，當時不會的時候，抄別人的都用不好，簡單的一句話形容就是“笨死了”；也是很多人寫的太復雜，不容易理解造成的。最近在搞erlang和C的通訊，也想試試erlang是不是可以和C#簡單通訊，就簡單的做了些測試用例，比較簡單，覺得新手也可以接受。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace ChatClient
{
    public partial class Form1 : Form
    {
        private System.Windows.Forms.RichTextBox richTextBox1;
        private System.Windows.Forms.TextBox textBox1;
        private System.ComponentModel.IContainer components = null;

        /// <summary>
        /// 服務端偵聽端口
        /// </summary>
        private const int _serverPort = 8707;
        /// <summary>
        /// 客戶端偵聽端口
        /// </summary>
        private const int _clientPort = 8708;
        /// <summary>
        /// 緩存大小
        /// </summary>
        private const int _bufferSize = 1024;
        /// <summary>
        /// 服務器IP
        /// </summary>
        private const string ServerIP = "172.17.47.199";  //手動修改為指定服務器ip

        private Thread thread;

        private void Form1_Load(object sender, EventArgs e)
        {
            thread = new Thread(new ThreadStart(delegate { Listenning(); }));
            thread.Start();
        }

        void textBox_KeyUp(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                string msg;
                if ((msg = textBox1.Text.Trim()).Length > 0)
                {
                    SendMessage(msg);
                }
                textBox1.Clear();
            }
        }

        void SendMessage(string msg)
        {
            try
            {
                Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ServerIP), _serverPort);
                socket.Connect(endPoint);
                byte[] buffer = System.Text.ASCIIEncoding.UTF8.GetBytes(msg);
                socket.Send(buffer);
                socket.Close();
            }
            catch
            { }
        }

        void Listenning()
        {
            TcpListener listener = new TcpListener(_clientPort);
            listener.Start();
            while (true)
            {
                Socket socket = listener.AcceptSocket();
                byte[] buffer = new byte[_bufferSize];
                socket.Receive(buffer);
                int lastNullIndex = _bufferSize - 1;
                while (true)
                {
                    if (buffer[lastNullIndex] != '\0')
                        break;
                    lastNullIndex--;
                }
                string msg = Encoding.UTF8.GetString(buffer, 0, lastNullIndex + 1);
                WriteLine(msg);
                socket.Close();
            }
        }

        void WriteLine(string msg)
        {
            this.Invoke(new MethodInvoker(delegate
            {
                this.richTextBox1.AppendText(msg + Environment.NewLine);
            }));
        }

        public Form1()
        {
            this.richTextBox1 = new System.Windows.Forms.RichTextBox();
            this.textBox1 = new System.Windows.Forms.TextBox();
            this.SuspendLayout();
            // 
            // richTextBox1
            // 
            this.richTextBox1.Location = new System.Drawing.Point(1, 2);
            this.richTextBox1.Name = "richTextBox1";
            this.richTextBox1.Size = new System.Drawing.Size(282, 188);
            this.richTextBox1.TabIndex = 3;
            this.richTextBox1.Text = "";
            this.richTextBox1.KeyUp += new System.Windows.Forms.KeyEventHandler(this.textBox_KeyUp);
            // 
            // textBox1
            // 
            this.textBox1.Location = new System.Drawing.Point(3, 196);
            this.textBox1.Multiline = true;
            this.textBox1.Name = "textBox1";
            this.textBox1.Size = new System.Drawing.Size(277, 65);
            this.textBox1.TabIndex = 2;
            this.textBox1.KeyUp += new System.Windows.Forms.KeyEventHandler(this.textBox_KeyUp);
            // 
            // Form1
            // 
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
            this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
            this.ClientSize = new System.Drawing.Size(284, 262);
            this.Controls.Add(this.richTextBox1);
            this.Controls.Add(this.textBox1);
            this.Name = "Form1";
            this.Text = "Form1";
            this.Load += new System.EventHandler(this.Form1_Load);
            this.ResumeLayout(false);
            this.PerformLayout();
        }

        protected override void Dispose(bool disposing)
        {
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }
    }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Collections;

namespace ChatService
{
    public partial class Service1 : ServiceBase
    {
        /// <summary>
        /// 服務端偵聽端口
        /// </summary>
        private const int _serverPort = 8707;
        /// <summary>
        /// 客戶端偵聽端口
        /// </summary>
        private const int _clientPort = 8708;
        /// <summary>
        /// 緩存大小
        /// </summary>
        private const int _bufferSize = 1024;
        /// <summary>
        /// 服務器IP
        /// </summary>
        private const string ServerIP = "172.17.47.199";  //手動修改為指定服務器ip
        /// <summary>
        /// 客戶端IP
        /// </summary>
        //private Hashtable ServerIPs = new Hashtable();  //存放ip + port
        private List<string> ServerIPs = new List<string>();

        public Service1()
        {
            //InitializeComponent();   //從控制台改為服務，需要注釋下面的一行，打開本行
            Listenning();
        }

        void SendMessage(string from, string msg)  46  {  47             
            for (int i = ServerIPs.Count - 1; i >= 0; i--)  49  {  50                 try
 {  52                     Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  53                     IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ServerIPs[i]), _clientPort);  54  socket.Connect(endPoint);  55                     byte[] buffer = System.Text.ASCIIEncoding.UTF8.GetBytes((from + " say: " + msg).Trim());  56  socket.Send(buffer);  57  socket.Close();  58  }  59                 catch
 {  61  ServerIPs.RemoveAt(i);  62  }  63  }  64  }  65 
        void Listenning()  67  {  68 
            TcpListener listener = new TcpListener(_serverPort);  70  listener.Start();  71             while (true)  72  {  73                 Socket socket = listener.AcceptSocket();  74                 var s = socket.RemoteEndPoint.ToString();  75                 var ipstr = s.Substring(0, s.IndexOf(":"));  76 
                if (!ServerIPs.Contains(ipstr))  78  {  79  ServerIPs.Add(ipstr);  80  }  81 
                byte[] buffer = new byte[_bufferSize];  83  socket.Receive(buffer);  84                 int lastNullIndex = _bufferSize - 1;  85 
                while (true)  87  {  88                     if (buffer[lastNullIndex] != '\0')  89                         break;  90                     lastNullIndex--;  91  }  92                 string msg = Encoding.UTF8.GetString(buffer, 0, lastNullIndex + 1);  93  SendMessage(ipstr,msg);  94                 Console.WriteLine(msg);//服務模式下關閉
 }  96  }  97 
        protected override void OnStart(string[] args)  99  { 100  Listenning(); 101  } 102 
        protected override void OnStop() 104  { 105 
 } 107  } 108 }

 

邏輯視圖（比較簡單）：

 

 

1.左上角的是一個遠程客戶端，右上角是本地客戶端，右下角是本地服務端（暫時改為控制台程序）

2.這段程序只給不懂得如何用socket玩玩

3.這里面剔除了數據加密、異步獲取等繁雜的過程，想要學習可以參照：http://yunpan.cn/cKT2ZHdKRMILz  訪問密碼 b610