程序分为两部分,我将这两部分分别称作客户端和主机端.
这两个程序将分别在两台计算机上运行已达到即时通讯的效果.
由于条件限制这里博主就直接用一台计算机来模拟这个过程.
主机端代码:import socket import threading import time s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) s.connect(('127.0.0.1',8888))#建立与服务器的链接. s.send('客户端申请连接服务器'.encode('utf-8'))#发送信息 def tcplink( ): #信息接受线程 print('请求链接主机') # sock.send('Wekcome!'.encode('utf-8')) while True: data = s.recv(1024) print("收到信息:n",data.decode('utf-8')) # time.sleep(1) if data.decode('utf-8')=='exit': break s.close() print("连接已关闭") def give(): while True: x = input("请输入回复:n") s.send(x.encode('utf-8')) t=threading.Thread(target=tcplink) #信息接受线程. pr=threading.Thread(target=give)#信息发送线程. t.start() time.sleep(1) pr.start()客户端代码:
import socket import threading import time s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) s.connect(('127.0.0.1',8888))#建立与服务器的链接. s.send('客户端申请连接服务器'.encode('utf-8'))#发送信息 def tcplink( ): #信息接受线程 print('请求链接主机') while True: data = s.recv(1024) print("收到信息:n",data.decode('utf-8')) # time.sleep(1) if data.decode('utf-8')=='exit': break s.close() print("连接已关闭") def give(): while True: x = input("请输入回复:n") s.send(x.encode('utf-8')) t=threading.Thread(target=tcplink) #信息接受线程. pr=threading.Thread(target=give)#信息发送线程. t.start() time.sleep(1) pr.start()
--------------------------------------------------这是一条分割线------------------------------------------------------------
**需要注意的是,当两个程序开始运行模拟通信过程时需要先启动主机端,其后启动客户端.不然会显示该计算机拒绝联接.如下:
**其次因为受条件限制该模拟过程只使用一台计算机运行两个程序,因此在
客户端和主机端确定链接对象ip的函数中使用172.0.0.1这个ip,定义为链接计算机本身.
另外需要注意的是客户端和主机端的端口号填写要相同,且要确定该端口号在此之前无程序占用.
一般来说端口号小于3000的端口可有有程序占用,所以稳健行事在这里来的代码中将端口号填写为8888.
----------------------------------------------------这也是一条分割线---------------------------------------------------------------
成功运行示例图:
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)