基于进程内通讯的python聊天室实现方法

本文实例讲述了基于进程内通讯的python聊天室实现方法。分享给大家供大家参考。具体如下：

#!/usr/bin/env python
# Added by <ctang@redhat.com>
import sys
import os
from multiprocessing import connection
ADDR = ('', 9997)
AUTH_KEY = '12345'
class Server(object):
 def __init__(self, username):
   self.auth_key = AUTH_KEY
   self.addr = ADDR
   self.username = username
   self.listener = connection.Listener(self.addr, authkey=self.auth_key)
 def listen(self):
   while True:
     conn = self.listener.accept()
     while True:
       try:
         request = conn.recv()
         response = self.response(request)
         conn.send(response)
       except EOFError:
         break
     conn.close()
 def reply(self):
   message = raw_input("％s: " ％ self.username)
   return message
 def output_request(self, request):
   sys.stdout.write('％s says: ％s\n' ％ request)
 def response(self, request):
   self.output_request(request)
   response = (self.username, self.reply())
   return response
class Client(object):
 def __init__(self, username):
   self.auth_key = AUTH_KEY
   self.addr = ADDR
   self.username = username
   self.display_name = self.make_display_name(username)
 def make_display_name(self, username):
   return "％s: " ％ username
 def connect(self):
   self.conn = connection.Client(self.addr, authkey=self.auth_key)
   while True:
     message = raw_input(self.display_name)
     self.send(message)
     response = self.conn.recv()
     self.output_response(response)
 def send(self, message):
   self.conn.send((self.username, message))
 def output_response(self, response):
   sys.stdout.write('％s says: ％s\n' ％ response)
def main():
 mode = sys.argv[1]
 if mode == 'server':
   username = raw_input("Your name please: ")
   server = Server(username)
   server.listen()
 elif mode == 'client':
   username = raw_input("Your name please: ")
   client = Client(username)
   client.connect()
if __name__ == '__main__':
 main()

希望本文所述对大家的Python程序设计有所帮助。