1.什么叫EMQ
2.求大神帮我写下这个C语言程序 把源代码回复给我 谢谢了!源码
3.深度解读设备的解析“万能语言”鸿蒙系统的分布式软总线能力
4.EMQX-简介、安装部署、源码基础功能、解析python代码测试
5.借助mbedTLS了解DTLS握手协议
什么叫EMQ
EMQ是源码一个高性能的开源消息服务器,专为高并发场景设计,解析安卓学习源码它基于Erlang/OTP语言平台构建,源码支持百万级的解析连接并具备分布式集群功能。该服务器采用MQTT V3.1/V3.1.1协议,源码兼容WebSocket、解析Stomp、源码CoAP、解析MQTT-SN等协议,源码确保了协议的解析全面支持。
EMQ的源码源代码完全开放,遵循Apache Version 2.0协议,能够承受百万级的并发连接,单节点可达到万连接的峰值负载,支持QoS0/1/2等级的消息处理,确保消息的可靠传递。
部署方面,EMQ易于安装和在多种平台上运行,包括Linux、FreeBSD、Mac OS X和Windows,使得它能够灵活适应各种服务器环境。此外,它还支持分布式集群和桥接,如双节点负载均衡或多节点分布式部署,以提高系统的扩展性和容错性。
为了进一步扩展功能,EMQ集成了诸如LDAP、MySQL、PostgreSQL等数据库的扩展模块和插件,如Redis和MongoDB,自媒体分发源码这使得它能够无缝集成到各种业务场景中,满足不同用户的需求。
总的来说,EMQ是一个强大且灵活的消息处理解决方案,适用于对连接数、协议兼容性和可扩展性有高要求的应用环境。它的开放性和易用性使其在众多MQTT服务器中脱颖而出。
求大神帮我写下这个C语言程序 把源代码回复给我 谢谢了!
/* determine the amount of the change
change = (paid - check) * ;
determine the number of dollars in the change
dollars = change / ;
…
(1). Using the previous statements as a starting point, write a C program
that calculates the number of dollar bills( cents), quarters coins(
cents), dimes coins ( cents), nickels coins (5 cents), and pennies coins (1
cents) in the change when $ is used to pay a bill of $6..
(2) Using the C program to calculate the change when a check of $.
is paid using a $ bill.
*/
#include "stdio.h"
void getChange(int paid, float bill)
{
if (paid < bill)
{
printf("Your money cant paid for the bill!\n");
return;
}
else
{
int remain;
int dollor = 0,quarter = 0,dime = 0,nickel = 0,penny = 0;
remain = (paid* - bill*)+0.5;
dollor = remain/;
printf("Change Dollors: %d\n",dollor);
remain -= dollor*;
quarter = remain/;
printf("Change Quarters: %d\n",quarter);
remain -= quarter*;
dime = remain/;
printf("Change Dimes: %d\n",dime);
remain -= dime*;
nickel = remain/5;
printf("Change Nickels: %d\n",nickel);
remain -=nickel*5;
penny = remain;
printf("Change Pennys: %d\n",penny);
printf("Change finished!\n");
}
}
void main()
{
int paid;
float bill;
printf("Please input your Paid($):");
scanf("%d",&paid);
printf("Please input your Bill($):");
scanf("%f",&bill);
printf("Your change is: \n");
getChange(paid, bill);
}
深度解读设备的“万能语言”鸿蒙系统的分布式软总线能力
本文深入解析鸿蒙系统的分布式软总线能力,旨在为鸿蒙平台开发者提供详尽的技术指南与参考。分布式软总线是鸿蒙操作系统的核心组件,旨在将不同设备无缝连接,实现万物互联的愿景。通过统一的通信协议与高效的数据传输机制,分布式软总线让设备间的连接变得流畅、稳定,为用户提供无感的设备体验。
鸿蒙分布式软总线致力于提供一种极简通信协议,实现设备间自动发现与连接,确保用户在设备发现与连接时无需等待。此功能基于物联网设备的发现机制,实现设备自动连接,使得设备与设备之间能够快速建立联系,带来无缝的互联体验。
在设备互联方面,鸿蒙分布式软总线提供了多设备互联与组网的能力,无需开发者关注网络协议差异和组网方式,仅需监听设备上下线状态即可。此外,该系统支持异构网络组网,能自动构建逻辑全连接网络,解决不同设备间协议交互的问题,实现高效、可靠的小盒内网穿透源码数据传输。
鸿蒙分布式软总线采用COAP(Constrained Application Protocol)协议,这是一种专为受限节点设计的轻量级Web协议,适用于能源、楼宇自动化等M2M(Machine-to-Machine)应用。COAP协议简化了REST架构,支持可靠传输、数据重传、块传输等功能,同时提供多播支持与异步消息传输,极大地增强了设备间的交互效率与稳定性。
在源代码结构方面,分布式软总线的实现主要集中在communication_services_softbus_lite目录下。此目录下的源码文件经过编译后形成动态库,其他依赖模块在编译时会添加动态库的依赖。该动态库包含了软总线初始化、操作系统适配、设备发现与连接、认证管理、会话传输等多个关键功能模块,确保了软总线在不同环境下的稳定运行。
具体而言,软总线的初始化过程涉及线程创建、信号量初始化以及注册TCP/IP协议栈与session底层socket操作。在设备发现与连接阶段,轻量设备作为被发现端发布服务,而发现端根据服务名称和设备ID建立会话,实现服务间的数据传输。认证管理模块则负责设备间信任关系的建立与维护,通过AES-GCM加密算法确保数据传输的安全性。
综上所述,分布式软总线作为鸿蒙操作系统的关键技术之一,通过提供高效、安全的设备互联与数据传输机制,显著提升了多设备协同工作的彩带图指标公式源码性能与用户体验。深入理解分布式软总线对于开发者而言,不仅有助于优化应用开发过程,还能加速万物互联生态的构建与发展。
EMQX-简介、安装部署、基础功能、python代码测试
MQTT属于是物联网的通信协议,在MQTT协议中有两大角色:客户端(发布者/订阅者),服务端(Mqtt broker);针对客户端和服务端需要有遵循该协议的的具体实现,EMQ/EMQX就是MQTT Broker的一种实现。
EMQX是基于 Erlang/OTP 平台开发的 MQTT 消息服务器,是开源社区中最流行的 MQTT 消息服务器。EMQ X 是开源百万级分布式 MQTT 消息服务器(MQTT Messaging Broker),用于支持各种接入标准 MQTT协议的设备,实现从设备端到服务器端的消息传递,以及从服务器端到设备端的设备控制消息转发。从而实现物联网设备的数据采集,和对设备的操作和控制。
到目前为止,比较流行的 MQTT Broker 有几个:使用 C 语言实现的 MQTT Broker,使用 Erlang 语言开发的 MQTT Broker,使用 Node.JS 开发的 MQTT Broker,同样使用 Erlang 开发的 MQTT Broker。从支持 MQTT5.0、稳定性、扩展性、集群能力等方面考虑,EMQX 的表现应该是最好的。
与别的MQTT服务器相比EMQ X 主要有以下的特点:经过+版本的迭代,EMQ X 目前为开源社区中最流行的 MQTT 消息中间件,在各种客户严格的生产环境上经受了严苛的考验;支持丰富的物联网协议,包括 MQTT、MQTT-SN、CoAP、精品atv新亚视源码 LwM2M、LoRaWAN 和 WebSocket等;优化的架构设计,支持超大规模的设备连接。企业版单机能支持百万的 MQTT 连接;集群能支持千万级别的 MQTT 连接;易于安装和使用;灵活的扩展性,支持企业的一些定制场景;中国本地的技术支持服务,通过微信、QQ等线上渠道快速响应客户需求;基于 Apache 2.0 协议许可,完全开源。EMQ X 的代码都放在 Github 中,用户可以查看所有源代码;EMQ X 3.0 支持 MQTT 5.0 协议,是开源社区中第一个支持 5.0协议规范的消息服务器,并且完全兼容 MQTT V3.1 和 V3.1.1 协议。除了 MQTT 协议之外,EMQ X 还支持别的一些物联网协议;单机支持百万连接,集群支持千万级连接;毫秒级消息转发。EMQ X 中应用了多种技术以实现上述功能;利用 Erlang/OTP 平台的软实时、高并发和容错(电信领域久经考验的语言);全异步架构;连接、会话、路由、集群的分层设计;消息平面和控制平面的分离等;扩展模块和插件,EMQ X 提供了灵活的扩展机制,可以实现私有协议、认证鉴权、数据持久化、桥接发和管理控制台等的扩展;桥接:EMQ X 可以跟别的消息系统进行对接,比如 EMQ X Enterprise 版本中可以支持将消息转发到 Kafka、RabbitMQ 或者别的 EMQ 节点等;共享订阅:共享订阅支持通过负载均衡的方式在多个订阅者之间来分发 MQTT 消息。比如针对物联网等 数据采集场景,会有比较多的设备在发送数据,通过共享订阅的方式可以在订阅端设置多个订阅者来实现这几个订阅者之间的工作负载均衡。
典型的物联网平台包括设备硬件、数据采集、数据存储、分析、Web / 移动应用等。EMQX 位于数据采集这一层,分别与硬件和数据存储、分析进行交互,是物联网平台的核心:前端的硬件通过 MQTT 协议与位于数据采集层的 EMQX 交互,通过 EMQX 将数据采集后,通过 EMQX 提供的数据接口,将数据保存到后台的持久化平台中(各种关系型数据库和 NOSQL 数据库),或者流式数据处理框架等,上层应用通过这些数据分析后得到的结果呈现给最终用户。
EMQX 公司主要提供三个产品,可在官网首页产品导航查看每一种产品;主要体现在支持的连接数量、产品功能和商业服务等方面的区别。
完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范支持;QoS0, QoS1, QoS2 消息支持;持久会话与离线消息支持;Retained 消息支持;Last Will 消息支持;TCP/SSL 连接支持;MQTT/WebSocket/SSL 支持;HTTP 消息发布接口支持;$SYS/# 系统主题支持;客户端在线状态查询与订阅支持;客户端 ID 或 IP 地址认证支持;用户名密码认证支持;LDAP 认证;Redis、MySQL、PostgreSQL、MongoDB、HTTP 认证集成;浏览器 Cookie 认证;基于客户端 ID、IP 地址、用户名的访问控制 (ACL);多服务器节点集群 (Cluster);支持 manual、mcast、dns、etcd、k8s 等多种集群发现方式;网络分区自动愈合;消息速率限制;连接速率限制;按分区配置节点;多服务器节点桥接 (Bridge);MQTT Broker 桥接支持;Stomp 协议支持;MQTT-SN 协议支持;CoAP 协议支持;Stomp/SockJS 支持;延时 Publish ($delay/topic);Flapping 检测;黑名单支持;共享订阅 ($share/:group/topic);TLS/PSK 支持;规则引擎;空动作 (调试);消息重新发布;桥接数据到 MQTT Broker;检查 (调试);发送数据到 Web 服务。
EMQ X 目前支持的操作系统:Centos6、Centos7、OpenSUSE tumbleweed、Debian 8、Debian 9、Debian 、Ubuntu .、Ubuntu .、Ubuntu .、macOS .、macOS .、macOS .、Windows Server 。产品部署建议 Linux 服务器,不推荐 Windows 服务器。安装的方式有很多种,可供自由选择:Shell脚本安装、包管理器安装、二进制包安装、ZIP压缩包安装、Homebrew安装、Docker运行安装、Helm安装、源码编译安装。
Dashboard界面查看基本信息。
身份认证是大多数应用的重要组成部分,MQTT 协议支持用户名密码认证,启用身份认证能有效阻止非法客户端的连接。EMQ X 中的认证指的是当一个客户端连接到 EMQ X 的时候,通过服务器端的配置来控制客户端连接服务器的权限。EMQ X 的认证支持包括两个层面:MQTT 协议本身在 CONNECT 报文中指定用户名和密码,EMQ X 以插件形式支持基于 Username、ClientID、HTTP、JWT、LDAP 及各类数据库如 MongoDB、MySQL、PostgreSQL、Redis 等多种形式的认证;在传输层上,TLS 可以保证使用客户端证书的客户端到服务器的身份验证,并确保服务器向客户端验证服务器证书。也支持基于 PSK 的 TLS/DTLS 认证。
EMQ X 支持使用内置数据源(文件、内置数据库)、JWT、外部主流数据库和自定义 HTTP API 作为身份认证数据源。连接数据源、进行认证逻辑通过插件实现的,每个插件对应一种认证方式,使用前需要启用相应的插件。客户端连接时插件通过检查其 username/clientid 和 password 是否与指定数据源的信息一致来实现对客户端的身份认证。(v5.0以上默认集成)EMQ X 支持的认证方式:内置数据源、外部数据库、其他。认证结果:认证成功、认证失败、忽略认证(ignore)。
EMQ X 默认配置中启用了匿名认证,任何客户端都能接入 EMQ X。没有启用认证插件或认证插件没有显式允许/拒绝(ignore)连接请求时,EMQ X 将根据匿名认证启用情况决定是否允许客户端连接。
可以订阅多个主题。
安装 paho-mqtt:导入 Paho MQTT 客户端。
通过TCP连接:设置 broker、port、topic、client_id,连接 MQTT Broker。
通过SSL/TLS连接:设置 broker、port、topic、client_id,连接 MQTT Broker,使用 CA certificate,设置用户名密码。
订阅主题:设置 on_message 回调函数,当收到消息时执行。
取消订阅:通过以下代码取消订阅,此时应指定取消订阅的主题。
发布消息:通过以下代码发布消息,设置消息内容、主题,调用 publish 方法。
接收消息:通过以下代码指定客户端对消息事件进行监听,并在收到消息后执行回调函数,将接收到的消息及其主题打印到控制台。
断开连接:如客户端希望主动断开连接,可以通过如下代码实现。
完整代码:导入 random、time、paho.mqtt.client as mqtt_client,设置 broker、port、topic、client_id,连接 MQTT Broker,设置 on_connect 回调函数,设置 publish 回调函数,运行客户端。
借助mbedTLS了解DTLS握手协议
本文旨在通过mbedTLS协议栈的实践操作,解析DTLS的握手过程。DTLS是在UDP层面上为TLS提供安全防护的协议,特别适合资源受限的嵌入式环境,如CoAP在物联网和云端通讯中的应用。
在mbedTLS这个开源且轻量级的SSL/TLS库中,我们利用其自带的dtls_client/dtls_server测试程序来观察握手过程。这个程序虽然在localhost上运行,但可以作为理解DTLS握手的基础。它使用了ECDHE_RSA_WITH_AES__GCM_SHA的加密套件,握手过程与RSA密钥交换有所不同,如多了Server Key Exchange报文。
为了深入分析,我们需要在源代码中开启调试信息,如在dtls_client.c和dtls_server.c中设置DEBUG_LEVEL,记录时间戳。然后,通过Wireshark抓包工具分析网络交互,结合调试信息理解握手报文的发送和接收。
DTLS握手流程包括客户端发送Client Hello,可能包含Hello Verify Request(首次连接时有,后续使用Cookie验证),然后是服务器回应Server Hello,接着是证书交换、服务器公钥交换、Change Cipher Spec和Finished等报文的交互。验证阶段很重要,如使用Cookie来防止DoS攻击,确保服务器与合法客户端建立连接。
握手结束后,双方利用协商的会话密钥对应用数据进行加密,每个数据包都包含序列号以保证数据顺序。通过mbedTLS的实例,我们可以直观理解DTLS握手协议的工作原理。
总结,虽然之前对SSL/TLS有所了解,但实际应用时仍需深入研究,例如mbedTLS的代码。通过实践和记录,我们可以更好地应对相关问题,为后续学习和工作提供参考。