程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#入門知識 >> C#中Socket用法,多個聊天和單一聊天。,

C#中Socket用法,多個聊天和單一聊天。,

編輯:C#入門知識

C#中Socket用法,多個聊天和單一聊天。,


自己琢磨Socket剛剛幾天,所以整理出來和大家共享一下。廢話少說直接進入正題。

在C#中提供了兩種網絡服務,一種是Socket類,另一種是TcpListener(服務器),TcpClient(客戶端);

至於這兩種有什麼區別那;MSDN上是這樣解釋的:

TcpClient 類,TcpListener 類提供了一些簡單的方法,用於在同步阻止模式下通過網絡來連接、發送和接收流數據。

Socket 類為網絡通信提供了一套豐富的方法和屬性。 Socket 類允許您使用 ProtocolType 枚舉中所列出的任何一種協議執行異步和同步數據傳輸。

個人理解就是一個是用於簡單的業務,一種用於復雜的業務。所以感覺是一樣的。本文事例主要用Socket類來實現。一般來說復雜的會了,簡單的應該也差不多了。

先從第一個情景來說:第一個就是建立多人聊天的模式,就是多個客戶端連接一個服務器,然後可以和多個客戶端通信。就像QQ裡的群聊。

 

首先我們來見一個服務器:

就包含一個文本框就行了,裡邊具體代碼如下:

 1     public partial class server : Form
 2     {
 3         private IPEndPoint ServerInfo;//存放服務器的IP和端口信息
 4         private Socket ServerSocket;//服務端運行的SOCKET
 5         private Thread ServerThread;//服務端運行的線程
 6         private Socket[] ClientSocket;//為客戶端建立的SOCKET連接
 7         private int ClientNumb;//存放客戶端數量
 8         private byte[] MsgBuffer;//存放消息數據
 9 
10         private object obj;
11 
12         public server()
13         {
14             InitializeComponent();
15             ListenClient();
16         }
17 
18         /// <summary>
19         /// 開始服務,監聽客戶端
20         /// </summary>
21         private void ListenClient()
22         {
23             try
24             {
25                 ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
26                 IPAddress ip = IPAddress.Parse("127.0.0.1");
27                 ServerInfo = new IPEndPoint(ip, Int32.Parse("3000"));
28                 ServerSocket.Bind(ServerInfo);
29                 ServerSocket.Listen(10);
30 
31                 ClientSocket = new Socket[65535];
32                 MsgBuffer = new byte[65535];
33                 ClientNumb = 0;
34 
35                 ServerThread = new Thread(new ThreadStart(RecieveAccept));
36                 ServerThread.Start();
37             }
38             catch (System.Exception ex)
39             {
40 
41             }
42         }
43 
44         /// <summary>
45         /// 添加阻塞,監聽客戶端
46         /// </summary>
47         private void RecieveAccept()
48         {
49             while (true)
50             {
51                 //等待接受客戶端連接,如果有就執行下邊代碼,沒有就阻塞
52                 ClientSocket[ClientNumb] = ServerSocket.Accept();
53                 //接受客戶端信息,沒有阻塞,則會執行下邊輸出的代碼;如果是Receive則不會執行下邊輸出代碼
54                 ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, SocketFlags.None,
55                     new AsyncCallback(ReceiveCallback), ClientSocket[ClientNumb]);
56                 this.Invoke((MethodInvoker)delegate
57                 {
58                     lock (this.textBox1)
59                         this.textBox1.Text += "客戶端:" + ClientNumb.ToString() + "連接成功!" + "\r\n";
60                 });
61                 ClientNumb++;
62             }
63         }
64 
65         /// <summary>
66         /// 回發數據到客戶端
67         /// </summary>
68         /// <param name="ar"></param>
69         private void ReceiveCallback(IAsyncResult ar)
70         {
71             try
72             {
73                 Socket rSocket = (Socket)ar.AsyncState;
74                 int rEnd = rSocket.EndReceive(ar);
75 
76                 for (int i = 0; i < ClientNumb; i++)
77                 {
78                     if (ClientSocket[i].Connected)
79                     {
80                         //發送數據到客戶端
81                         ClientSocket[i].Send(MsgBuffer, 0, rEnd, SocketFlags.None);
82                     }
83 
84                     //同時接受客戶端回發的數據,用於回發
85                     rSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), rSocket);
86                 }
87             }
88             catch (System.Exception ex)
89             {
90 
91             }
92         }
93     }

 

然後我們添加客戶端代碼,客戶端要一個按鈕和兩個文本框

具體代碼如下:

 1     public partial class Client : Form
 2     {
 3         private IPEndPoint ServerInfo;
 4         private Socket ClientSocket;
 5         private object obj;
 6 
 7         //信息接收緩存
 8         private Byte[] MsgBuffer;
 9         //信息發送存儲
10         private Byte[] MsgSend;
11 
12         public Client()
13         {
14             InitializeComponent();
15             ConnectServer();
16             this.button1.Click += new EventHandler(button1_Click);
17         }
18 
19         /// <summary>
20         /// 打開客戶端,即連接服務器
21         /// </summary>
22         private void ConnectServer()
23         {
24             try
25             {
26                 ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
27                 MsgBuffer = new byte[65535];
28                 MsgSend = new byte[65535];
29                 IPAddress ip = IPAddress.Parse("127.0.0.1");
30                 ServerInfo = new IPEndPoint(ip, Int32.Parse("3000"));
31                 ClientSocket.Connect(ServerInfo);
32                 //發送信息至服務器
33                 ClientSocket.Send(Encoding.Unicode.GetBytes("用戶: 進入系統!" + "\r\n"));
34                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, SocketFlags.None,
35                     new AsyncCallback(ReceiveCallback), null);
36                 this.textBox1.Text += "登錄服務器成功" + "\r\n";
37             }
38             catch (System.Exception ex)
39             {
40 
41             }
42         }
43 
44         /// <summary>
45         /// 回調時調用
46         /// </summary>
47         /// <param name="ar"></param>
48         private void ReceiveCallback(IAsyncResult ar)
49         {
50             int rEnd = ClientSocket.EndReceive(ar);
51             this.Invoke((MethodInvoker)delegate
52                  {
53                      lock (this.textBox1)
54                      {
55                          this.textBox1.Text += Encoding.Unicode.GetString(MsgBuffer, 0, rEnd) + "\r\n";
56                      }
57                  });
58             ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);
59         }
60 
61         /// <summary>
62         /// 發送信息
63         /// </summary>
64         /// <param name="sender"></param>
65         /// <param name="e"></param>
66         private void button1_Click(object sender, EventArgs e)
67         {
68             MsgSend = Encoding.Unicode.GetBytes("說:\n" + this.textBox2.Text + "\n\r");
69             if (ClientSocket.Connected)
70             {
71                 ClientSocket.Send(MsgSend);
72             }
73         }
74 
75     }
76 }

這樣先運行服務器,在多運行幾個客戶端就可以了。

 

 

下邊講一下第二種案例:這種是多個客戶端和服務器連接,每個客戶端都可以和服務器通信,但是客戶端之間沒有通信,而且每個客戶端和服務器通信時,不會影響其他客戶端。

具體樣式如圖:

接著我們來看看具體的代碼:

先來看看服務器的,樣式和第一種一樣,

具體代碼:

 1     public partial class Server : Form
 2     {
 3         private Socket socket = null;
 4         private Thread thread = null;
 5 
 6         public Server()
 7         {
 8             InitializeComponent();
 9             StartListening();
10         }
11 
12         /// 
13         /// 開始監聽客戶端
14         /// 
15         private void StartListening()
16         {
17             try
18             {
19                 socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
20                 IPAddress ipaddress = IPAddress.Parse("127.0.0.1");
21                 IPEndPoint endPoint = new IPEndPoint(ipaddress, int.Parse("3000"));
22 
23                 socket.Bind(endPoint);
24                 socket.Listen(20);
25 
26                 thread = new Thread(new ThreadStart(WatchConnection));
27                 thread.IsBackground = true;
28                 thread.Start();
29 
30                 this.listBox1.Text = "開始監聽客戶端傳來的消息" + "\r\n";
31             }
32             catch (System.Exception ex)
33             {
34                 this.listBox1.Text += "SocketException" + ex;
35             }
36         }
37 
38         Socket[] socConnection = new Socket[12];
39         private static int clientNum = 0;
40 
41         /// <summary>
42         /// 監聽客戶端發來的請求
43         /// </summary>
44         private void WatchConnection()
45         {
46             while (true)
47             {
48                 socConnection[clientNum] = socket.Accept();
49                 this.Invoke((MethodInvoker)delegate
50                 {
51                     this.listBox1.Text += "客戶端連接成功" + "\r\n";
52                 });
53 
54                 Thread thread = new Thread(new ParameterizedThreadStart(ServerRecMsg));
55                 thread.IsBackground = true;
56                 thread.Start(socConnection[clientNum]);
57                 clientNum++;
58             }
59         }
60 
61         /// <summary>
62         /// 接受客戶端消息並發送消息
63         /// </summary>
64         /// <param name="socketClientPara"></param>
65         private void ServerRecMsg(object socketClientPara)
66         {
67             Socket socketServer = socketClientPara as Socket;
68             try
69             {
70                 while (true)
71                 {
72                     byte[] arrServerRecMsg = new byte[1024 * 1024];
73                     int length = socketServer.Receive(arrServerRecMsg);
74 
75                     string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 0, length);
76                     this.Invoke((MethodInvoker)delegate
77                     {
78                         this.listBox1.Text += "接收到:" + strSRecMsg + "\r\n";
79                     });
80 
81                     byte[] arrSendMsg = Encoding.UTF8.GetBytes("收到服務器發來的消息");
82                     //發送消息到客戶端
83                     socketServer.Send(arrSendMsg);
84                 }
85             }
86             catch (System.Exception ex)
87             {
88 
89             }
90         }
91     }

再來看看客戶端代碼:

樣式和第一種也一樣:

 1     public partial class Client : Form
 2     {
 3         private Socket socketClient = null;
 4         private Thread threadClient = null;
 5 
 6         public Client()
 7         {
 8             InitializeComponent();
 9             ConnectionServer();
10             this.button1.Click += new EventHandler(button1_Click);
11         }
12 
13         /// <summary>
14         /// 連接服務器
15         /// </summary>
16         private void ConnectionServer()
17         {
18             socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
19             IPAddress ipaddress = IPAddress.Parse("127.0.0.1");
20             IPEndPoint endPoint = new IPEndPoint(ipaddress, int.Parse("3000"));
21             try
22             {
23                 socketClient.Connect(endPoint);
24                 threadClient = new Thread(RecMsg);
25                 threadClient.IsBackground = true;
26                 threadClient.Start();
27             }
28             catch (System.Exception ex)
29             {
30 
31             }
32 
33         }
34 
35         /// <summary>
36         /// 接收服務器消息
37         /// </summary>
38         private void RecMsg()
39         {
40             while (true)
41             {
42                 //內存緩沖區1M,用於臨時存儲接收到服務器端的消息
43                 byte[] arrRecMsg = new byte[1024 * 1024];
44                 //將接收到的數據放入內存緩沖區,獲取其長度
45                 int length = socketClient.Receive(arrRecMsg);
46                 //將套接字獲取到的字節數組轉換為我們可以理解的字符串
47                 string strRecMsg = Encoding.UTF8.GetString(arrRecMsg, 0, length);
48                 this.Invoke((MethodInvoker)delegate
49                 {
50                     lock (this.listBox1)
51                     {
52                         this.listBox1.Text += "服務器:" + strRecMsg + "\r\n";
53                     }
54                 });
55             }
56         }
57 
58         /// <summary>
59         /// 向服務器發送消息
60         /// </summary>
61         /// <param name="sender"></param>
62         /// <param name="e"></param>
63         private void button1_Click(object sender, EventArgs e)
64         {
65             ClientSendMsg(this.textBox1.Text.Trim());
66         }
67 
68         /// <summary>
69         /// 發送信息到服務器
70         /// </summary>
71         /// <param name="sendMsg"></param>
72         private void ClientSendMsg(string sendMsg)
73         {
74             //將輸入的字符串轉化為機器可以識別的字節數組
75             byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(sendMsg);
76             //發送數據
77             socketClient.Send(arrClientSendMsg);
78             this.listBox1.Text += "客戶端:" + sendMsg + "\r\n";
79         }
80     }

到此兩種方式就說完了,不知道說的對不對,請各位吐槽!!!,轉載注明出處。


一個C語言冒泡排序法的簡單程序

main()
{
int i,j,temp;
int a[10];
for(i=0;i<10;i++)
scanf ("%d,",&a[i]);
for(j=0;j<=9;j++)
{ for (i=0;i<10-j;i++)
if (a[i]>a[i+1])
{ temp=a[i];
a[i]=a[i+1];
a[i+1]=temp;}
}
for(i=1;i<11;i++)
printf("%5d,",a[i] );
printf("\n");
}

--------------
冒泡算法
冒泡排序的算法分析與改進
交換排序的基本思想是:兩兩比較待排序記錄的關鍵字,發現兩個記錄的次序相反時即進行交換,直到沒有反序的記錄為止。
應用交換排序基本思想的主要排序方法有:冒泡排序和快速排序。

冒泡排序

1、排序方法
將被排序的記錄數組R[1..n]垂直排列,每個記錄R看作是重量為R.key的氣泡。根據輕氣泡不能在重氣泡之下的原則,從下往上掃描數組R:凡掃描到違反本原則的輕氣泡,就使其向上"飄浮"。如此反復進行,直到最後任何兩個氣泡都是輕者在上,重者在下為止。
(1)初始
R[1..n]為無序區。

(2)第一趟掃描
從無序區底部向上依次比較相鄰的兩個氣泡的重量,若發現輕者在下、重者在上,則交換二者的位置。即依次比較(R[n],R[n-1]),(R[n-1],R[n-2]),…,(R[2],R[1]);對於每對氣泡(R[j+1],R[j]),若R[j+1].key<R[j].key,則交換R[j+1]和R[j]的內容。
第一趟掃描完畢時,"最輕"的氣泡就飄浮到該區間的頂部,即關鍵字最小的記錄被放在最高位置R[1]上。

(3)第二趟掃描
掃描R[2..n]。掃描完畢時,"次輕"的氣泡飄浮到R[2]的位置上……
最後,經過n-1 趟掃描可得到有序區R[1..n]
注意:
第i趟掃描時,R[1..i-1]和R[i..n]分別為當前的有序區和無序區。掃描仍是從無序區底部向上直至該區頂部。掃描完畢時,該區中最輕氣泡飄浮到頂部位置R上,結果是R[1..i]變為新的有序區。

2、冒泡排序過程示例
對關鍵字序列為49 38 65 97 76 13 27 49的文件進行冒泡排序的過程

3、排序算法
(1)分析
因為每一趟排序都使有序區增加了一個氣泡,在經過n-1趟排序之後,有序區中就有n-1個氣泡,而無序區中氣泡的重量總是大於等於有序區中氣泡的重量,所以整個冒泡排序過程至多需要進行n-1趟排序。
若在某一趟排序中未發現氣泡位置的交換,則說明待排序的無序區中所有氣泡均滿足輕者在上,重者在下的原則,因此,冒泡排序過程可在此趟排序後終止。為此,在下面給出的算法中,引入一個布爾量exchange,在每趟排序開始前,先將其置為FALSE。若排序過程中發生了交換,則將其置為TRUE。各趟排序結束時檢查exchange,若未曾發生過交換則終止算法,不再進行下一趟排序。

(2)具體算法
void BubbleSort(SeqList R)
{ //R(l..n)是待排序的文件,采用自下向上掃描,對R做冒泡排序
int i,j;
Boolean exchange; //交換標志
for(i=1;i&......余下全文>>
 

一個C語言冒泡排序法的簡單程序

main()
{
int i,j,temp;
int a[10];
for(i=0;i<10;i++)
scanf ("%d,",&a[i]);
for(j=0;j<=9;j++)
{ for (i=0;i<10-j;i++)
if (a[i]>a[i+1])
{ temp=a[i];
a[i]=a[i+1];
a[i+1]=temp;}
}
for(i=1;i<11;i++)
printf("%5d,",a[i] );
printf("\n");
}

--------------
冒泡算法
冒泡排序的算法分析與改進
交換排序的基本思想是:兩兩比較待排序記錄的關鍵字,發現兩個記錄的次序相反時即進行交換,直到沒有反序的記錄為止。
應用交換排序基本思想的主要排序方法有:冒泡排序和快速排序。

冒泡排序

1、排序方法
將被排序的記錄數組R[1..n]垂直排列,每個記錄R看作是重量為R.key的氣泡。根據輕氣泡不能在重氣泡之下的原則,從下往上掃描數組R:凡掃描到違反本原則的輕氣泡,就使其向上"飄浮"。如此反復進行,直到最後任何兩個氣泡都是輕者在上,重者在下為止。
(1)初始
R[1..n]為無序區。

(2)第一趟掃描
從無序區底部向上依次比較相鄰的兩個氣泡的重量,若發現輕者在下、重者在上,則交換二者的位置。即依次比較(R[n],R[n-1]),(R[n-1],R[n-2]),…,(R[2],R[1]);對於每對氣泡(R[j+1],R[j]),若R[j+1].key<R[j].key,則交換R[j+1]和R[j]的內容。
第一趟掃描完畢時,"最輕"的氣泡就飄浮到該區間的頂部,即關鍵字最小的記錄被放在最高位置R[1]上。

(3)第二趟掃描
掃描R[2..n]。掃描完畢時,"次輕"的氣泡飄浮到R[2]的位置上……
最後,經過n-1 趟掃描可得到有序區R[1..n]
注意:
第i趟掃描時,R[1..i-1]和R[i..n]分別為當前的有序區和無序區。掃描仍是從無序區底部向上直至該區頂部。掃描完畢時,該區中最輕氣泡飄浮到頂部位置R上,結果是R[1..i]變為新的有序區。

2、冒泡排序過程示例
對關鍵字序列為49 38 65 97 76 13 27 49的文件進行冒泡排序的過程

3、排序算法
(1)分析
因為每一趟排序都使有序區增加了一個氣泡,在經過n-1趟排序之後,有序區中就有n-1個氣泡,而無序區中氣泡的重量總是大於等於有序區中氣泡的重量,所以整個冒泡排序過程至多需要進行n-1趟排序。
若在某一趟排序中未發現氣泡位置的交換,則說明待排序的無序區中所有氣泡均滿足輕者在上,重者在下的原則,因此,冒泡排序過程可在此趟排序後終止。為此,在下面給出的算法中,引入一個布爾量exchange,在每趟排序開始前,先將其置為FALSE。若排序過程中發生了交換,則將其置為TRUE。各趟排序結束時檢查exchange,若未曾發生過交換則終止算法,不再進行下一趟排序。

(2)具體算法
void BubbleSort(SeqList R)
{ //R(l..n)是待排序的文件,采用自下向上掃描,對R做冒泡排序
int i,j;
Boolean exchange; //交換標志
for(i=1;i&......余下全文>>
 

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved