热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Win10IoTC#开发4-UART串口通信

Windows10IoTCore是微软针对物联网市场的一个重要产品,既可以开发设备UI与用户交互式操作,又可以控制GPIO等接口,使得原来嵌入式繁琐的开发变得简单。通过RemoteDebug

Windows 10 IoT Core 是微软针对物联网市场的一个重要产品,既可以开发设备UI与用户交互式操作,又可以控制GPIO等接口,使得原来嵌入式繁琐的开发变得简单。通过Remote Debug功能可以进行断点追踪调试。C#语言本身也有很好的用户基础,相信Win10 IoT 不远的将来会火起来。
上个月帮朋友解决了关于Win10 IoT 的一些技术问题,当前也有很多公司在尝试采用Win10 IoT进行开发,可能也会遇到这些问题,相关文档现在还非常少,这里写出来供大家参考。
因为要做一个Java Web与Restful的自宿主框架和其他一大堆事情,这篇文章也拖了半个月,框架刚刚完成,以后可以摆脱Tomcat这些HttpServer了,现在静下来把这篇文章写完。
Win10 IoT的安装部署过程后面我会写文章进行补充,下面直接介绍串口通信的开发过程。
1.连接设备

首先将 Raspberry Pi 2 与传感器连接。GND,5V 对接,TX与RX交叉连接。

Raspberry Pi 2 GPIO 接口

传感器与设备连接

2.启动设备
将Raspberry连接到局域网并启动。打开 Windows IoT Core Watcher 查看设备的工作状态。包含名称,mac地址,ip地址,当前在线等信息。

3.创建项目
打开VS2015创建项目,在C#分类下选择Windows IoT Core 模板。

4.配置权限
Package.appxmanifest文件的节点中加入读取网络与串口通讯的权限,这步很像Android的uses-permission。

<Capabilities>
    <Capability Name="internetClient" />
    <Capability Name="internetClientServer" />
    <Capability Name="privateNetworkClientServer" />
    <DeviceCapability Name="serialcommunication">
      <Device Id="any">
        <Function Type="name:serialPort" />
      Device>
    DeviceCapability>
Capabilities>

5.模块代码
创建UART的串口设备并设置参数。

string aqsFilter = SerialDevice.GetDeviceSelector("UART0");
DeviceInformationCollection dis = await DeviceInformation.FindAllAsync(aqsFilter);
//获取串口设备
_derialPort = await SerialDevice.FromIdAsync(dis[0].Id);
//串口设备是否获取成功
if (null != _derialPort)
{
    _derialPort.ReadTimeout = TimeSpan.FromMilliseconds(1000);//超时
    _derialPort.BaudRate = 9600;//波特率
    _derialPort.Parity = SerialParity.None;//校验检查
    _derialPort.StopBits = SerialStopBitCount.One;//停止位
    _derialPort.DataBits = 8;//数据位
    _derialPort.Handshake = SerialHandshake.None;//握手方式
    //设置读取输入流
    _dataReader = new DataReader(_derialPort.InputStream);
}

读取串口数据

 Task loadAsyncTask;
_dataReader.InputStreamOptions = InputStreamOptions.Partial;
//读取数据
loadAsyncTask = _dataReader.LoadAsync(_readBufferLength).AsTask();
uint bytesRead = await loadAsyncTask;
//判断获取数据长度
if (bytesRead > 0)
{
     //转换十六进制数据
     string res = LoadData(bytesRead);
     SendMsg(res);
}
StringBuilder str_builder = new StringBuilder();
//转换缓冲区数据为16进制
while (_dataReader.UnconsumedBufferLength > 0)
{
    str_builder.Append(_dataReader.ReadByte().ToString("x2"));
}

推送数据

HttpClient httpClient = new HttpClient();
httpClient.GetAsync(new Uri(string.Format("http://192.168.1.9:8099/{0}", res)));

6.调试代码
在另外一台电脑(ip:192.168.1.9)上先用Nodejs创建了一个http的监听服务模拟服务器,监听8099端口上设备发送过来的串口数据,并打印到Console里。

在VS2015的工具栏中选择Remote Machine进行调试,IP地址输入设备对应地址,可以在Windows IoT Core Watcher中查看到。点击运行后会自动部署到设备上。

 

7.运行结果
代码部署完成后开始执行任务,Output窗口打印获取到的串口数据。

Nodejs模拟的服务器打印接收到的推送数据。从打印结果上可以看到发送和接收到的数据一致。

与传感器的数据协议约定一致。

完整代码:

using System;
using System.Diagnostics;
using System.Text;
using System.Threading.Tasks;
using Windows.ApplicationModel.Background;
using Windows.Devices.Enumeration;
using Windows.Devices.SerialCommunication;
using Windows.Storage.Streams;
using Windows.Web.Http;

namespace CloudTechIot3
{
    //http://www.cnblogs.com/cloudtech
    //librastarwing@hotmail.com
    public sealed class StartupTask : IBackgroundTask
    {
        #region Fileds

        private DataReader _dataReader;
        private SerialDevice _derialPort;
        //缓冲区大小
        private uint _readBufferLength = 10;

        #endregion

        #region Main Method

        public async void Run(IBackgroundTaskInstance taskInstance)
        {

            await Listen();
            Close();
        }

        #endregion

        #region Private Methods

        //监听串口
        private async Task Listen()
        {
            try
            {
                string aqsFilter = SerialDevice.GetDeviceSelector("UART0");
                DeviceInformationCollection dis = await DeviceInformation.FindAllAsync(aqsFilter);
                //获取串口设备
                _derialPort = await SerialDevice.FromIdAsync(dis[0].Id);
                //串口设备是否获取成功
                if (null != _derialPort)
                {
                    _derialPort.ReadTimeout = TimeSpan.FromMilliseconds(1000);//超时
                    _derialPort.BaudRate = 9600;//波特率
                    _derialPort.Parity = SerialParity.None;//校验检查
                    _derialPort.StopBits = SerialStopBitCount.One;//停止位
                    _derialPort.DataBits = 8;//数据位
                    _derialPort.Handshake = SerialHandshake.None;//握手方式
                    //设置读取输入流
                    _dataReader = new DataReader(_derialPort.InputStream);
                    //循环读取数据
                    while (true)
                    {
                        await ReadAsync();
                    }
                }
                else
                {
                    //TODO
                }
            }
            catch (Exception ex)
            {
                //TODO
            }
            finally
            {
                Close();
            }
        }

        //异步读取数据
        private async Task ReadAsync()
        {
            Task loadAsyncTask;
            _dataReader.InputStreamOptions = InputStreamOptions.Partial;
            //读取数据
            loadAsyncTask = _dataReader.LoadAsync(_readBufferLength).AsTask();
            Task.Delay(TimeSpan.FromSeconds(2.1)).Wait();
            uint bytesRead = await loadAsyncTask;
            //判断获取数据长度
            if (bytesRead > 0)
            {
                //转换十六进制数据
                string res = LoadData(bytesRead);
                SendMsg(res);
            }
            else
            {
                //TODO
            }
        }

        //输出结果
        private void SendMsg(string res)
        {
            //打印
            Debug.WriteLine(res);
            //推送到服务器
            HttpClient httpClient = new HttpClient();
            httpClient.GetAsync(new Uri(string.Format("http://192.168.1.9:8099/{0}", res)));
        }

        //转换数据
        private string LoadData(uint bytesRead)
        {
            StringBuilder str_builder = new StringBuilder();
            //转换缓冲区数据为16进制
            while (_dataReader.UnconsumedBufferLength > 0)
            {
                str_builder.Append(_dataReader.ReadByte().ToString("x2"));
            }
            return str_builder.ToString().ToUpper();
        }

        //释放资源
        private void Close()
        {
            if (null != _dataReader)
            {
                _dataReader.DetachStream();
            }
            if (null != _derialPort)
            {
                _derialPort.Dispose();
            }
        }

        #endregion
    }
}

到这里整个数据读取发送的过程就完成了,如果对代码有优化的建议,欢迎留言或发邮件给我(librastarwing@hotmail.com)。
也可以加我的微信号查看以前的文章。

项目源码 GitHub https://github.com/CloudTechx/CloudTechIot 的 CloudTechIot3 目录下。


推荐阅读
  • 本文探讨了在使用Apache Flink向Kafka发送数据过程中遇到的事务频繁失败问题,并提供了详细的解决方案,包括必要的配置调整和最佳实践。 ... [详细]
  • Apollo入门指南
    Apollo是一个分布式配置中心,由服务端和客户端组成,支持配置的集中管理和动态更新。 ... [详细]
  • 本文探讨了在使用 ClickOnce 部署方式时遇到的自动更新失败问题,包括本地安装与服务器安装的不同表现,并提供了详细的解决方案。 ... [详细]
  • 解决JavaWeb项目中因IPv6导致的IP转换错误
    本文探讨了在JavaWeb项目中,当尝试将客户端IP地址从字符串形式转换为整数时遇到的问题,并提供了详细的解决方案。具体问题表现为在本地环境中通过`request.getRemoteHost()`获取到的IP地址为IPv6格式,而非预期的IPv4格式。 ... [详细]
  • 本文详细解析了Java中流的概念,特别是OutputStream和InputStream的区别,并通过实际案例介绍了如何实现Java对象的序列化。文章不仅解释了流的基本概念,还探讨了序列化的重要性和具体实现步骤。 ... [详细]
  • 探讨了生成时间敏感的一次性伪随机密码的方法,旨在通过加入时间因素防止重放攻击。 ... [详细]
  • 深入解析轻量级数据库 SQL Server Express LocalDB
    本文详细介绍了 SQL Server Express LocalDB,这是一种轻量级的本地 T-SQL 数据库解决方案,特别适合开发环境使用。文章还探讨了 LocalDB 与其他轻量级数据库的对比,并提供了安装和连接 LocalDB 的步骤。 ... [详细]
  • 深入理解SAP Fiori及其核心概念
    本文详细介绍了SAP Fiori的基本概念、发展历程、核心特性、应用类型、运行环境以及开发工具等,旨在帮助读者全面了解SAP Fiori的技术框架和应用场景。 ... [详细]
  • 本文详细介绍了如何利用go-zero框架从需求分析到最终部署至Kubernetes的全过程,特别聚焦于微服务架构中的网关设计与实现。项目采用了go-zero及其生态组件,涵盖了从API设计到RPC调用,再到生产环境下的监控与维护等多方面内容。 ... [详细]
  • 匠心|传统_2021年度总结 | 葡萄城软件开发技术回顾(上)
    匠心|传统_2021年度总结 | 葡萄城软件开发技术回顾(上) ... [详细]
  • 本文介绍了一种算法,用于在一个给定的二叉树中找到一个节点,该节点的子树包含最大数量的值小于该节点的节点。如果存在多个符合条件的节点,可以选择任意一个。 ... [详细]
  • Cadence SPB 16.5 安装指南与注意事项
    本文提供了详细的 Cadence SPB 16.5 安装步骤,包括环境配置、安装过程中的关键步骤以及常见问题的解决方案。适合初次安装或遇到问题的技术人员参考。 ... [详细]
  • 本文档提供了详细的MySQL安装步骤,包括解压安装文件、选择安装类型、配置MySQL服务以及设置管理员密码等关键环节,帮助用户顺利完成MySQL的安装。 ... [详细]
  • 本项目使用Java语言开发了一个基于B/S架构的指纹识别系统,该系统能够实现指纹的高效采集与精准识别,适用于多种安全认证场景。 ... [详细]
  • 本文介绍了进程的基本概念及其在操作系统中的重要性,探讨了进程与程序的区别,以及如何通过多进程实现并发和并行。文章还详细讲解了Python中的multiprocessing模块,包括Process类的使用方法、进程间的同步与异步调用、阻塞与非阻塞操作,并通过实例演示了进程池的应用。 ... [详细]
author-avatar
516837745_d2d52c
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有