TCP的代码

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Windows;
  6 using System.Windows.Controls;
  7 using System.Windows.Data;
  8 using System.Windows.Documents;
  9 using System.Windows.Input;
 10 using System.Windows.Media;
 11 using System.Windows.Media.Imaging;
 12 using System.Windows.Navigation;
 13 using System.Windows.Shapes;
 14 using System.Net.Sockets;
 15 using System.Net;
 16 using System.IO;
 17 using System.Threading;
 18 
 19 namespace TCPServerExample
 20 {
 21     /// <summary>
 22     /// MainWindow.xaml 的交互逻辑
 23     /// </summary>
 24     public partial class MainWindow : Window
 25     {
 26         TcpListener myListener;
 27         List<User> userList = new List<User>();
 28         bool isExit;
 29         IPAddress ip;
 30         public MainWindow()
 31         {
 32             InitializeComponent();
 33             button1.IsEnabled = true;
 34             button2.IsEnabled = false;
 35         }
 36         //开始按钮
 37         private void button1_Click(object sender, RoutedEventArgs e)
 38         {
 39             button1.IsEnabled = false;
 40             button2.IsEnabled = true;
 41             isExit = true;
 42             //获取本机IP地址
 43             IPAddress[] ips = Dns.GetHostAddresses(Dns.GetHostName());
 44             foreach (var item in ips)
 45             {
 46                 if (item.AddressFamily==AddressFamily.InterNetwork)
 47                 {
 48                     ip = item;
 49                     break;
 50                 }
 51             }
 52 
 53 
 54             myListener = new TcpListener(ip, 51888);
 55             IPEndPoint iep = new IPEndPoint(ip, 51888);
 56             myListener.Start();
 57             //textBlock1.Text += string.Format("服务器在{0}的{1}打开监听",ips[5],port);
 58             textBlock1.Text += string.Format("服务器在{0}打开监听\n", iep);
 59             Thread t1 = new Thread(ListenClientConnect);
 60             t1.Start();
 61         }
 62 
 63         //第一步，开启监听
 64         private void ListenClientConnect()
 65         {
 66             //获取相应客户端套接字
 67             while (isExit)
 68             {
 69                 try
 70                 {
 71                     TcpClient newClient = myListener.AcceptTcpClient();
 72                     User user = new User(newClient);
 73                     userList.Add(user);
 74                     Action act = delegate()
 75                     {
 76                         textBlock1.Text += string.Format("用户{0}连接成功，当前在线用户数为{1}\n",
 77                             newClient.Client.RemoteEndPoint, userList.Count);
 78                     };
 79                     textBlock1.Dispatcher.Invoke(act);
 80                     Thread t2 = new Thread(ReceiveMessage);
 81                     t2.Start(user);
 82                 }
 83                 catch
 84                 {
 85                     break;
 86                 }
 87   
 88             }
 89         }
 90         //第二步，接收消息
 91         private void ReceiveMessage(Object user1)
 92         {
 93             User newuser = (User)user1;
 94             while (isExit)
 95             {
 96                 try
 97                 {
 98                     string message = newuser.br.ReadString();
 99                     AddMessage(string.Format("客户端：{0}发送信息：{1}\n",
100                             newuser.client.Client.RemoteEndPoint, message));
101                    string[] array = message.Split(‘,‘);
102                     switch (array[0])
103                     {
104                         case "Login":
105                             {
106                                 newuser.username = array[1];
107                                 //服务器告诉所有在线客户端，有新的用户登录
108                                 for (int i = 0; i < userList.Count; i++)
109                                 {
110                                     if (userList[i].username != newuser.username)
111                                     {
112                                         userList[i].bw.Write("Login," + array[1]);
113                                     }
114                                     newuser.bw.Write("Login," + userList[i].username);
115                                 }
116                                 break;
117                             }
118                         case "Logout":
119                             {
120                                 for (int i = 0; i < userList.Count; i++)
121                                 {
122                                     if (userList[i].username != newuser.username)
123                                     {
124                                         userList[i].bw.Write("Logout," + array[1]);
125                                     }
126                                 }
127                                 userList.Remove(newuser);
128                                 AddMessage("客户端" + newuser.username + "退出，" + "当前用户数为：" + userList.Count);
129                                 return;
130                             }
131                         case "Talk":
132                             {
133                                 string target = array[1];
134                                 for (int i = 0; i < userList.Count; i++)
135                                 {
136                                     if (userList[i].username == target)
137                                     {
138                                         userList[i].bw.Write("Talk," + newuser.username + "," + array[2]);
139                                     }
140                                 }
141                                 break;
142                             }
143                         default:
144                             {
145                                 MessageBox.Show("什么意思?");
146                                 break;
147                             }
148                     }
149                 }
150                 catch
151                 {
152                     break;
153                 }
154             }
155         }
156         //第三步，添加消息到textBlock
157         private void AddMessage(string message)
158         {
159             Action act = delegate()
160             {
161                 textBlock1.Text += message;
162             };
163             textBlock1.Dispatcher.Invoke(act);
164         }
165 
166         //结束按钮
167         private void button2_Click(object sender, RoutedEventArgs e)
168         {
169             button1.IsEnabled = true;
170             button2.IsEnabled = false;
171             for (int i = 0; i < userList.Count; i++)
172             {
173                 try
174                 {
175                     userList[i].bw.Write("服务器已停止监听！");
176                 }
177                 catch
178                 {
179                     break;
180                 }
181                 userList[i].Close();
182             }
183             isExit = false;
184             Thread.Sleep(1000);
185             myListener.Stop();
186             
187             for (int i = 0; i < userList.Count; i++)
188             {
189                 userList[i].Close();
190             }
191             textBlock1.Text += "监听结束！";
192         }
193     }
194 }

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 using System.Net.Sockets;
 6 using System.IO;
 7 
 8 namespace TCPServerExample
 9 {
10     class User
11     {
12         public string username{get;set;}
13         public TcpClient client{get;set;}
14         public BinaryWriter bw { get; set; }
15         public BinaryReader br { get; set; }
16         public User(TcpClient newclient)
17         {
18             this.client = newclient;
19             NetworkStream networkstream = newclient.GetStream();
20             bw = new BinaryWriter(networkstream);
21             br = new BinaryReader(networkstream);
22             
23 
24         }
25 
26         public void Close()
27         {
28             client.Close();
29             bw.Close();
30             br.Close();
31 
32         }
33     }
34 }

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Windows;
  6 using System.Windows.Controls;
  7 using System.Windows.Data;
  8 using System.Windows.Documents;
  9 using System.Windows.Input;
 10 using System.Windows.Media;
 11 using System.Windows.Media.Imaging;
 12 using System.Windows.Navigation;
 13 using System.Windows.Shapes;
 14 using System.Net.Sockets;
 15 using System.Net;
 16 using System.IO;
 17 using System.Threading;
 18 
 19 namespace TCPClientExample
 20 {
 21     /// <summary>
 22     /// MainWindow.xaml 的交互逻辑
 23     /// </summary>
 24     public partial class MainWindow : Window
 25     {
 26         TcpClient newClient;
 27         BinaryWriter bw;
 28         BinaryReader br;
 29         string username;
 30         //enum item { listBox1, textBox1 };
 31         //enum opreation { add,remove};
 32         public MainWindow()
 33         {
 34             InitializeComponent();
 35         }
 36         private void button1_Click(object sender, RoutedEventArgs e)
 37         {
 38             button1.IsEnabled = false;
 39             username = textBox2.Text;
 40             //创建套接字（TcpClient对象）
 41             newClient = new TcpClient();  
 42             //获取服务器IP地址
 43             IPAddress ip = IPAddress.Parse("10.0.2.15");
 44             try
 45             {
 46                 newClient.Connect(ip, 51888);
 47                 listBox1.Items.Add("连接成功！");
 48             }
 49             catch
 50             {
 51                 listBox1.Items.Add("连接失败！");
 52                 button1.IsEnabled = true;
 53                 return;
 54             }
 55             NetworkStream networkStream = newClient.GetStream();
 56             bw = new BinaryWriter(networkStream);
 57             br = new BinaryReader(networkStream);
 58             bw.Write("Login," + username);
 59             Thread t1 = new Thread(ReceiveMessage); 
 60             t1.Start();
 61         }
 62         //第一步，接收消息
 63         private void ReceiveMessage()
 64         {
 65             string message = "";
 66             while (true)
 67             {
 68                 try
 69                 {
 70                     message = br.ReadString();
 71                 }
 72                 catch
 73                 {
 74                     break;
 75                 }
 76                 string[] array = message.Split(‘,‘);
 77                 switch (array[0])
 78                 {
 79                     case "Login":
 80                         AddUser(array[1]);
 81                         break;
 82                     case "Logout":
 83                         RemoveUser(array[1]);
 84                         break;
 85                     case "Talk":
 86                         AddMessage(array[1] + ":" + array[2]);
 87                         break;
 88                     default:
 89                         AddMessage(message);
 90                         break;
 91                 }
 92             }
 93         }
 94         //第二步，添加消息到textBlock
 95         private void AddMessage(string message)
 96         {
 97             Action act = delegate()
 98             {
 99                 listBox1.Items.Add(message);
100             };
101             listBox2.Dispatcher.Invoke(act);
102         }
103         //第三步，添加用户到列表
104         private void AddUser(string name)
105         {
106             Action act = delegate()
107             {
108                 listBox2.Items.Add(name);
109             };
110             listBox2.Dispatcher.Invoke(act);
111         }
112         //第四步，移除用户
113         private void RemoveUser(string name)
114         {
115             Action act = delegate()
116             {
117                 listBox2.Items.Remove(name);
118             };
119             listBox2.Dispatcher.Invoke(act);
120         }
121 
122         private void button2_Click(object sender, RoutedEventArgs e)
123         {
124             NetworkStream networkStream = newClient.GetStream();
125              bw = new BinaryWriter(networkStream);
126             string message = textBox1.Text;
127             bw.Write("Talk,"+listBox2.SelectedItem+","+message);
128             listBox1.Items.Add(username + ":" + textBox1.Text);   
129         }
130         private void Window_Closing(object sender, System.ComponentModel.CancelEventArgs e)
131         {
132             try
133             {
134                 bw.Write("Logout," + username);
135             }
136             catch
137             {
138                 MessageBox.Show("与服务器连接失败！");
139             }
140             bw.Close();
141         }
142     }
143 }