JerryZhen

  • 2024-06-30
  • 加入了学习《【DigiKey创意大赛】多通道微型气相色谱采集单元》,观看 多通道微型气相色谱采集单元

  • 2024-06-05
  • 发表了主题帖: 【米尔-全志 T527 开发板-试用评测】第五篇 项目后记

    在项目开发过程中,有几个有意思的小知识点分享给大家:   1,如何在米尔原生的安卓系统中编译python第三方库? 本项目采用的是termux,可以在安卓系统中模拟linux环境。如果是纯python库,只需要使用pip安装即可。但是python很多高性能库使用的是rust编写的,比如pydantic, orjson之类的,而termux默认的是使用clang编译器,需要特殊设置。 本项目使用fastapi作为网络框架,它依赖了一堆rust写的库,在安装时需要需设置rust环境,运行: pkg install rust   pkg install binutils 编译库的时候要花点时间,耐心等待。   2. 软件框架fastapi+celery+redis 在使用 FastAPI编写后端的过程中,数据采集任务可以使用 Celery 通过消息任务队列的方式进行异步实现,从而提升应用的整体性能。采集和显示是两个异步任务。采集任务采集到的结果放到redis中,页面请求数据去redis中读取,这样显示和采集解耦,提升了响应速度。   3. 性能升级 尽管我们通过软件框架其实已经可以保证了产品的性能,但是如果想要更高的性能,可以考虑使用golang或者C语言这些静态语言来实现,不过这样开发效率可能会稍微慢些。个人认为在国产芯崛起,硬件越来越便宜的情况下,开发速度至关重要,pyhon的生态注定它的开发效率实在是太逆天了,另外有个开源的工业网关thingsboard gateway就是用python实现,在绝大多数的应用场景下绰绰有余。   最后祝米尔和全志的板卡大卖,后续能提供更多物美价廉的开发板。    

  • 2024-06-04
  • 发表了主题帖: 【米尔-全志 T527 开发板-试用评测】第四篇 楼控网关展示平台

    本帖最后由 JerryZhen 于 2024-6-5 14:17 编辑 最近一直在忙着设计楼控网关的展示箱,用于展会宣传,现在不同以往,好酒也怕巷子深,卖点宣传很重要。从设计到硬件到软件等一系列工作,其实很繁琐的,经过一个月的奋战,现在已经基本完工,先上张图和视频,展示下效果。     [localvideo]f8042271f3c205391deb54aecec5bd13[/localvideo]   项目硬件部分设计思路如下,T527作为数据采集网关,显示部分通过HDMI接显示屏,数据采集部分通过bacnet协议读取楼控DDC设备中的逻辑点位信息,进而将网络中的设备状态在屏幕上进行可视化。项目的原理图如下。可以看到,我们是通过DDC控制两个电机,两个led灯,以及两个温湿度传感器。主控T527会每秒去采集一次DDC中的点位信息,然后将采集到的数据可视化到屏幕上。   项目的软件部分:软件的核心就是数据采集,具体代码如下: import BAC0 from app.services.cache import redis_client points = { "led1": { "read":'192.168.20.51:47808 binaryOutput 501 presentValue', "default":"inactive", }, "led2":{ "read": '192.168.20.51:47808 binaryOutput 502 presentValue', "default":"inactive", }, "motor1": { "read": '192.168.20.108:47808 binaryOutput 501 presentValue', "default":"inactive", }, "motor2": { "read": '192.168.20.108:47808 binaryOutput 502 presentValue', "default":"inactive", } , "temperature": { "read": '192.168.20.108:47808 analogInput 301 presentValue', "default": "0.0" }, "humidity": { "read": '192.168.20.108:47808 analogInput 302 presentValue', "default": "0.0" }, # "switch1": '192.168.20.51:47808 binaryInput 201 presentValue', # "switch2": '192.168.20.51:47808 binaryInput 202 presentValue', # "switch3": '192.168.20.108:47808 binaryInput 201 presentValue', # "switch4": '192.168.20.108:47808 binaryInput 202 presentValue', } class BacnetClient: def __init__(self, host:str): self.conn = BAC0.connect(host) def close(self): self.conn.disconnect() def read_points(self): for point, pointinfo in points.items(): try: point_value = self.conn.read(pointinfo["read"]) if point in ["temperature", "humidity"]: point_value = '%.1f'%point_value redis_client.set(point, point_value) except Exception as e: print("read error", e) bacnet_client = BacnetClient("192.168.20.65/24") if __name__ == "__main__": ret = bacnet_client.read_points() print(ret) bacnet_client.close()   总结:米尔-全志 T527,配备八核A55高性能处理器,RISC-V协处理器,支持2Tops NPU,拥有丰富的通讯接口,功能强大。非常适合工控行业,本次采用米尔的这款板卡用于原型设计,由于米尔配套的资料齐全,大大缩短了项目周期,为米尔和全志芯点赞。  

  • 2024-04-27
  • 发表了主题帖: 【米尔-全志 T527 开发板-试用评测】-第三篇 网关方案

    本帖最后由 JerryZhen 于 2024-4-27 20:17 编辑 一、系统概述 基于米尔-全志 T527设计一个简易的物联网网关,该网关能够管理多台MQTT设备,通过MQTT协议对设备进行读写操作,同时提供HTTP接口,允许用户通过HTTP协议与网关进行交互,并对设备进行读写操作。   二、系统架构 网关服务:基于FastAPI框架构建的Web服务,提供HTTP接口。 MQTT客户端:负责与MQTT设备通信,管理设备连接、消息发布和订阅。 设备管理:维护一个设备列表,记录设备的基本信息和状态。 数据存储:使用内存或数据库存储设备数据,确保数据持久化。 三、组件设计 MQTT组件: 负责与MQTT broker建立连接。 订阅设备主题,接收设备发送的消息。 发布消息到设备,实现远程控制。 设备管理组件: 维护一个设备列表,记录设备的唯一标识符(如设备ID)、MQTT主题、连接状态等信息。 提供设备增删改查的方法。 HTTP组件: 基于FastAPI定义HTTP接口。 接收用户请求,调用MQTT组件和设备管理组件进行相应操作。 返回操作结果给用户。 四、接口设计 设备列表: GET /devices:返回所有设备的列表。 POST /devices:添加新设备到网关。 DELETE /devices/{device_id}:从网关中删除指定设备。 设备详情: GET /devices/{device_id}:返回指定设备的详细信息。 设备数据: GET /devices/{device_id}/data:获取指定设备的最新数据。 POST /devices/{device_id}/data:发送数据到指定设备。 设备控制: POST /devices/{device_id}/control:发送控制命令到指定设备。 五、数据结构设计 设备信息: 设备ID (device_id):唯一标识设备的字符串。 MQTT主题 (mqtt_topic):设备在MQTT broker上的主题。 连接状态 (connection_status):表示设备是否在线的布尔值。 其他设备属性(如名称、描述等)。 设备数据: 设备ID (device_id):关联设备信息的设备ID。 时间戳 (timestamp):数据发送或接收的时间。 数据内容 (data):设备发送或接收的具体数据,可以是JSON格式或其他格式。 六、安全性考虑 使用HTTPS协议提供安全的HTTP通信。 实现用户认证和授权机制,确保只有授权用户可以访问和操作设备。 对于敏感操作(如删除设备),要求用户进行二次确认或提供额外的安全措施。 七、部署与扩展 使用Docker容器化部署网关服务,便于管理和扩展。 根据需要,可以水平扩展网关实例以处理更多的设备连接和请求。 八、实现步骤 安装所需的Python库:fastapi, uvicorn, paho-mqtt等。 创建FastAPI应用并定义路由。 实现MQTT组件,包括与MQTT broker的连接、订阅、发布等功能。 实现设备管理组件,维护设备列表并提供增删改查的方法。 实现HTTP组件,调用MQTT组件和设备管理组件处理用户请求。 编写测试代码,验证网关的各项功能是否正常工作。 部署网关服务并监控其运行状态。 该设计方案仅仅是概述,具体实现细节可能需要根据实际需求和项目环境进行调整和优化。在实际开发中,还需要考虑异常处理、日志记录、性能优化等方面的问题。基于上述设计方案,以下是一个简化版的参考代码,展示了如何使用FastAPI和paho-mqtt库来创建一个物联网网关。需要注意,示例中不包含完整的错误处理、用户认证和授权机制,这些在实际生产环境中都是必不可少的。依赖的主要库版本: fastapi==0.108.0 paho-mqtt==1.6.1   网关模拟代码gateway.py: from fastapi import FastAPI, HTTPException, Body, status from paho.mqtt.client import Client as MQTTClient from typing import List, Dict, Any import asyncio import json app = FastAPI() mqtt_client = None device_data = {} subtopic="gateway/device/#" # MQTT回调函数 def on_message(client, userdata, msg): payload = msg.payload.decode() topic = msg.topic device_id = topic.split('/')[-1] device_data[device_id] = payload print(f"Received message from {device_id}: {payload}") # MQTT连接和订阅 def mqtt_connect_and_subscribe(broker_url, broker_port): global mqtt_client mqtt_client = MQTTClient() mqtt_client.on_message = on_message mqtt_client.connect(broker_url, broker_port, 60) mqtt_client.subscribe(subtopic) mqtt_client.loop_start() # MQTT发布消息 async def mqtt_publish(topic: str, message: str): if mqtt_client is not None and mqtt_client.is_connected(): mqtt_client.publish(topic, message) else: print("MQTT client is not connected!") # 设备管理:添加设备 @app.post("/devices/", status_code=status.HTTP_201_CREATED) async def add_device(device_id: str): device_data[device_id] = None return {"message": f"Device {device_id} added"} # 设备管理:获取设备列表 @app.get("/devices/") async def get_devices(): return list(device_data.keys()) # 设备管理:获取设备数据 @app.get("/devices/{device_id}/data") async def get_device_data(device_id: str): if device_id not in device_data: raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=f"Device {device_id} not found") return device_data.get(device_id) # 设备管理:发送数据到设备 @app.post("/devices/{device_id}/data") async def send_data_to_device(device_id: str, data: Dict[str, Any] = Body(...)): topic = f"devices/{device_id}" message = json.dumps(data) await mqtt_publish(topic, message) return {"message": f"Data sent to {device_id}"} # 设备控制:发送控制命令到设备 @app.post("/devices/{device_id}/control") async def control_device(device_id: str, command: str): topic = f"devices/device/{device_id}" await mqtt_publish(topic, command) return {"message": f"Control command sent to {device_id}"} # FastAPI启动事件 @app.on_event("startup") async def startup_event(): mqtt_connect_and_subscribe("127.0.0.1", 1883) # FastAPI关闭事件 @app.on_event("shutdown") async def shutdown_event(): if mqtt_client is not None: mqtt_client.loop_stop() mqtt_client.disconnect() # 运行FastAPI应用 if __name__ == "__main__": import uvicorn uvicorn.run(app, host="127.0.0.1", port=8000)   设备1模拟代码 dev1.py: import paho.mqtt.client as mqtt # 连接成功回调 def on_connect(client, userdata, flags, rc): print('Connected with result code '+str(rc)) client.subscribe('devices/1') # 消息接收回调 def on_message(client, userdata, msg): print(msg.topic+" "+str(msg.payload)) client.publish('gateway/device/1',payload=f'echo {msg.payload}',qos=0) client = mqtt.Client() # 指定回调函数 client.on_connect = on_connect client.on_message = on_message # 建立连接 client.connect('127.0.0.1', 1883) # 发布消息 client.publish('gateway/device/1',payload='Hello, I am device',qos=0) client.loop_forever()   设备2模拟代码 dev2.py import paho.mqtt.client as mqtt # 连接成功回调 def on_connect(client, userdata, flags, rc): print('Connected with result code '+str(rc)) client.subscribe('devices/2') # 消息接收回调 def on_message(client, userdata, msg): print(msg.topic+" "+str(msg.payload)) client.publish('gateway/device/2',payload=f'echo {msg.payload}',qos=0) client = mqtt.Client() # 指定回调函数 client.on_connect = on_connect client.on_message = on_message # 建立连接 client.connect('127.0.0.1', 1883) # 发布消息 client.publish('gateway/device/2',payload='Hello, I am device',qos=0) client.loop_forever()   运行网关代码,打开网页得到api接口:  通过api分别添加设备1和设备2,     在另外两个控制台中分别运行模拟设备1和模拟设备2的代码 通过网页API向设备1发送数据   通过网页API获得设备回复的数据,设备代码中只是简单的把网关发过来的数据进行回传   我们在网关的后台可以看到完整的数据流   至此一个简易的网关已经实现了,接下来将会尝试实现楼宇里的最常见的bacnet设备进行通讯管理。  

  • 2024-03-24
  • 发表了主题帖: 【米尔-全志 T527 开发板-试用评测】-第二篇 网关协议管理功能的实现

    在第一篇中在米尔T527开发板自带的安卓系统上搭建了linux开发环境,并测试了mqtt协议。本篇我们进一步实现一个简易的协议管理器,这对于边缘网关来说很重要。因为在边缘网关中通常需要处理各种常见的物联网通讯协议,一个优秀的协议管理器对项目成败至关重要。因为用来做产品原型测试,所以我们继续用python作为开发语言,原因无他,主要是因为生态好,库多,上手快。为了简单起见,接下来我们主要展示如何同时管理socket 和 MQTT,并根据不同的协议进行数据的收发。   因为要管理多种协议,我们自然想到使用工厂模式实现 ProtocolManager 类,从而可以使代码更加灵活和可扩展。工厂模式允许我们根据传入的参数动态地创建和返回协议实例,而不需要在 ProtocolManager 中硬编码所有协议的具体实现。 class Protocol: def send(self, data): raise NotImplementedError("Protocol must implement send method") def receive(self): raise NotImplementedError("Protocol must implement receive method") class TCPProtocol(Protocol): def __init__(self, host, port): self.host = host self.port = port # 初始化 TCP 连接等 def send(self, data): # 实现 TCP 发送逻辑 pass def receive(self): # 实现 TCP 接收逻辑 pass class MQTTProtocol(Protocol): def __init__(self, broker_address): self.broker_address = broker_address # 初始化 MQTT 连接等 def send(self, data): # 实现 MQTT 发送逻辑 pass def receive(self): # 实现 MQTT 接收逻辑 pass class ProtocolFactory: @staticmethod def create_protocol(protocol_type, *args, **kwargs): if protocol_type == 'tcp': return TCPProtocol(*args, **kwargs) elif protocol_type == 'mqtt': return MQTTProtocol(*args, **kwargs) else: raise ValueError(f"Unknown protocol type: {protocol_type}") class ProtocolManager: def __init__(self): self.protocols = {} def connect(self, protocol_type, *args, **kwargs): protocol_instance = ProtocolFactory.create_protocol(protocol_type, *args, **kwargs) self.protocols[protocol_type] = protocol_instance def send_data(self, protocol_type, data): if protocol_type in self.protocols: protocol_instance = self.protocols[protocol_type] protocol_instance.send(data) else: print(f"No connection established for protocol: {protocol_type}") def receive_data(self, protocol_type): if protocol_type in self.protocols: protocol_instance = self.protocols[protocol_type] return protocol_instance.receive() else: print(f"No connection established for protocol: {protocol_type}") return None # 使用示例 manager = ProtocolManager() # 连接 TCP 和 MQTT manager.connect('tcp', 'localhost', 12345) manager.connect('mqtt', 'localhost') # 发送数据 manager.send_data('tcp', b'Hello, TCP!') manager.send_data('mqtt', 'Hello, MQTT!') # 接收数据(这里只是示例,实际使用时可能需要异步接收或轮询) tcp_data = manager.receive_data('tcp') mqtt_data = manager.receive_data('mqtt') print(f"Received TCP data: {tcp_data}") print(f"Received MQTT data: {mqtt_data}") 在上面的示例中,我们定义了 Protocol 基类,并创建了两个继承自 Protocol 的具体协议类 TCPProtocol 和 MQTTProtocol。ProtocolFactory 类是一个静态工厂,负责根据传入的协议类型创建相应的协议实例。ProtocolManager 类使用 connect 方法通过工厂创建协议实例,并将其存储在 protocols 字典中。send_data 和 receive_data 方法现在根据协议类型从字典中获取协议实例,并调用其 send 和 receive 方法。这种方式使得添加新的协议变得非常简单,只需要定义一个新的协议类,并在 ProtocolFactory 中添加相应的创建逻辑即可,而不需要修改 ProtocolManager 类的代码。   但是在实际应用中,接收数据通常涉及到监听数据流的异步事件或回调,并且通常使用队列或缓存来存储接收到的数据,直到它们被处理。python中可以使用asyncio库和queue模块来实现异步队列, 我们将上述接收数据部分改写为异步缓存处理,修改后的代码如下: import asyncio import queue class Protocol: async def receive(self): raise NotImplementedError async def send_data(self, data): raise NotImplementedError class AsyncProtocol(Protocol): def __init__(self): self.receive_queue = asyncio.Queue() async def receive(self): while True: data = await self._receive_data() await self.receive_queue.put(data) async def _receive_data(self): # 这里模拟从网络或其他IO源接收数据 await asyncio.sleep(1) return f"Received data from {self.__class__.__name__}" async def get_received_data(self): return await self.receive_queue.get() async def send_data(self, data): # 这里应该实现具体的发送逻辑 # 暂时打印数据作为模拟 print(f"Sending data to {self.__class__.__name__}: {data}") class TCPProtocol(AsyncProtocol): pass class MQTTProtocol(AsyncProtocol): pass class ProtocolFactory: @staticmethod async def create_protocol(protocol_type): if protocol_type == 'tcp': return TCPProtocol() elif protocol_type == 'mqtt': return MQTTProtocol() else: raise ValueError(f"Unknown protocol type: {protocol_type}") class ProtocolManager: def __init__(self): self.protocols = {} async def connect(self, protocol_type): protocol_instance = await ProtocolFactory.create_protocol(protocol_type) self.protocols[protocol_type] = protocol_instance asyncio.create_task(protocol_instance.receive()) async def send_data(self, protocol_type, data): if protocol_type in self.protocols: await self.protocols[protocol_type].send_data(data) else: print(f"No connection established for protocol: {protocol_type}") async def receive_data(self, protocol_type): if protocol_type in self.protocols: protocol_instance = self.protocols[protocol_type] return await protocol_instance.get_received_data() else: print(f"No connection established for protocol: {protocol_type}") return None # 使用示例 async def main(): manager = ProtocolManager() await manager.connect('tcp') await manager.connect('mqtt') # 发送数据 await manager.send_data('tcp', 'Hello TCP!') await manager.send_data('mqtt', 'Hello MQTT!') # 接收数据 tcp_data = await manager.receive_data('tcp') mqtt_data = await manager.receive_data('mqtt') print(f"TCP received: {tcp_data}") print(f"MQTT received: {mqtt_data}") # 运行事件循环 asyncio.run(main()) 修改后的代码中,send_data方法现在只是简单地打印出要发送的数据和协议类型,以模拟发送逻辑。在实际应用中,需要在这些方法中加入真正的网络发送和接收逻辑。 运行代码,结果如下:   至此,一个简易的协议管理框架已经大家完毕,下一篇会基于该框架进行更多的物联网协议测试,以实现网关基础的收发功能。  

  • 2024-03-17
  • 发表了主题帖: 【米尔-全志 T527 开发板-试用评测】-第一篇 小试牛刀之MQTT

    本帖最后由 JerryZhen 于 2024-3-17 08:57 编辑 米尔开发套件 MYD-LT527由核心板 MYC-LT527 和底板MYB-LT527 组成,核心板与底板采用 LGA贴片焊接方式。随同开发套件 MYIR    提供了软件资源以及文档资料。由于全志科技 T527 系列高性能处理器是一款基于八核 Cortex-A55 + HiFi4 DSP+RISC-V 多核异构工业级处理器,因此性能肯定没得说。笔者很幸运能够在第一时间拿到板子。开发板的硬件参数以及外观可以参考官网,这里不作赘述。放上两张实物照片让大家饱饱眼福,做工很扎实,外观漂亮。   板子出厂系统是安卓 13,采用 AOSP 版本项目进行构建,包含完整的硬件驱动,常用的系统工具,调试工具等。支持使用 Java 进行应用开发。至于linux系统,官方表示稍后会提供 ubuntu22.04 以及buildroot系统。   安卓系统现在在车机之类的行业中应用很广泛。但是由于笔者主要从事工控,因此还是更习惯用linux开发。虽然现在官方暂未提供linux系统,但是问题不大,我们可以通过termux在安卓上实现类似linux虚拟机。Termux是一个专为安卓设备设计的开源Linux环境和命令行工具。通过Termux,用户可以在安卓设备上运行各种Linux命令和软件包,用来进行编程开发、网络安全测试、数据分析等各种任务。 Termux具有以下特点和功能: 1. 完全开源:Termux的所有代码都是开源的,用户可以自由地修改和定制。 2. 支持包管理:Termux内置了包管理工具,用户可以通过它来安装、更新和删除各种软件包。 3. 支持终端模拟器:Termux内置了功能强大的终端模拟器,用户可以在其中执行各种命令。 4. 支持插件:Termux还支持通过插件扩展功能,用户可以根据需要安装各种插件。 5. 社区活跃:Termux有一个激活的用户社区,用户可以在社区中获取帮助、分享经验和交流。 总的来说,Termux是一个强大的工具,可以让用户在安卓设备上轻松地进行各种Linux操作和开发任务。   下面笔者简要介绍下,如何在MYD-LT527的安卓系统上搭建Termux开发环境,并实现一个简单的MQTT通信demo。 首先安装两个apk(Termux, Termux:Boot),然后打开Termux.   pkg换源:  termux-change-repo 升级系统包:  pkg update -y 获取开发板存储权限: termux-setup-storage 安装openssh: pkg install -y openssh 启动ssh服务:sshd 设置密码:passwd 查看当前用户名:whoami 查看当前IP地址: ifconfig   现在可以在电脑上通过SSH远程登录开发板并进行各种操作,大大提高了开发板的可玩性。 现在我们通过python在开发板上实现mqtt收发数据为例进行讲解。 在系统中安装pyhon:pkg install python 创建项目文件夹:mkdir mqtt 进入项目目录:cd mqtt 创建python环境: python -m venv .venv 激活环境:source .venv/bin/activate 安装mqtt库: pip install paho-mqtt     然后分别实现发送客户端pub.py: import time import paho.mqtt.client as mqtt broker = 'broker.emqx.io' port = 1883 topic = "/Python/mqtt" mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2) mqttc.connect(broker, port) mqttc.loop_start() msg_count = 0 while True: time.sleep(1) msg = f"messages: {msg_count}" msg_info = mqttc.publish(topic, msg) print(f"Send `{msg}` to topic `{topic}`") msg_count += 1 mqttc.disconnect() mqttc.loop_stop() 再实现接收客户端sub.py: import paho.mqtt.client as mqtt broker = 'broker.emqx.io' port = 1883 topic = "/Python/mqtt" def on_message(client, userdata, message): print(f"Received `{message.payload.decode()}` from `{message.topic}` topic") def on_connect(client, userdata, flags, reason_code, properties): if reason_code.is_failure: print(f"Failed to connect: {reason_code}. loop_forever() will retry connection") else: client.subscribe(topic) mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2) mqttc.on_connect = on_connect mqttc.on_message = on_message mqttc.connect(broker, port) mqttc.loop_forever()   代码中broker选择公网的emqx官方服务器,配置如下: broker = 'broker.emqx.io' port = 1883 topic = "/Python/mqtt"   然后在两个窗口中分别运行发送客户端和接收客户端, 并观察结果。   至此第一篇分享结束,我们已经成功的在米尔T527开发板实现了一个简单的mqtt通讯应用。后面章节我们会基于T527做工业边缘网关,实现更强大的功能。  

  • 2024-02-22
  • 回复了主题帖: 测评入围名单:米尔基于全志T527开发板

    个人信息无误,确认可以完成评测计划。

  • 2023-09-15
  • 发表了主题帖: 【米尔T113测评】MQTT使用

    Node-RED 是一种编程工具,用于以新颖有趣的方式将硬件设备、API 和在线服务连接在一起。 它提供了一个基于浏览器的编辑器,可以使用调色板中的广泛节点轻松将流连接在一起,只需单击即可部署到其运行时。 T113如何安装nodered这里不在赘述,本文主要介绍如何在node-red中使用MQTT。 MQTT是一种轻量级基于代理的发布/订阅的消息传输协议,在物联平台的数据传输中应用非常广泛。在mqtt协议中最重要的是一个中间代理的服务。所有的消息都经过它来转发。我们要使用MQTT也必须要启动一个mqtt的代理(Broker)服务器。 Broker可以在本地自己搭建,然而自己搭建并维护服务端对于很多物联网初学者来说,是很有挑战性的。然也物联免费提供MQTT服务,此服务可用于学习物联网或个人物联网项目搭建。然也物联公共版MQTT服务器地址:test.ranye-iot.net,未加密传输端口:1883。此公共版MQTT服务为开放式免费服务。因此本服务主要用于个人学习测试使用。免费有如下限制:MQTT信息体(Payload)大小请不要超过100字节,否则服务器会拒绝接收。客户端信息发布频率不要过高,向同一主题发布信息的频率请不要高于每秒1次。 我们演示的node-red流很简单,一个订阅,一个发布。节点布局如下:   发布节点发布一个区间为[20,30]之间的随机数,用于模拟温度。节点配置信息如下: 发布节点需要配置broker相关信息:     订阅节点配置信息如下: 订阅节点的也许配置的连接的broker信息: 配置完毕,点击部署,然后打开调试窗口,然后点击时间戳按钮模拟发送,我们可以看到调试窗口输出的debug信息,发送端和接收端都已经正常工作了。   用好MQTT,在物联网世界中是非常重要的,基本上所有平台云台都支持MQTT协议。如果想从事物联网开发相关工作,务必需要了解并能用好该协议。

  • 2023-09-05
  • 发表了主题帖: 【米尔T113测评】UDP编程

    udp --- 用户数据报协议,是一个无连接的简单的面向数据报的运输层协议。 udp不提供可靠性,它只是把应用程序传给IP层的数据报发送出去,但是并不能保证它们能到达目的地。 udp在传输数据报前不用在客户和服务器之间建立一个连接,且没有超时重发等机制,故而传输速度很快。 udp是一种面向无连接的协议,每个数据报都是一个独立的信息,包括完整的源地址或目的地址,它在网络上以任何可能的路径传往目的地,因此能否到达目的地,到达目的地的时间以及内容的正确性都是不能被保证的。 udp通讯流程很简单,具体步骤如下:   udp服务端代码 #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <netinet/in.h> #include <arpa/inet.h> #include <stdbool.h> #include <pthread.h> #define BUFFER_SIZE 1024 // buf size struct CONNECT_INFO { struct sockaddr_in client_addr; }; static int sock_fd; static volatile bool is_connect = false; bool udp_server_init(short port) { struct sockaddr_in server_addr; sock_fd = socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd == -1) { perror("socket"); return false; } // initialize address. bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(port); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); // bind the local port. if ((bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(struct sockaddr_in))) == -1) { perror("bind"); return false; } return true; } void *send_thread(void *arg) { struct CONNECT_INFO *info = (struct CONNECT_INFO *)arg; if (info == NULL) { printf("error connect info"); return (void*)-1; } while (1) { char send_buf[BUFFER_SIZE]; bzero(send_buf, sizeof(send_buf)); // input from keyboard. char *str = fgets(send_buf, sizeof(send_buf), stdin); if (str == NULL) { perror("fgets"); continue; } if (strlen(str) <= 1) { continue; } if(is_connect == false) { printf("No client are available!\n"); continue; } // send data. if ((sendto(sock_fd, send_buf, strlen(str) - 1, 0, (struct sockaddr *)&info->client_addr, sizeof(struct sockaddr_in))) < 0) { perror("sendto"); continue; } } return (void*)0; } int main(int argc, char *argv[]) { // check your input. if (argc != 2) { printf("Usage:\n"); printf(" %s <port number>\n", argv[0]); return -1; } short port = atoi(argv[1]); bool ret = udp_server_init(port); if (ret == false) { goto err; } pthread_t t_id; struct CONNECT_INFO info; socklen_t addr_len = sizeof(struct sockaddr_in); memset(&info, 0, sizeof(info)); pthread_create(&t_id, NULL, send_thread, (void *)&info); pthread_detach(t_id); printf("Waiting for client connectionn\n"); while (1) { // recive from client. char recv_buf[BUFFER_SIZE]; bzero(recv_buf, sizeof(recv_buf)); if ((recvfrom(sock_fd, recv_buf, sizeof(recv_buf), 0, (struct sockaddr *)&info.client_addr, &addr_len)) <= 0) { perror("recvfrom"); goto err; } printf("[Recv from client %s:%d] : %s\n", inet_ntoa(info.client_addr.sin_addr), htons(info.client_addr.sin_port), recv_buf); is_connect = true; } close(sock_fd); return 0; err: close(sock_fd); return -1; }     udp客户端代码: #include <stdio.h> #include <string.h> #include <netinet/in.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <unistd.h> #include <errno.h> #include <arpa/inet.h> #define BUFFER_SIZE 1024 // buf size int main(int argc, char *argv[]) { // check the arguments. if (argc != 3) { printf("Usage:\n"); printf(" %s <server_addr> <portnumber>\n", argv[0]); return -1; } int sock_fd; char send_buf[BUFFER_SIZE]; char recv_buf[BUFFER_SIZE]; struct sockaddr_in server_addr; char *addr = argv[1]; short port = atoi(argv[2]); // initialize address. bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_addr.s_addr = inet_addr(addr); server_addr.sin_port = htons(port); // create udp socket. sock_fd = socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd == -1) { perror("socket"); return -1; } pid_t pid = fork(); if (pid > 0) { // The parent process is responsible for sending messages. while (1) { bzero(send_buf, sizeof(send_buf)); // read from stdin. char *str = fgets(send_buf, sizeof(send_buf), stdin); if (str == NULL) { perror("fgets"); goto err; } if (strlen(str) <= 1) { continue; } // send data. if ((sendto(sock_fd, send_buf, strlen(str) - 1, 0, (struct sockaddr *)&server_addr, sizeof(struct sockaddr_in))) < 0) { perror("sendto"); goto err; } } } else if (pid == 0) { // The child process is responsible for receiving messages. while (1) { bzero(recv_buf, sizeof(recv_buf)); socklen_t addr_len = sizeof(struct sockaddr_in); if ((recvfrom(sock_fd, recv_buf, sizeof(recv_buf), 0, (struct sockaddr *)&server_addr, &addr_len)) <= 0) { perror("recvfrom"); goto err; } printf("[Recv from server %s:%d] : %s\n", inet_ntoa(server_addr.sin_addr), htons(server_addr.sin_port), recv_buf); } } close(sock_fd); return 0; err: close(sock_fd); return -1; }   编译后运行结果:            

  • 发表了主题帖: 【米尔T113测评】TCP编程

    TCP协议是一种面向连接的、可靠的、基于字节流的传输层通信协议。通讯过程如下:       服务器端先初始化Socket,然后与端口绑定(bind),对端口进行监听(listen),调用accept阻塞,等待客户端连接。在这时如果有个客户端初始化一个Socket,然后连接服务器(connect),如果连接成功,这时客户端与服务器端的连接就建立了。客户端发送数据请求,服务器端接收请求并处理请求,然后把回应数据发送给客户端,客户端读取数据,最后关闭连接,一次交互结束。   服务端代码: #include <stdio.h> #include <stdlib.h> #include <sys/types.h> #include <sys/stat.h> #include <netinet/in.h> #include <sys/socket.h> #include <string.h> #include <unistd.h> #include <signal.h> #include <sys/ipc.h> #include <errno.h> #include <sys/shm.h> #include <time.h> #include <pthread.h> #include <arpa/inet.h> #define BUFFER_SIZE 1024 // buf size #define LISTENQ 1 // the max quote #define SIZE_SHMADD 2048 int main(int argc, char *argv[]) { // check the arguments. if (argc != 2) { printf("Usage:\n"); printf(" %s <port number>\n", argv[0]); return -1; } struct sockaddr_in server_addr; struct sockaddr_in client_addr; char recv_buf[BUFFER_SIZE]; char send_buf[BUFFER_SIZE]; pid_t pid; int sock_fd, conn_fd = -1; int optval = 1; int port = atoi(argv[1]); if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) { perror("socket"); return -1; } // setting bind port crycled. if ((setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR, (void *)&optval, sizeof(int))) < 0) { perror("setsockopt"); goto err; } // initized address. bzero(&server_addr, sizeof(struct sockaddr_in)); server_addr.sin_family=AF_INET; server_addr.sin_addr.s_addr=htonl(INADDR_ANY); server_addr.sin_port = htons(port); // bind the port. if (bind(sock_fd, (struct sockaddr *)(&server_addr), sizeof(struct sockaddr)) == -1) { perror("bind"); goto err; } // transform the socket into listen socket. if (listen(sock_fd, LISTENQ) == -1) { perror("listen"); goto err; } printf("Waiting for client connectionn...\n"); socklen_t cli_len = sizeof(struct sockaddr_in); conn_fd = accept(sock_fd, (struct sockaddr *)(&client_addr), &cli_len); if (conn_fd == -1) { perror("accept"); close(sock_fd); return -1; } printf("Client accepted : %s:%d \n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); pid = fork(); if (pid > 0) { // The parent process is responsible for sending messages. while (1) { bzero(send_buf, sizeof(send_buf)); char *str = fgets(send_buf, sizeof(send_buf), stdin); if (str == NULL) { perror("fgets"); goto err; } if (send(conn_fd, send_buf, strlen(send_buf) - 1, 0) < 0) { perror("send"); goto err; } } } else if (pid == 0) { // The child process is responsible for receiving messages. while (1) { bzero(recv_buf, sizeof(recv_buf)); if ((recv(conn_fd, recv_buf, BUFFER_SIZE, 0)) <= 0) { perror("recv"); goto err; } printf("[Recv from client %s:%d] : %s\n", inet_ntoa(server_addr.sin_addr), htons(server_addr.sin_port), recv_buf); } } else { perror("fork"); goto err; } close(conn_fd); close(sock_fd); return 0; err: close(conn_fd); close(sock_fd); return -1; }     客户端代码: #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <errno.h> #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <arpa/inet.h> #define BUFFER_SIZE 1024 int main(int argc, char *argv[]) { // check the arguments. if (argc != 3) { printf("Usage:\n"); printf(" %s <server addr> <port number>\n", argv[0]); return -1; } char *addr = argv[1]; short port = atoi(argv[2]); int sock_fd; int ret; char recv_buf[BUFFER_SIZE], send_buf[BUFFER_SIZE]; struct sockaddr_in server_addr; // initialize address/ bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(port); server_addr.sin_addr.s_addr = inet_addr(addr); // create socket fd. sock_fd = socket(AF_INET, SOCK_STREAM, 0); if (sock_fd == -1) { perror("socket"); return -1; } // connect. ret = connect(sock_fd, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); if (ret == -1) { perror("connect"); goto err; } printf("connect server(IP:%s Port: %d).\n", addr, port); pid_t pid = fork(); if (pid > 0) { // The parent process is responsible for sending messages. while (1) { bzero(send_buf, sizeof(send_buf)); char *str = fgets(send_buf, sizeof(send_buf), stdin); if (str == NULL) { perror("fgets"); goto err; } if (send(sock_fd, send_buf, strlen(send_buf) - 1, 0) < 0) { perror("send"); goto err; } } } else if (pid == 0) { // The child process is responsible for receiving messages. while (1) { bzero(recv_buf, sizeof(recv_buf)); if (sock_fd > 0) { if ((recv(sock_fd, recv_buf, BUFFER_SIZE, 0)) <= 0) { perror("recv"); goto err; } printf("[Recv from server %s:%d] : %s\n", inet_ntoa(server_addr.sin_addr), htons(server_addr.sin_port), recv_buf); } } } else { perror("fork"); goto err; } close(sock_fd); return 0; err: close(sock_fd); return -1; }     编译后运行结果如下: 服务端启起来,等待客户端连接。  启动客户端,发送数据, 服务端接收数据。      

  • 2023-08-29
  • 发表了主题帖: 【米尔T113测评】开机点灯

    本帖最后由 JerryZhen 于 2023-8-29 17:18 编辑 很高兴有机会试用米尔T113开发板。 米尔电子的 MYD-YT113X 板卡由核心板 MYC-YT113X 和底板 MYB-YT113X 组成,核心板与底板采用邮票孔焊接方式。此外 MYIR 提供了丰富的软件资源以及文档资料。开发板在出厂时已经烧录了镜像,只需要按照手册上电即可使用。 系统以文件的形式为 LED 设备提供操作接口。这些接口位于/sys/class/leds 目录下。在硬件资源列表中,可以通过命令读写 sysfs 的方式对 LED 进行测试。其中 0 表示 LED 点亮,1 表示 LED 熄灭, None表示关闭心跳灯。现在以心跳灯 led-blue 为例测试 LED:     最后附上开发板点灯图:  

  • 2023-08-22
  • 回复了主题帖: 测评入围名单:米尔-全志T113国产开发板

    个人信息无误

  • 回复了主题帖: 测评入围名单:米尔-全志T113国产开发板

    确认可以完成评测计划

最近访客

< 1/2 >

统计信息

已有30人来访过

  • 芯积分:47
  • 好友:--
  • 主题:9
  • 回复:3

留言

你需要登录后才可以留言 登录 | 注册


现在还没有留言