python 客戶端點對點通信小案例

點對點通訊分為客戶端和服務器，多個客戶端通過服務器進行信息的交流

服務器端代碼  service端

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import SocketServer
import subprocess

##  代號 地址和端口 連接對象
class myconn(object):   ##存放連接
    listconn = {}  ##  地址端口  連接對象
    # codeflage = {}  ##  代號   地址端號


class MyServer(SocketServer.BaseRequestHandler):

    def setup(self):
        myconn.listconn[self.client_address] = self.request
        pass

    def handle(self):
        print("got connection from",self.client_address)
        while True:
            conn = self.request
            data = conn.recv(1024)
            if not data:
                break
            print data

            #如果目標客戶端在發送數據給目標客服端
            # 這里可以根據對方的ip和端口號來查找 我這里直接發給每一個用戶了
            print len(myconn.listconn)
            if len(myconn.listconn) > 1:
                for i in myconn.listconn.keys():
                    if self.client_address != i:
                        myconn.listconn[i].sendall(data)
                pass
            else: ##不再      則發送數據給客戶端
                conn.sendall(data)
                pass
            conn.sendall(data)

    def finish(self):
        del myconn.listconn[self.client_address]
        pass
    pass

if __name__ == '__main__':
    server = SocketServer.ThreadingTCPServer(('localhost',8022),MyServer)
    print 'waiting for connection...'
    server.serve_forever()

客戶端代碼

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


from socket import *
import threading

HOST = 'localhost'  ##
PORT=8022
BUFSIZ = 1024  ##緩沖區大小  1K
ADDR = (HOST,PORT)

tcpCliSock = socket(AF_INET,SOCK_STREAM)
tcpCliSock.connect(ADDR)


class inputdata(threading.Thread):
    def run(self):
        while True:
            data = raw_input('> ')
            tcpCliSock.send(data)
        pass


class getdata(threading.Thread):
    def run(self):
        while True:
            data = tcpCliSock.recv(BUFSIZ)
            print data
    pass


def main():
    myinputd = inputdata()
    mygetdata = getdata()
    myinputd.start()
    mygetdata.start()
    myinputd.join()
    mygetdata.join()


if __name__ == '__main__':
    main()

程序需要先運行服務端在運行多個客戶端，多個客戶端可已進行通訊