Skip to main content

Socket通讯

前言

上一节我们学习了如何通过MicroPython编程实现CanMV K230连接到无线路由器。这一节我们则来学习一下Socket通信实验。Socket几乎是整个互联网通信的基础。

实验目的

通过Socket编程实现CanMV K230与电脑服务器助手建立连接,相互收发数据。

实验讲解

Socket我们听得非常多了,但由于网络工程是一门系统工程,涉及的知识非常广,概念也很多,任何一个知识点都能找出一堆厚厚的的书,因此我们经常会混淆。在这里,我们尝试以最容易理解的方式来讲述Socket,如果需要全面了解,可以自行查阅相关资料学习。

我们先来看看网络层级模型图,这是构成网络通信的基础:

socket1

我们看看TCP/IP模型的传输层和应用层,传输层比较熟悉的概念是TCP和UDP,UPD协议基本就没有对IP层的数据进行任何的处理了。而TCP协议还加入了更加复杂的传输控制,比如滑动的数据发送窗口(Slice Window),以及接收确认和重发机制,以达到数据的可靠传送。应用层中网页常用的则是HTTP。那么我们先来解析一下这TCP和HTTP两者的关系。

我们知道网络通信是最基础是依赖于IP和端口的,HTTP一般情况下默认使用端口80。举个简单的例子:我们逛淘宝,浏览器会向淘宝网的网址(本质是IP)和端口发起请求,而淘宝网收到请求后响应,向我们手机返回相关网页数据信息,实现了网页交互的过程。而这里就会引出一个多人连接的问题,很多人访问淘宝网,实际上接收到网页信息后就断开连接,否则淘宝网的服务器是无法支撑这么多人长时间的连接的,哪怕能支持,也非常占资源。

也就是应用层的HTTP通过传输层进行数据通信时,TCP会遇到同时为多个应用程序进程提供并发服务的问题。多个TCP连接或多个应用程序进程可能需要通过同一个 TCP协议端口传输数据。为了区别不同的应用程序进程和连接,许多计算机操作系统为应用程序与TCP/IP协议交互提供了套接字(Socket)接口。应用层可以和传输层通过Socket接口,区分来自不同应用程序进程或网络连接的通信,实现数据传输的并发服务。

简单来说,Socket抽象层介于传输层和应用层之间,跟TCP/IP并没有必然的联系。Socket编程接口在设计的时候,就希望也能适应其他的网络协议。

socket2

套接字(socket)是通信的基石,是支持TCP/IP协议的网络通信的基本操作单元。它是网络通信过程中端点的抽象表示,包含进行网络通信必须的五种信息:连接使用的协议(通常是TCP或UDP),本地主机的IP地址,本地进程的协议端口,远地主机的IP地址,远地进程的协议端口。

所以,socket的出现只是可以更方便的使用TCP/IP协议栈而已,简单理解就是其对TCP/IP进行了抽象,形成了几个最基本的函数接口。比如create,listen,accept,connect,read和write等等。以下是通讯流程:

socket3

从上图可以看到,建了Socket通信需要一个服务器端和一个客户端,以本实验为例,CanMV K230作为客户端,电脑使用网络调试助手作为服务器端,双方使用TCP协议传输。对于客户端,则需要知道电脑端的IP和端口即可建立连接。(端口可以自定义,范围在0~65535,注意不占用常用的80等端口即可。)

以上的内容,简单来说就是如果用户面向应用来说,那么CanMV K230只需要知道通讯协议是TCP或UDP、服务器的IP和端口号这3个信息,即可向服务器发起连接和发送信息。就这么简单。

MicroPython已经封装好相关模块socket,对象如下介绍:

socket对象

构造函数

s=usocket.socekt(af=AF_INET, type=SOCK_STREAM,proto=IPPROTO_TCP)

构建socket对象。

  • af: IPV类型

    • AF_INET: IPV4;
    • AF_INET6: IPV6;
  • type:

    • SCOK_STREAM: TCP;
    • SOCK_DGRAM: UDP;
  • proto:

    • IPPROTO_TCP: TCP协议;
    • IPPROTO_UDP: UDP协议;

(如果要构建TCP连接,可以使用默认参数配置,即不输入任何参数。)

使用方法

address=socket.getaddrinfo('www.01studio.cc', 80)[0][-1]

address=socket.getaddrinfo('127.0.0.1', 80)[0][-1]

获取Socket通信格式地址。


s.connect(address)

创建连接。

  • address :地址务必由上面 getaddrinfo 函数返回。

s.send(bytes)

发送数据。

  • bytes:发送内容格式为字节。

s.recv(bufsize)

接收数据。

  • bufsize:单次最大接收字节个数。

s.bind(address)

绑定,用于服务器角色。


s.listen([backlog])

监听,用于服务器角色。

  • backlog: 允许连接个数,必须大于0。

s.accept()

接受连接,用于服务器角色。


更多用法请阅读官方文档:
https://developer.canaan-creative.com/canmv/main/canmv/library/micropython/usocket.html#socket

本实验中CanMV K230属于客户端,因此只用到客户端的函数即可。实验代码编写流程如下:

参考代码

'''
实验名称:Socket通讯
实验平台:01Studio CanMV K230
说明:通过Socket编程实现CanMV K230与电脑服务器助手建立TCP连接,相互收发数据。
'''

#导入相关模块
import network,socket,time
from machine import Pin,Timer

#WIFI连接函数
def WIFI_Connect():

WIFI_LED=Pin(52, Pin.OUT) #初始化WIFI指示灯

wlan = network.WLAN(network.STA_IF) #STA模式
wlan.active(True) #激活接口
start_time=time.time() #记录时间做超时判断

if not wlan.isconnected():

print('connecting to network...')

#输入WIFI账号密码(仅支持2.4G信号), 连接超过10秒为超时
wlan.connect('01Studio', '88888888')

if wlan.isconnected(): #连接成功

#LED蓝灯点亮
WIFI_LED.value(1)

#串口打印信息
print('network information:', wlan.ifconfig())

return True

else: #连接失败

#LED闪烁3次提示
for i in range(3):
WIFI_LED.value(1)
time.sleep_ms(300)
WIFI_LED.value(0)
time.sleep_ms(300)

wlan.active(False)

return False

#判断WIFI是否连接成功
if WIFI_Connect(): #连接成功

#创建socket连接TCP类似,连接成功后发送“Hello 01Studio!”给服务器。
s=socket.socket()
addr=socket.getaddrinfo('192.168.1.115',10000)[0][-1] #服务器IP和端口
print(addr)
s.connect(addr)
s.send('Hello 01Studio!')

while True:

text=s.recv(128) #单次最多接收128字节
if text == '':
pass

else: #打印接收到的信息为字节,可以通过decode('utf-8')转成字符串
print(text)
s.send('I got:'+text.decode('utf-8'))

time.sleep_ms(300)

WIFI连接代码在上一节已经讲解,这里不再重复,程序在连接成功后建了Socket连接,连接成功发送‘Hello 01Studio!’信息到服务器。另外K230定时器设定了了每100ms处理从服务器接收到的数据。将接收到数据通过串口打印和重新发送给服务器。

实验结果

保证电脑和CanMV k230在同一个网段下(通常是指连接在同一个路由器),同时最好关闭电脑防火墙。

在电脑端打开网络调试助手并建立服务器,软件在 零一科技(01Studio)MicroPython开发套件配套资料\01-开发工具\01-Windows\网络调试助手 下的 NetAssist.exe ,直接双击打开即可!

电脑打开网络调试助手:

socket4

以下是新建服务器的方法,打开网络调试助手后在左上角协议类型选择 TCP Server;中间的本地IP地址是自动识别的,不要修改,这个就是服务器的IP地址。然后端口写10000(0-65535都可以。),点击连接,成功后红点亮。如下图:

socket5

这时候服务器已经在监听状态!用户需要根据自己的实际情况自己输入WIFI信息和服务器IP地址+端口。即修改上面的代码以下部分内容。(服务器IP和端口可以在网络调试助手找到。)

# WiFi信息,输入WIFI账号密码(仅支持2.4G信号), 连接超过10秒为超时
wlan.connect('01Studio', '88888888')
addr=socket.getaddrinfo('192.168.1.115',10000)[0][-1] #服务器IP和端口

运行程序,开发板成功连接WIFI后,发起了socket连接,连接成功可以可以看到网络调试助手收到了开发板发来的信息。在下方列表多了一个连接对象,点击选中:

socket6

选中后我们在发送框输入信息“http://www.01studio.org”,点击发送,可以看到开发板的串行终端打印出来该信息,类型为字节数据。

socket

通过本节学习,我们了解了socket通信原理以及使用MicroPython进行socket编程并且通信的实验。得益于优秀的封装,让我们可以直接面向socket对象编程就可以快速实现socket通信,从而开发更多的网络应用,例如将前面采集到的传感器数据发送到服务器。