TCP编程tcp服务器客户端服务端tcp服务端发送和接收消息客户端接受和发送消息tcp服务器使用多线程接受多个客户端服务端使用多进程接收多个客户端

import socket
import time

# socket对象
clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

print('1......')

'''
连接服务器,
    如果连接上，继续运行
    连接不上，报错
'''
clientSocket.connect(('192.168.11.74',8888))

print('2......')

#关闭
clientSocket.close()

import socket
import time

# 买个手机
serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 插卡
serverSocket.bind(('', 8888))
# 由飞行模式到接听模式
serverSocket.listen(10)

print('1......')

'''
    clientAddr：连接的客户端的信息(ip,port)
'''
# 等待电话打入
newSocket, clientAddr = serverSocket.accept()
print('2......')
print(newSocket)
print(clientAddr)

# time.sleep(100)
# 关
newSocket.close()  # 关闭之后，客户端也会被关闭

serverSocket.close()  # 项目运行中服务器一直运行，不会关闭

import socket
import time

'''
serverSocket是用来接收新的客户端的
以后与这个连接的客户端的收发消息就不能用serverSocket了，
而是用返回来的新的newSocket
'''

serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)


serverSocket.bind(('', 8888))
serverSocket.listen(10)

newSocket, clientAddr = serverSocket.accept()


#发
sendData = input('>>')
newSocket.send(sendData.encode('gbk'))
#收
'''
    此时的recv会导致阻塞。
    一旦对应客户端断开了，不阻塞，并返回''的字符串
'''
recvData = newSocket.recv(1024)
print(recvData.decode('gbk'))




newSocket.close()
serverSocket.close()

import socket
import time

clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
clientSocket.connect(('192.168.11.66',8888))


#发
sendData = input('>>')
clientSocket.send(sendData.encode('gbk'))
#收
recvData = clientSocket.recv(1024)
print(recvData.decode('gbk'))

clientSocket.close()

import socket
import time
import threading


def socketState(newSocket,clientAddr):

    while True:
        recvData = newSocket.recv(1024)
        recvData = recvData.decode('gbk')
        if recvData == '':
            print('客户端%s退出了...'%clientAddr[0])
            newSocket.close()
            break
        else:
            print('来自于%s:%s的消息(%s):%s'%(clientAddr[0],clientAddr[1],time.strftime('%Y-%m-%d %H:%M:%S'),recvData))
            sendData = 'echo:%s'%recvData
            newSocket.send(sendData.encode('gbk'))


def main():
    #创建服务端socket对象
    serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    serverSocket.bind(('', 8888))
    serverSocket.listen(10)
    #循环，等待多个客户端连接
    while True:
        #等待客户端的连接，阻塞。连接后，继续运行
        newSocket, clientAddr = serverSocket.accept()


        #创建新的线程，执行与新客户端的交互
        serverThread = threading.Thread(target=socketState, args=(newSocket,clientAddr))
        serverThread.start()
        # 这里不能关闭，多线程共享数据
        #newSocket.close()


if __name__ == '__main__':
    main()

import socket
import time
import multiprocessing

def socketState(newSocket,clientAddr):

    while True:
        recvData = newSocket.recv(1024)
        recvData = recvData.decode('gbk')
        if recvData == '':
            print('客户端%s退出了...'%clientAddr[0])
            newSocket.close()
            break
        else:
            print('来自于%s:%s的消息(%s):%s'%(clientAddr[0],clientAddr[1],time.strftime('%Y-%m-%d %H:%M:%S'),recvData))
            sendData = 'echo:%s'%recvData
            newSocket.send(sendData.encode('gbk'))

def main():
    #创建服务端socket对象
    serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    serverSocket.bind(('', 8888))
    serverSocket.listen(10)
    #循环，等待多个客户端连接
    while True:
        #等待客户端的连接，阻塞。连接后，继续运行
        newSocket, clientAddr = serverSocket.accept()

        #创建新的进程，执行与新客户端的交互
        serverProcess = multiprocessing.Process(target=socketState, args=(newSocket,clientAddr))
        serverProcess.start()
        '''
            这里要关闭。
            子进程会单独分配与父进程相同的内容，地址不同(深拷贝)
       '''
        newSocket.close()


if __name__ == '__main__':
    main()