socket练习

作业要求：
1、服务端可以接受多个客户端(3个以上)
2、每个客户端生成一个线程处理接受请求

环境说明：

server端运行Centos7，Python2.7

client可以是linux和win7

本程序通过sshserver.py和sshclient.py实现

sshserver.py

#!/usr/bin/env python 
#coding:utf8

import  socket
from  subprocess import PIPE,Popen
import  threading
import time
from datetime import  datetime

def getIP():
    cmd = "/sbin/ifconfig |grep 'netmask' |awk '{print $2}'|grep -v '127.0.0.1'"
    p = Popen(cmd,stdout=PIPE,stderr=PIPE,shell=True)
    stdout, stderr = p.communicate()
    return  stdout.strip()
ip = getIP()

# host = "192.168.88.100"
host = ip
port = 12345

def get_result(cmd):
    p = Popen(cmd, stdout=PIPE,stderr=PIPE, shell=True)
    stdout, stderr = p.communicate()
    stdout = stdout.strip()
    stderr = stderr.strip()
    return  stdout,stderr

def get_content(conn,content,timeNow):
    if content:
        len_size_stdout = len(content)
        conn.sendall("{0}".format(len_size_stdout))
        print("{0}: {1}".format(timeNow, content))
        conn.sendall("{0}".format(content))

def send_message(conn,addrclient):
    status = 1
    while True:
        Now = datetime.now()
        timeNow = Now.strftime("%Y-%m-%d %H:%M:%S")
        try:
            cmd = conn.recv(2048)
        except Exception as e :
            # raise  e
            print("{0} 客户端:{1}异常退出".format(timeNow,addrclient))
            break
        if len(cmd) > 0:
            status = 1
            print("{0}: {1}".format(timeNow, cmd))
            stdout,stderr = get_result(cmd)
            if stdout:
                len_size_stdout = len(stdout)
                conn.sendall("{0}".format(len_size_stdout))
                print("{0}: {1}".format(timeNow, stdout))
                conn.sendall("{0}".format(stdout))
            if stderr:
                len_size_stdout = len(stderr)
                conn.sendall("{0}".format(len_size_stdout))
                print("{0}: {1}".format(timeNow, stderr))
                conn.sendall("{0}".format(stderr))
        else:
            status += 1
            time.sleep(1)
            if status == 5:
                break
    print("{0} : {1} close socket!!!".encode('utf-8').format(timeNow,addrclient))
    conn.close()

def multil_worler(socket):
    while True:
        conn, addrclient = socket.accept()
        thread = threading.Thread(target=send_message,args=(conn,addrclient))
        print(thread.getName())
        print("线程name:{1} 连接服务器IP：{0}".format((addrclient),thread.getName()))
        thread.start()

def main():
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.bind((host, port))
    print("服务器主机host:{0},端口:{1}".format(host, port))
    sock.listen(5)
    multil_worler(sock)


if __name__ == "__main__":
    main()

　　

sshserver.py

#!/usr/bin/env python 
#coding:utf8
import socket
import time

host = "172.16.61.158"
port = 12345

def send_message(s):
    status = 1
    while True:
        cmd = raw_input("[root@zhan-01 ~]# ")
        if cmd.upper() == "EXIT":
            print("client {0},bye bye!".format(host))
            break
        elif cmd:
            s.sendall(cmd)
            print(cmd)
            # s.sendall(cmd.encode("utf-8"))
            len_size = s.recv(2048)
            num = int(len_size) / 2048
            print( int(len_size) ,2048)
            if num <1:
                data = s.recv(2048)
                print(data)
            else:
                if int(len_size) % 2048 != 0:
                    new_num  = num + 1
                new_data = ""

                while True:
                    data1 = s.recv(2048)
                    # Python3
                    # new_data  += str(data,encoding="utf8")
                    # Python2
                    new_data = new_data + data1
                    #第一次为N-1
                    new_num = new_num -1
                    time.sleep(0.5)
                    if int(new_num) == 0:
                        break
                print(new_data)
        else:
            status += 1
            time.sleep(1)
            if status == 5:
                break
    s.close()

def main():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((host, port))
    send_message(s)

if __name__ == "__main__":
    main()

　　

运行结果：

启动服务端：

启动客户端(linux和Win)：

1 Linux客户端运行：

client：

server：

——————————————————————————————————————————————————————————————

2 Win运行：

client：

server端日志：