程序分为两部分,我将这两部分分别称作客户端和主机端.
这两个程序将分别在两台计算机上运行已达到即时通讯的效果.
由于条件限制这里博主就直接用一台计算机来模拟这个过程.
主机端代码:
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.
----------------------------------------------------这也是一条分割线---------------------------------------------------------------
成功运行示例图:
?
?
?
|