黑马程序员技术交流社区

标题: 关于UDP同步的winform小程序，八期人少，所以来这了 [打印本页]

---

作者: qiumanlover    时间: 2013-5-28 18:19
标题: 关于UDP同步的winform小程序，八期人少，所以来这了


服务端和客户端是一样的程序，即只有一个程序，开两个，绑定不同地址，然后实现通讯。
发送消息是通过监听TextBox的KeyDown事件实现的，接收消息是放在线程里的
现在的问题是：两边的程序只能接受一次对方的消息，此后就收不到了
如果将接受消息的方法放在按键事件里，则会卡住输入框，直到收到对面的消息
源码如下：

1. using System;
   
2. using System.Text;
   
3. using System.Windows.Forms;
   
4. using System.Net.Sockets;
   
5. using System.Net;
   
6. using System.Threading;
   
7. 
   
8. namespace UDP_SYN
   
9. {
   
10.         public partial class UDPClient : Form
    
11.         {
    
12.                 private IPEndPoint localIpe = null;                                //本地节点
    
13.                 private Socket localSock = null;                                //绑定本地节点的套接字
    
14.                 private static IPEndPoint remoteIpe = null;                //远程结点
    
15.                 private EndPoint Remote = null;                                        //用于接收消息的抽象对象结点
    
16.                 private byte[] sendbuff = new byte[1024];                //发送缓冲区
    
17.                 private byte[] recvbuff = new byte[1024];                //接收缓冲区
    
18.                 private int msgLen;                                                                //接收的数据的字节长度
    
19. 
    
20.                 public UDPClient()
    
21.                 {
    
22.                         CheckForIllegalCrossThreadCalls = false;
    
23.                         InitializeComponent();
    
24.                         TextBox.CheckForIllegalCrossThreadCalls = false;        //关闭文本框的跨线程检查
    
25.                 }
    
26. 
    
27.                 private void Form1_Load(object sender, EventArgs e)
    
28.                 {
    
29.                         button1.Enabled = true;
    
30.                         txtSend.Enabled = false;
    
31.                 }
    
32. 
    
33.                 private void button1_Click(object sender, EventArgs e)
    
34.                 {
    
35.                         localIpe = new IPEndPoint(IPAddress.Parse(txtLocalIP.Text.ToString().Trim()),
    
36.                                 Convert.ToInt32(txtLocalPort.Text.ToString().Trim()));
    
37.                         localSock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
    
38.                         remoteIpe = new IPEndPoint(IPAddress.Parse(txtRemoteIP.Text.ToString().Trim()),
    
39.                                 Convert.ToInt32(txtRemotePort.Text.ToString().Trim()));
    
40. 
    
41.                         localSock.Bind(localIpe);
    
42. 
    
43.                         Thread startThrd = new Thread(new ThreadStart(RecvThrd));
    
44.                         startThrd.IsBackground = true;
    
45.                         startThrd.Start();
    
46. 
    
47.                         //处理按键之后的页面布局，阻止修改配置
    
48.                         txtSend.Enabled = true;
    
49.                         button1.Enabled = false;
    
50.                         txtLocalIP.Enabled = false;
    
51.                         txtLocalPort.Enabled = false;
    
52.                         txtRemoteIP.Enabled = false;
    
53.                         txtRemotePort.Enabled = false;
    
54.                         txtSend.Focus();
    
55. 
    
56.                 }
    
57. 
    
58.                 //按下回车键发送消息，并显示在自己的接收消息窗口
    
59.                 private void txtSend_KeyDown(object sender, KeyEventArgs e)
    
60.                 {
    
61.                         if (e.KeyCode == Keys.Enter)
    
62.                         {
    
63.                                 try
    
64.                                 {
    
65.                                         sendbuff = Encoding.ASCII.GetBytes(txtSend.Text.ToString());
    
66.                                         localSock.SendTo(sendbuff, remoteIpe);
    
67.                                         txtRecv.AppendText(localSock.LocalEndPoint.ToString() + "  " +
    
68.                                                 DateTime.Now.ToString() + "  " + remoteIpe.ToString()
    
69.                                                 + "\r\n\t" + txtSend.Text.ToString() + "\r\n");
    
70.                                         SendKeys.Send("{BackSpace}");
    
71.                                         txtSend.Clear();
    
72.                                 }
    
73.                                 catch (Exception ex)
    
74.                                 {
    
75.                                         MessageBox.Show(ex.ToString());
    
76.                                 }
    
77.                         }
    
78.                 }
    
79. 
    
80.                 //接收消息的方法，放入线程，防止阻塞当前窗口
    
81.                 private void RecvThrd()
    
82.                 {
    
83.                         Remote = (EndPoint)(remoteIpe);
    
84.                         msgLen = localSock.ReceiveFrom(recvbuff, ref Remote);
    
85.                         Remote = (EndPoint)(remoteIpe);
    
86.                         ShowMsg(Encoding.ASCII.GetString(recvbuff, 0, msgLen));
    
87. 
    
88.                 }
    
89. 
    
90.                 public void ShowMsg(string str)
    
91.                 {
    
92.                         txtRecv.AppendText(Remote.ToString() + "  " + DateTime.Now.ToString()
    
93.                                 + "  " + Remote.ToString() + "\r\n\t" + str + "\r\n");
    
94.                 }
    
95.         }
    
96. }
    

复制代码

---

作者: 陈行    时间: 2013-5-28 22:40
把接收消息在方法里加个死循环  就能不断接收消息

---

作者: qiumanlover    时间: 2013-5-29 13:46

淡.。 发表于 2013-5-28 22:40
把接收消息在方法里加个死循环  就能不断接收消息

谢谢提醒，那天灵感来了想起来的，不过后来忘了，还是谢谢你

---

作者: 崔宏奎    时间: 2013-5-30 22:39
Form1_Load里开一个线程Thread startThrd = new Thread(new ThreadStart(RecvThrd));
然后死循环
While(Listen....)
{
    Receive......
}

发送信息使用UI线程~~

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2