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

程序需要先运行服务端在运行多个客户端，多个客户端可已进行通讯