#创建主叫方(字符发送时需要编码)
import socket
import threading
#建立客户套接字
c=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
print('创建客户套接字')
c.connect(('00.00.00.00',0000))#链接对方,不成功抛出异常(自己的ip)
print('我已链接到服务')
#send发送的数据要编码 encode()编码
def myreve(c):
while True:
#1024b=1k
#3b=1字节(所以字符在300以内)
msg=c.recv(1024)#当没有消息的时候休息,阻塞
print(msg.decode())#解码
threading._start_new_thread(myreve,(c,))
while True:
msg=input()
c.send(msg.encode())#编码
#被叫方(跟主叫方差不多)
ss=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
print('建立服务套接字')
#服务套接字绑定端口号,绑定主机
print('绑定端口和主机')
ss.bind(('localhost',9999))
#建立最大链接数,超过排队
ss.listen(5)
#接受客户套接字请求
c=ss.accept()
print('某个用户链接到我了')
#线程 函数
def myreve(c):
while True:
msg=c.recv(1024)#当没有消息的时候休息,阻塞
print(msg.decode())#解码
threading._start_new_thread(myreve,(c[0],))
while True:
msg=input()
c[0].send(msg.encode())#编码