树莓派与PC端在局域网内运用python实现即时通讯_Python

树莓派与PC端在局域网内运用python实现即时通讯

2021-07-18 14:58XC2439 Python

这篇文章主要为大家详细介绍了树莓派与PC端在局域网内运用python实现即时通讯，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

电脑和树莓派在同一局域网内，先在电脑和树莓派创建python运行环境，然后在树莓派中用python运行rpi.py；在电脑上运行computer.py；电脑上输入字符即可在树莓派上即时显示！

rpi.py

				?

									#coding:utf-8

									#import necessary package

									import socket

									import time

									import sys

									host_ip = "192.168.31.151" #树莓派的ip地址

									host_port = 8888

									print("starting socket: tcp...")

									#1.create socket object:socket=socket.socket(family,type)

									socket_tcp = socket.socket(socket.af_inet, socket.sock_stream)

									print("tcp server listen @ %s:%d!" %(host_ip, host_port) )

									host_addr = (host_ip, host_port)

									#2.bind socket to addr:socket.bind(address)

									socket_tcp.bind(host_addr)

									#3.listen connection request:socket.listen(backlog)

									socket_tcp.listen(1)

									#4.waite for client:connection,address=socket.accept()

									socket_con, (client_ip, client_port) = socket_tcp.accept()

									print("connection accepted from %s." %client_ip)

									socket_con.send("welcome to rpi tcp server!")

									print("receiving package...")

									###主循环

									while true:

									 try:

									  data=socket_con.recv(512)

									  if len(data)>0:

									   print("received:%s"%data)

									   socket_con.send(data)

									   time.sleep(1)

									   continue

									 except exception:

									   socket_tcp.close()

									   sys.exit(1)

computer.py

				?

									import socket

									import time

									import sys

									server_ip = "192.168.31.151" #树莓派的ip地址

									server_port = 8888

									print("starting socket: tcp...")

									server_addr = (server_ip, server_port)

									socket_tcp = socket.socket(socket.af_inet, socket.sock_stream)

									while true:

									 try:

									  print("connecting to server @ %s:%d..." %(server_ip, server_port))

									  socket_tcp.connect(server_addr)

									  break

									 except exception:

									  print("can't connect to server,try it latter!")

									  time.sleep(1)

									  continue

									print("please input:")

									while true:

									 try:

									  data = socket_tcp.recv(512)

									  if len(data)>0:

									   print("received: %s" % data)

									   command=raw_input()

									   socket_tcp.send(command)

									   time.sleep(1)

									   continue

									 except exception:

									  socket_tcp.close()

									  socket_tcp=none

									  sys.exit(1)