Chinaunix

标题: 想写个局域网聊天的程序 [打印本页]
作者: bleem1998    时间: 2006-02-07 22:16
标题: 想写个局域网聊天的程序
问题老是出在线程里的那个socet上
大致思路是这样：
开一个线程在后台的5001端口上监听
主线程打开5000端口，然后往“192.168.1.255:5001”这个广播地址发东西
后台收到数据就print

运行程序需要libglade和pygtk

gogogo.zip

2.65 KB, 下载次数: 109

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

  2. #!/usr/bin/env python
  3. import pygtk
  4. pygtk.require('2.0')
  5. import gtk, gtk.glade, pango, socket, threading, time, sys

  7. HOST="0.0.0.0"
  8. SENDADD="192.168.1.255"
  9. PORT=5000
  10. SENDPORT=5001

  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()

  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))

  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")

  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


  57. #listen thread
  58. thread = Get()
  59. thread.start()

  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)

  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')

  74. win.connect('destroy', gtk.main_quit)
  75. button.connect("clicked", on_button1_clicked)
  76. entry_send.connect('key_press_event', on_keypress)

  78. gtk.main()

复制代码
作者: bleem1998    时间: 2006-02-07 23:15
现在有个很棘手的问题，pygtk是怎样支持线程的？
我的主线程显示gtk界面
但是子线程需要修改一个控件的属性
好象一修改就死掉了呀
这可怎么搞
高手帮忙看看

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

  2. #!/usr/bin/env python
  3. import pygtk
  4. pygtk.require('2.0')
  5. import gtk, gtk.glade, pango, socket, threading, time, sys, time

  7. HOST="0.0.0.0"
  8. SENDADD="192.168.1.255"
  9. PORT=5000
  10. SENDPORT=5001

  12. lock=threading.RLock()

  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()

  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))

  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")

  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()


  64. #listen thread
  65. thread = Get()
  66. thread.start()

  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)

  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')

  81. win.connect('destroy', gtk.main_quit)
  82. button.connect("clicked", on_button1_clicked)
  83. entry_send.connect('key_press_event', on_keypress)

  85. gtk.gdk.threads_enter()
  86. gtk.main()
  87. gtk.gdk.threads_leave()
复制代码

[ 本帖最后由 bleem1998 于 2006-2-7 23:39 编辑 ]
作者: limodou    时间: 2006-02-08 00:26
在wxPython中，不能在子线程中直接执行GUI命令，可以通过wx.CallAfter来执行，它会将方法在主线程中运行，或自定义事件。
作者: bleem1998    时间: 2006-02-08 13:35
谢谢木头的解答
可是我不会用wxwindow
就从来没装上过
唉
作者: s98    时间: 2006-02-12 01:49
大哥写点注视吧，我对你的程序很感兴趣！刚学PYTHON
作者: bleem1998    时间: 2006-02-12 02:25
你下载这个
里面有一些注释
可以在windows和Linux下工作可以在windows和Linux下工作

123.zip

3.23 KB, 下载次数: 185

code
作者: Lmatrix    时间: 2009-11-28 09:54
标题: 出现异常
LZ的程序是在windows下运行的，有没有linux下运行过，我在linux下写的一个广播程序，sendto(data, (’192.168.1.255', 8000))出现socket.error: [Errno 13] Permission denied 异常。
作者: lesii    时间: 2009-11-28 19:49
标题: 回复 #8 Lmatrix 的帖子
权限不够，是不是没有x权限啊



欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2