想写个局域网聊天的程序

bleem1998

问题老是出在线程里的那个socet上
大致思路是这样：
开一个线程在后台的5001端口上监听
主线程打开5000端口，然后往“192.168.1.255:5001”这个广播地址发东西
后台收到数据就print

运行程序需要libglade和pygtk

bleem1998

哎呀
是我搞了个低级错误
发送UDP包却用TCP服务来接收
唉
问题总算解决了一部分
但是程序结束的时候还是有点问题
慢慢再说吧
下面是改后的程序

1. 
   
2. #!/usr/bin/env python
   
3. import pygtk
   
4. pygtk.require('2.0')
   
5. import gtk, gtk.glade, pango, socket, threading, time, sys
   
6. 
   
7. HOST="0.0.0.0"
   
8. SENDADD="192.168.1.255"
   
9. PORT=5000
   
10. SENDPORT=5001
    
11. 
    
12. def on_keypress(widget, event):
    
13.    if event.keyval == gtk.keysyms.Return:
    
14.        on_button1_clicked(None)
    
15.    if event.keyval == gtk.keysyms.Escape:                #may be have better way
    
16.        gtk.main_quit()
    
17. 
    
18. def on_button1_clicked(button):
    
19.    global send_socket
    
20.    tv = textv
    
21.    input_str = entry_send.get_text()
    
22.    if len(input_str) <= 0:
    
23.       return
    
24.    #get text string need send
    
25.    string = entry_name.get_text() + ': ' + input_str + '\n'
    
26.    #write to textview
    
27.    tvbuffer = tv.get_buffer()
    
28.    iter_last = tvbuffer.get_iter_at_line(tvbuffer.get_line_count())
    
29.    tvbuffer.insert(iter_last, string)
    
30.    tv.scroll_to_iter(iter_last, tv.get_left_margin(), False, 0.5, 0.5)
    
31.    #clean input entry
    
32.    entry_send.set_text('')
    
33.    #send out now!
    
34.    send_socket.sendto(string, (SENDADD, SENDPORT))
    
35. 
    
36. class Get(threading.Thread):
    
37.    def __init__(self):
    
38.       try:
    
39.          self.sock_listen = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
40.          self.sock_listen.bind((HOST, SENDPORT))
    
41.       except socket.error:
    
42.          sys.exit("bind %d port error" % SENDPORT)
    
43.       threading.Thread.__init__(self, name = "thread1")
    
44. 
    
45.    def run(self):
    
46.       while True:
    
47.          print '1'
    
48.          packet, address = self.sock_listen.recvfrom(1024)
    
49.          print '1'
    
50.          if not packet:
    
51.             break
    
52.          else:
    
53.             #add to TextView...
    
54.             print "Get:",packet
    
55. 
    
56. 
    
57. #listen thread
    
58. thread = Get()
    
59. thread.start()
    
60. 
    
61. try:
    
62.    send_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
63.    send_socket.bind((HOST, PORT))
    
64. except socket.error:
    
65.    sys.exit("bind %d port error" % SPORT)
    
66. 
    
67. xml = gtk.glade.XML('office-talk.glade')
    
68. win = xml.get_widget('window1')
    
69. button = xml.get_widget("button1")
    
70. textv = xml.get_widget('tv1')
    
71. entry_send = xml.get_widget('entry1')
    
72. entry_name = xml.get_widget('entry2')
    
73. 
    
74. win.connect('destroy', gtk.main_quit)
    
75. button.connect("clicked", on_button1_clicked)
    
76. entry_send.connect('key_press_event', on_keypress)
    
77. 
    
78. gtk.main()
    
79. 
    

复制代码

bleem1998

现在有个很棘手的问题，pygtk是怎样支持线程的？
我的主线程显示gtk界面
但是子线程需要修改一个控件的属性
好象一修改就死掉了呀
这可怎么搞
高手帮忙看看

不行了睡觉了
现在的版本是这样的
基本运行但是还有问题

1. 
   
2. #!/usr/bin/env python
   
3. import pygtk
   
4. pygtk.require('2.0')
   
5. import gtk, gtk.glade, pango, socket, threading, time, sys, time
   
6. 
   
7. HOST="0.0.0.0"
   
8. SENDADD="192.168.1.255"
   
9. PORT=5000
   
10. SENDPORT=5001
    
11. 
    
12. lock=threading.RLock()
    
13. 
    
14. def on_keypress(widget, event):
    
15.    if event.keyval == gtk.keysyms.Return:
    
16.        on_button1_clicked(None)
    
17.    if event.keyval == gtk.keysyms.Escape:                #may be have better way
    
18.        gtk.main_quit()
    
19. 
    
20. def on_button1_clicked(button):
    
21.    global send_socket
    
22.    tv = textv
    
23.    input_str = entry_send.get_text()
    
24.    if len(input_str) <= 0:
    
25.       return
    
26.    #get text string need send
    
27.    string = entry_name.get_text() + ': ' + input_str + '\n'
    
28.    #write to textview
    
29.    tvbuffer = tv.get_buffer()
    
30.    iter_last = tvbuffer.get_iter_at_line(tvbuffer.get_line_count())
    
31.    tvbuffer.insert(iter_last, string)
    
32.    tv.scroll_to_iter(iter_last, tv.get_left_margin(), False, 0.5, 0.5)
    
33.    #clean input entry
    
34.    entry_send.set_text('')
    
35.    #send out now!
    
36.    send_socket.sendto(string, (SENDADD, SENDPORT))
    
37. 
    
38. class Get(threading.Thread):
    
39.    def __init__(self):
    
40.       try:
    
41.          self.sock_listen = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
42.          self.sock_listen.bind((HOST, SENDPORT))
    
43.       except socket.error:
    
44.          sys.exit("bind %d port error" % SENDPORT)
    
45.       threading.Thread.__init__(self, name = "thread1")
    
46. 
    
47.    def run(self):
    
48.       while True:
    
49.          packet, address = self.sock_listen.recvfrom(1024)
    
50.          if (not packet) or address == SENDADD:
    
51.             break
    
52.          else:
    
53.             #add to TextView...
    
54.             print "Get:",packet
    
55.             gtk.gdk.threads_enter()
    
56.             tv = textv
    
57.             tvbuffer = tv.get_buffer()
    
58.             iter_last = tvbuffer.get_iter_at_line(tvbuffer.get_line_count())
    
59.             tvbuffer.insert(iter_last, packet)
    
60.             tv.scroll_to_iter(iter_last, tv.get_left_margin(), False, 0.5, 0.5)
    
61.             gtk.gdk.threads_leave()
    
62. 
    
63. 
    
64. #listen thread
    
65. thread = Get()
    
66. thread.start()
    
67. 
    
68. try:
    
69.    send_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
70.    send_socket.bind((HOST, PORT))
    
71. except socket.error:
    
72.    sys.exit("bind %d port error" % SPORT)
    
73. 
    
74. xml = gtk.glade.XML('office-talk.glade')
    
75. win = xml.get_widget('window1')
    
76. button = xml.get_widget("button1")
    
77. textv = xml.get_widget('tv1')
    
78. entry_send = xml.get_widget('entry1')
    
79. entry_name = xml.get_widget('entry2')
    
80. 
    
81. win.connect('destroy', gtk.main_quit)
    
82. button.connect("clicked", on_button1_clicked)
    
83. entry_send.connect('key_press_event', on_keypress)
    
84. 
    
85. gtk.gdk.threads_enter()
    
86. gtk.main()
    
87. gtk.gdk.threads_leave()
    

复制代码

[ 本帖最后由 bleem1998 于 2006-2-7 23:39 编辑 ]

limodou

在wxPython中，不能在子线程中直接执行GUI命令，可以通过wx.CallAfter来执行，它会将方法在主线程中运行，或自定义事件。

bleem1998

谢谢木头的解答
可是我不会用wxwindow
就从来没装上过
唉

s98

大哥写点注视吧，我对你的程序很感兴趣！刚学PYTHON

bleem1998

你下载这个
里面有一些注释
可以在windows和Linux下工作可以在windows和Linux下工作

Lmatrix

LZ的程序是在windows下运行的，有没有linux下运行过，我在linux下写的一个广播程序，sendto(data, (’192.168.1.255', 8000))出现socket.error: [Errno 13] Permission denied 异常。

lesii

权限不够，是不是没有x权限啊