python实现NB-IoT模块远程控制
时间:2019-04-20
本文章向大家介绍python实现NB-IoT模块远程控制,主要包括python实现NB-IoT模块远程控制使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本来想尝试下如果不使用运营商网络应用平台情况下,只是在服务商服务器上是否可以实现对终端完全控制,如果这样可行,那么物联网应用服务端更有灵活性。实际情况下,很难实现和运营商网络对等的处理,用python代码原型确实能够实现参数的变化(如PSM,eDXR等),但是终端分配的IP地址毕竟属于接入网部分,更近似一个局域网,如果采用其他方式访问(如IMSI、IMEI等),还是需要与运营商核心网进行配合。以下是尝试远程控制的实现方法。
主要实现功能
1、使用python pyserial模块通过串口发送AT命令给模组进行参数修改,参考<使用python pyserial模块串口通信>;
2、通过inter网进行控制命令传输,选用UDP进行主机控制,参考<python socket网络接口编程>;
3、直接通过NB-IoT无线网络进行控制命令的传输;
4、python多窗口处理服务器端程序,实现接收和发送同时进行;
远程控制主机脚本
服务器端程序:监测UDP对应的端口号,如果接收到register信息则返回allowed,然后进入命令输入状态,等待命令输入完成,发送给终端,等待终端反馈,并接续下一个命令传送。
#!/usr/bin/python3.6 import socket import sys import re BUFFER_SIZE = 1024 TARGET_ADDR = '' TARGET_PORT = 60000 TARGET = (TARGET_ADDR,TARGET_PORT) ss = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) ss.bind(TARGET) print("server online!! wait for register!") data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: sys.exit(0) else: print(data) if(re.match(b'register',data)): ss.sendto(b'allowed',addrRsv) else: ss.sendto(b'reject',addrRsv) while True: #等待命令输入 aa = input('cmd > ') if not aa: break else: cmdV = aa+'\r' ss.sendto(cmdV.encode('utf-8'),addrRsv) #等待结果返回 data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: break else: print(data) ss.close()
客户主机程序:发送register并成功接收allowed后,等待控制命令,通过串口转发给终端模块,并接收终端模块的反馈消息,返回给服务器侧。
#!/usr/bin/python3.6 import serial import sys import os import re import socket #初始化UART端口 ser = serial.Serial("COM5",9600,timeout=30) #选择相应的协议类型UDP ss = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) BUFFER_SIZE = 1024 TARGET_ADDR = 'IP address' TARGET_PORT = 60000 TARGET = (TARGET_ADDR,TARGET_PORT) aa = '开机命令'.encode('utf-8') #convert to bytes type ser.write(aa) while True: line = ser.readline() if not line: print("can not get cmd result, release!") sys.exit(0) print(line) if ( re.match(b'OK',line) ): break ss.sendto(bytes('register','utf-8'),TARGET) data,addrRsv = ss.recvfrom(BUFFER_SIZE) if re.match(b'allowed',data): print('register successfully!') pass else: print('register failure') sys.exit(0) while True: data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: print("time out,release now!!") break elif re.match(b'end',data): print("end of process!!") break; ser.write(data) while True: line = ser.readline() if not line: print("can not get cmd result, release!") break print(line) if ( re.match(b'OK',line) ): ss.sendto(bytes('OK','utf-8'),TARGET) break elif(re.match(b'ERROR',line)): ss.sendto(bytes('ERROR','utf-8'),TARGET) break else: pass ser.close()
多线程窗口
为了使得服务器端能够实现同时实现接收和发送,可以在服务器端开启两个窗口进行监听,示例如下:
启动代码
#!/usr/bin/python3.6 import threading import time import subprocess import os import sys def thread_fun1(): #global vlock while(1): print("thread fun1 is running!!!") time.sleep(1) #... ... print(len(sys.argv)) #vlock = threading.Lock() t1 = threading.Thread(target=thread_fun1,args=()) t1.start() addr = 'IP address' port = 60000 cmdStr = "python anotherThread.py %s %d"%(addr,port) #设置creationflags = subprocess.CREATE_NEW_CONSOLE,用来创建新的控制台窗口 subprocess.Popen(cmdStr,creationflags = subprocess.CREATE_NEW_CONSOLE)
anotherThread.py
#!/usr/bin/python3.6 def thread_fun2(): while(1): aa = input('cmd > ') print("thread fun2 is running!!!") print(aa) if(aa == 'end'): break thread_fun2()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
- 面试机器学习、大数据岗位时遇到的各种问题
- 使用nginx代理跨域,使用nginx代理bing的每日一图
- Java Web基础入门
- Java中Optional使用注意事项
- 使用awk来解析dump文件 (73天)
- IntelIj IDEA运行JUnit Test OutOfMemoryError
- git pull fails “unable to resolve reference” “unable to update local ref”
- 使用dropwizard(5)--加入swagger
- 使用hint来调优sql语句(72天)
- 用R语言对城管事件数据分析
- 使用dropwizard(4)-加入测试-jacoco代码覆盖率
- goldengate学习-安装篇(71天)
- 使用dropwizard(6)-国际化-easy-i18n
- 配置不同环境下启用swagger,在生产环境关闭swagger
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 使用docker python 的最新版本以及pip 安装模块
- Java面试题总结之数据库与SQL语句
- Python脚本命令行执行隐藏密码等敏感信息
- 使用SRS Docker搭建自己的直播平台
- @陈同学的专属Python教程之快速使用
- MYSQL错误码2059解决办法
- @陈同学的专属Python教程之函数
- 微信小程序的Web API接口设计及常见接口实现
- @陈同学的专属Python教程之常见数据结构
- 用易语言写个简单的小爬虫其中的关键点
- python坐标获取经纬度或经纬度获取坐标免费模块--geopy
- 详解:小程序页面预加载优化,让你的小程序运行如飞
- RocketMQ学习六-消息存储
- swoole 实现 unixSocket 通信
- mybatis-plus一对多关联查询踩坑