socket編程學習-------python打造多人聊天室

 今天我們的任務是基於python打造一個多人聊天室。

聊天室的設計思想是 ：在局域網下， 利用socket進行連接通信，當服務器端啟動的時候，利用Thread線程不停的等待客戶端的鏈接；當有客戶端開啟連

接的時候，服務器端通過IO流反饋“上線用戶”信息給客戶端，客戶端也使用線程不停的接收服務器的信息，從而實現多人在線聊天功能。

1.編寫服務器端程序：

# -*-coding:utf-8-*-

#服務端

import socket
import threading

def clientThreadIn(conn,nick): 
    global data
    while True:
        try:
            temp = conn.recv(1024)#客戶端發過來的消息
            if not temp:
                conn.close()
                return
            NotifyAll(temp)
            print data

        except:
            NotifyAll(nick+'leaves the room')#出現異常就退出
            print data
            return

def clientThreadOut(conn,nick):
    global data
    while True:
        if con.acquire():
            con.wait()#堵塞，放棄對資源的占有  等待通知運行后面的代碼
            if data:
                try:
                    conn.send(data)
                    con.release()
                except:
                    con.release
                    return


def NotifyAll(ss):
    global  data
    if con.acquire():#獲取鎖
        data = ss
        con.notifyAll()#當前線程放棄對資源的占有，通知所有等待x線程
        con.release()


con = threading.Condition()#條件
Host = raw_input('input the server ip address:')# ip地址
port = 1111
data = ''


s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#創建套接字
print 'Socket created'
s.bind((Host,port)) #把套接字綁定到ip地址
s.listen(5)
print 'Socket now listening'

while True:
    conn,addr = s.accept()#接受連接
    print 'Connected with'+'' +addr[0]+':'+str(addr[1]) #字符串拼接
    nick = conn.recv(1024)#獲取用戶名
    NotifyAll('Welcome'+' '+nick+' to the room!')
    print data
    print str((threading.activeCount()+1)/2)+'person(s)'
    conn.sendall(data)
    threading.Thread(target=clientThreadIn,args=(conn,nick)).start()
    threading.Thread(target=clientThreadOut,args=(conn,nick)).start()

2.編寫客戶端程序：

# -*-coding:utf-8-*-

#socket 服務端和客戶端    服務端監聽   客戶端的請求  鏈接確認

import socket
import threading

outString = ''
inString = ''
nick = ''

#發送信息的函數
def DealOut(sock):
    global nick,outString #聲明為全局變量，進行賦值,這樣才可以生效
    while True:
        outString = raw_input() #輸入
        outString = nick+':'+outString#拼接cd
        sock.send(outString)#發送

#接收信息
def DealIn(sock):
    global inString
    while True:
        try:
            inString = sock.recv(1024)
            if not inString:
                break
            if outString != inString:
                print inString
        except:
            break



nick = raw_input('input your nickname:')#名字
ip = raw_input('input your server ip address:')#ip地址


sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#創建套接字,默認為ipv4
sock.connect((ip,1111)) #發起請求，接收的是一個元組
sock.send(nick)

#多線程  接收信息 發送信息
thin = threading.Thread(target=DealIn,args=(sock,))#調用threading 創建一個接收信息的線程'
thin.start()

thout = threading.Thread(target=DealOut,args=(sock,))#    創建一個發送信息的線程，聲明是一個元組
thout.start()

3.最后貼一張效果圖