一、客户端向服务器的发送消息
        代码如下：

1. public Form1()
   
2.         {
   
3.             InitializeComponent();
   
4.             TextBox.CheckForIllegalCrossThreadCalls = false;//关闭跨线程修改控件检查
   
5.         }
   
6. 
   
7.         Socket sokClient = null;//负责与该服务端套接字通信的套接字
   
8.         Thread threadClient = null;//负责 监听 服务器端发送来的消息的 线程
   
9.         bool isRec = true;//是否循环接受服务端的数据
   
10.         private void button1_Click(object sender, EventArgs e)
    
11.         {
    
12.             //实例化 套接字 （ip4寻址协议，流式传输，TCP协议）
    
13.             sokClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
14.             //创建IP对象
    
15.             IPAddress address = IPAddress.Parse(txtIp.Text.Trim());
    
16.             //创建网络节点对象 包含 ip和port
    
17.             IPEndPoint endPoint = new IPEndPoint(address, int.Parse(txtPort.Text.ToString().Trim()));
    
18.             //创建 服务端监听套接字
    
19.             sokClient.Connect(endPoint);
    
20.             //创建负责接受 服务端发送来数据的 线程
    
21.             threadClient = new Thread(ReceiveMsg);
    
22.             threadClient.IsBackground = true;
    
23.             threadClient.Start();
    
24.         }
    
25.         void ReceiveMsg()
    
26.         {
    
27.             while (isRec)
    
28.             {
    
29.                 byte[] msgArr = new byte[1024 * 1024 * 2];//接受到的消息的缓冲区
    
30.                 sokClient.Receive(msgArr);
    
31.                 string strMsg = System.Text.Encoding.UTF8.GetString(msgArr);
    
32.                 ShowMsg("服务端消息：" + strMsg.ToString().Trim());
    
33.             }
    
34.         }
    
35. 
    
36.         private void btnSendNews_Click(object sender, EventArgs e)
    
37.         {
    
38.             byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(txtInput.Text.Trim());//把字符串 转换成 字节
    
39.             sokClient.Send(arrMsg);//发送信息
    
40.             ShowMsg("我说：" + txtInput.Text.Trim());
    
41.         }
    
42. 
    
43.         #region 向文本框显示消息  -void ShowMsg(string msg)
    
44.         //向文本框显示消息
    
45.         void ShowMsg(string msg)
    
46.         {
    
47.             txtShow.AppendText(msg + "\r\n");
    
48.         }
    
49.         #endregion

复制代码

二、服务端接受客户端发送的消息
        代码如下：

1. public Form1()
   
2.         {
   
3.             InitializeComponent();
   
4.             TextBox.CheckForIllegalCrossThreadCalls = false;//关闭跨线程修改控件检查
   
5.         }
   
6. 
   
7.         Socket sokWatch = null;//负责监听 客户端 连接请求的 套接字
   
8.         Thread threadWatch = null;//负责调用套接字，执行  监听请求的线程
   
9. 
   
10.         //开始监听按钮
    
11.         private void button1_Click(object sender, EventArgs e)
    
12.         {
    
13.             //实例化 套接字 （ip4寻址协议，流式传输，TCP协议）
    
14.             sokWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
15.             //创建IP对象
    
16.             IPAddress address = IPAddress.Parse(txtIp.Text.Trim());
    
17.             //创建网络节点对象 包含 ip和port
    
18.             IPEndPoint endPoint = new IPEndPoint(address, int.Parse(txtPort.Text.ToString().Trim()));
    
19.             //将 监听套接字 绑定到 对应的IP和端口
    
20.             try
    
21.             {
    
22.                 sokWatch.Bind(endPoint);
    
23.             }
    
24.             catch (Exception ex)
    
25.             {
    
26.                 ShowMsg("异常：" + ex);
    
27.                 return;
    
28.             }
    
29.             //设置 监听队列 长度为10（同时能处理10个连接请求）
    
30.             sokWatch.Listen(10);
    
31.             threadWatch = new Thread(StartWatch);
    
32.             threadWatch.IsBackground = true;
    
33.             threadWatch.Start();
    
34.             ShowMsg("启动服务成功!");
    
35.         }
    
36. 
    
37.         Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
    
38.         bool isWatch = true;
    
39.         //被线程调用 监听连接端口
    
40.         void StartWatch()
    
41.         {
    
42.             while (isWatch)
    
43.             {
    
44.                 //监听 客户端 连接请求 ，但是，它会阻断当前线程
    
45.                 Socket sokMsg = sokWatch.Accept();//监听到请求，立即创建负责与该客户端套接字通信的套接字
    
46.                 //将 通信套接字 加入 集合，并以通信套接字的远程IpPort作为键
    
47.                 dicSocket.Add(sokMsg.RemoteEndPoint.ToString(), sokMsg);
    
48.                 cboClient.Items.Add(sokMsg.RemoteEndPoint.ToString());
    
49.                 ShowMsg("接受连接成功!");
    
50.                 //启动一个新线程  用来监听客户端发送来的数据
    
51.                 Thread threadConnection = new Thread(ReciveMsg);
    
52.                 threadConnection.IsBackground = true;
    
53.                 threadConnection.Start(sokMsg);
    
54.             }
    
55.         }
    
56. 
    
57.         //发送信息  到指定的客户端
    
58.         private void btnSendNews_Click(object sender, EventArgs e)
    
59.         {
    
60.             byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(txtInput.Text.Trim());//把字符串 转换成 字节
    
61.             //从下拉框中 获得 要向哪个客户端发送消息
    
62.             string socketConnection = cboClient.Text.Trim();
    
63.             if (!string.IsNullOrEmpty(socketConnection))
    
64.             {
    
65.                 //查字典集合中根据键获得 负责与该客户端负责通信的套接字 并调用send方法发送数据过去
    
66.                 dicSocket[socketConnection].Send(arrMsg);
    
67.                 //sokMsg.Send(arrMsg);//发送信息
    
68.                 ShowMsg("我说：" + txtInput.Text.Trim());
    
69.             }
    
70.             else
    
71.             {
    
72.                 ShowMsg("消息：请选择发送消息的用户！");
    
73.             }
    
74. 
    
75.         }
    
76.         bool isRec = true;//与客户端通信的 套接字 是否 监听消息
    
77. 
    
78.         #region 接受客户端发送来的消息  -void ReciveMsg(Socket sokConnection)
    
79.         /// <summary>
    
80.         /// 接受客户端发送来的消息
    
81.         /// </summary>
    
82.         /// <param name="sokConnection">与客户端通信的套接字对象</param>
    
83.         void ReciveMsg(object sok)
    
84.         {
    
85.             Socket sokConnection = sok as Socket;
    
86.             if (sokConnection != null)
    
87.             {
    
88.                 try
    
89.                 {
    
90.                     while (isRec)
    
91.                     {
    
92.                         byte[] msgArr = new byte[1024 * 1024 * 2];//接受到的消息的缓冲区
    
93.                         int length = sokConnection.Receive(msgArr);
    
94.                         string strMsg = System.Text.Encoding.UTF8.GetString(msgArr, 0, length);
    
95.                         ShowMsg(sokConnection .RemoteEndPoint+ "的消息：" + strMsg + "\r\n");
    
96.                     }
    
97.                 }
    
98.                 catch (SocketException ex)
    
99.                 {
    
100.                     ShowMsg("异常：" + ex);
     
101.                 }
     
102.                 catch (Exception ex)
     
103.                 {
     
104.                     ShowMsg("异常：" + ex);
     
105.                 }
     
106.             }
     
107.         }
     
108.         #endregion
     
109. 
     
110.         #region 向文本框显示消息  -void ShowMsg(string msg)
     
111.         //向文本框显示消息
     
112.         void ShowMsg(string msg)
     
113.         {
     
114.             txtShow.AppendText(msg + "\r\n");
     
115.         }
     
116.         #endregion

复制代码

学习学习

{:soso_e181:}

值得学习ing!