当前位置： 移动技术网 > IT编程>脚本编程>Python > python使用多线程编写tcp客户端程序

python使用多线程编写tcp客户端程序

2019年09月06日  | 移动技术网IT编程  | 我要评论

谁与何炅微博互动大玩同年囧照,卢中南,机甲战士下载

今天在网上找了半天，发现很多关于此题目的程序都只能接收数据，所以随便找了个程序研究了一下，然后做出一些修改

代码如下：

from socket import *
import threading
tcp_socket = socket(af_inet, sock_stream)
tcp_socket.connect(('192.168.1.102', 8080))
true = true


def rece_msg(tcp_socket):
 global true
 while true:
  recv_msg = tcp_socket.recv(1024).decode("utf8")
  if recv_msg == "exit":
   true = false
  print('接收到的信息为：%s' % recv_msg)


def send_msg(tcp_socket):
 global true
 while true:
  send_msg = input('请输入要发送的内容')
  tcp_socket.send(send_msg.encode('utf-8'))
  if send_msg == "exit":
   true = false


def main():
 while true:
  print('*'*50)
  print('1 发送消息\n2 接收消息')
  option = int(input('请选择操作内容'))
  print('*'*50)
  if option == 1:
   threading.thread(target=send_msg, args=(tcp_socket,)).start()
  elif option == 2:
   threading.thread(target=rece_msg, args=(tcp_socket,)).start()
  else:
   print('输入有误')
  break


if __name__ == '__main__':
 main()

该代码只能实现要么一直发送，要么一直接收

运行如图

发送数据时截图

 

接收数据时截图

 

为解决只能单方发送和接收问题，现将代码修改如下

from socket import *
import threading
tcp_socket = socket(af_inet, sock_stream)
tcp_socket.connect(('192.168.1.102', 8080))
true = true


def rece_msg(tcp_socket):
 global true
 while true:
  recv_msg = tcp_socket.recv(1024).decode("utf8")
  if recv_msg == "exit":
   true = false
  print('接收到的信息为：%s\n' % recv_msg)


def send_msg(tcp_socket):
 global true
 while true:
  send_msg = input('请输入要发送的内容\n')
  tcp_socket.send(send_msg.encode('utf-8'))
  if send_msg == "exit":
   true = false


threading.thread(target=send_msg, args=(tcp_socket,)).start()
threading.thread(target=rece_msg, args=(tcp_socket,)).start()

运行结果

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网