搜索[分布式总线]结果-低调大师优秀个人博客

精选列表

搜索[分布式总线]，共10005篇文章

xtools-boot一款基于JDK25,SpringBoot4的通用Spring工具库

实现日志存储和检索支持 Knife4j 4.5.0 自动生成 API 文档集成 Spring AMQP 4.0.3 实现 RabbitMQ 异步消息处理集成 Spring Data Redis 实现分布式缓存

2026-06-09

CentOS8安装MyCat，轻松搞定数据库的读写分离、垂直分库、水平分库

支持分布式事务（弱xa）。支持XA分布式事务（1.6.5）。支持全局序列号，解决分布式下的主键生成问题。分片规则丰富，插件化开发，易于扩展。强大的web，命令行监控。

2025-09-05

Solon2 分布式事件总线的技术价值？

分布式事件总线在分布式开发（或微服务开发）时，是极为重要的架构手段。它可以分解响应时长，可以削峰，可以做最终一致性的分布式事务，可以做业务水平扩展。

2023-03-12

.NET 分布式事件总线 Jaina v1.0.0 发布

Jaina .NET 事件总线，简化项目、类库、线程、服务等之间的通信，代码更少，质量更好。‎

2021-10-25

.NET 分布式事件总线规范 Jaina v3.1.0 发布

.); }); Jaina .NET 事件总线，简化项目、类库、线程、服务等之间的通信，代码更少，质量更好。‎

2022-08-24

HarmonyOS分布式软总线原理剖析：从理论到实践的完整指南

HarmonyOS作为华为自主研发的分布式操作系统，其分布式软总线（DSoftBus）技术堪称整个系统的神经网络，承载着设备发现、连接建立、数据传输等关键功能。

2025-12-23

深度解读设备的“万能语言”鸿蒙系统的分布式软总线能力

摘要：本文分享鸿蒙分布式软总线，并对相关源代码进行解析，为在鸿蒙系统平台上工作的相关人员的信息参考和指导。

2021-01-22

润小云解读鸿蒙OS系列（五）：分布式软总线之discovery_service

下面是设备的定义，分为本地设备（被发现端设备）和外部设备，从中不难看出鸿蒙OS的分布式特性，本地设备可以通过PublishService函数将自身的服务发布出去，供外部设备发现并使用。

2020-12-01

润小云解读鸿蒙OS系列（二）：分布式软总线之trans_service

初始化的时机在分布式软总线的设计中，trans_service模块是在authmanager模块中被初始化的，而authmanager模块又被discovery模块初始化，因此设备在向外发布本设备信息的过程中

2020-11-18

微众银行开源分布式金融级消息总线 DeFiBus

近期微众银行宣布开源其支撑内部分布式架构基础的分布式消息总线DeFiBus。 DeFiBus完全基于开源软件自主研发，历经几年的打磨及生产检验，满足金融领域对大型分布式系统调用的更高要求。

2019-11-11

国际通用建筑总线 KNX 科普：分布式架构如何实现智能照明控制

在建筑智能照明领域，KNX 是全球应用非常广泛的现场总线标准，广泛落地于机场、地铁、体育馆、医院、酒店等大型公建。

2026-09-16

OpenHarmony分布式软总线流程分析v1.0丨1.被发现端，发布服务

) [2.开启软总线，建立连接](https://harmonyos.51cto.com/posts/6296#bkwz) 完整版可以下载文末的pdf。

2021-07-02

润小云解读鸿蒙OS系列（六）：分布式软总线之discovery+COAP全流程

简介 Discovery 是一种基于coap 通信协议的设备发现机制；Coap（Constrained Application Protocol）是一种可以使用在资源受限的物联网设备上，并支持可靠传输的轻量化类web协议。它详细规范定义在 RFC 7252, coap 协议支持IP多播, 即可以同时向多个设备发送请求，鸿蒙OS的设备发现功能也是基于这个特性；用户使用discovery功能时，需要保证发现端设备与被发现端设备在同一个局域网内，并且都能收到对方coap协议报文；目前discovery服务仅支持基于Wi-Fi通信方式的设备发现机制。代码分析代码目录结构如下图： Discovery 对外提供PublishService() 接口来实现设备的发现功能，其函数实现解读如下： PublishService主要的代码流程图如下，由于篇幅有限我们本次不做详细的介绍。被发现端主要是通过PublishService()这个函数发布服务。PublishService()函数的实现在discovery_service.c文件中，我们来看看这个函数的主流程代码；函数参数三个： moduleName：调用者的模块名称 info：PublishInfo结构体，发布的信息 cb：发布成功或者失败的回调函数在函数实现中，我们可以看到权限检查，参数检验，信号量创建之类等代码；这里就不做介绍；我们从初始化服务 InitService()函数看， InitCommonManager() 函数主要是调用InitLocalDeviceInfo()给g_deviceInfo结构体初始化； RegisterWifiCallback(WifiEventTrigger)函数将WifiEventTrigger(unsigned int para)函数赋值给全局变量g_wifiCallback 最主要看CoapInit()函数这里面我们优先分析下CoapInitSocket() 和 CreateCoapListenThread() CoapInitSocket()函数实现如下：可以看到CoapInitSocket()函数里面其实就是调用了socket()函数创建了socket，然后调用bind()绑定到指定的ip跟port，然后将socket描述符赋值给全局变量g_serverFd。以便后面GetCoapServerSocket()函数调用获取socket描述符。 CreateCoapListenThread() 创建线程接收消息，函数实现如下； CoapReadHandle 接收并处理收到的消息 HandleReadEvent函数实现如下，我们分别看看CoapSocketRecv()、COAP_SoftBusDecode()、PostServiceDiscover()函数； CoapSocketRecv()实现就是调用recvfrom()接收消息。收到消息放到recvBuffer里面然后调用COAP_SoftBusDecode()解码收到的消息。解码之后放到decodePacket里面然后调用PostServiceDiscover()函数对接收到的消息进行回应。 PostServiceDiscover()函数代码如下：其中GetServiceDiscoverInfo()，这个函数可以获取到对端的ip 和remoteUrl。这里可以获取到设备信息，也就是deviceInfo 结构体成员如下：获取到这些信息之后我们就可以调用CoapResponseService()函数回复消息了。这里就看看主要的回复消息流程，其他的流程有兴趣可以自己继续钻研。调用socket()创建socket 并将socket描述符返回跟全局变量g_clientFd，以便后面函数GetCoapClientSocket()获取socket描述符。调用sendto发送消息。此文档只是介绍了收发消息的主要流程，其他的细节这里并没有详细介绍。感兴趣的同学可以根据这个主流程继续钻研下其他的功能实现。

2020-12-01

分布式消息总线，基于.NET Socket Tcp的发布-订阅框架之离线支持，附代码下载

一、分布式消息总线以及基于Socket的实现在前面的分享一个分布式消息总线，基于.NET Socket Tcp的发布-订阅框架，附代码下载一文之中给大家分享和介绍了一个极其简单也非常容易上的基于.NET

2017-11-14

档案库房分布式环境设备，RS485总线架构下一体机集群平台接入方案

物联网 · 盛世宏博 · RS485总线、一体机集群、Modbus RTU、边缘网关、档案环境平台

2026-10-13

MASA Framework 事件总线 - 进程内事件总线

概述事件总线是一种事件发布/订阅结构，通过发布订阅模式可以解耦不同架构层级，同样它也可以来解决业务之间的耦合，它有以下优点松耦合横切关注点可测试性事件驱动发布订阅模式通过下图我们可以快速了解发布订阅模式的本质

2022-11-24

跟踪总线事件

spring.cloud.bus.trace.enabled=true [{ "timestamp": 1516583843951, "info": { "signal": "spring.cloud.bus.ack", "event": "RefreshRemoteApplicationEvent", "id": "7fe840f5-ccd4-45f3-a511-bf13388938a8", "origin": "config-client:8002", "destination": "**" } }, { "timestamp": 1516583842814, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:17:22 GMT", "status": "200" } }, "timeTaken": "4068" } }, { "timestamp": 1516583842302, "info": { "signal": "spring.cloud.bus.ack", "event": "RefreshRemoteApplicationEvent", "id": "7fe840f5-ccd4-45f3-a511-bf13388938a8", "origin": "config-client:8003", "destination": "**" } }, { "timestamp": 1516583840668, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:17:20 GMT", "status": "200" } }, "timeTaken": "3106" } }, { "timestamp": 1516583838429, "info": { "method": "POST", "path": "/bus/refresh", "headers": { "request": { "host": "localhost:6201", "user-agent": "curl/7.56.1", "accept": "*/*" }, "response": { "X-Application-Context": "config-server:6201", "status": "200" } }, "timeTaken": "4054" } }, { "timestamp": 1516583834702, "info": { "signal": "spring.cloud.bus.sent", "type": "RefreshRemoteApplicationEvent", "id": "7fe840f5-ccd4-45f3-a511-bf13388938a8", "origin": "config-server:6201", "destination": "**:**" } }, { "timestamp": 1516583834702, "info": { "signal": "spring.cloud.bus.ack", "event": "RefreshRemoteApplicationEvent", "id": "7fe840f5-ccd4-45f3-a511-bf13388938a8", "origin": "config-server:6201", "destination": "**" } }, { "timestamp": 1516583673848, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "host": "localhost:6201", "connection": "keep-alive", "user-agent": "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36", "upgrade-insecure-requests": "1", "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8", "accept-encoding": "gzip, deflate, br", "accept-language": "zh-CN,zh;q=0.9" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:14:33 GMT", "status": "200" } }, "timeTaken": "2114" } }, { "timestamp": 1516583643244, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:14:02 GMT", "status": "200" } }, "timeTaken": "1678" } }, { "timestamp": 1516583631731, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:13:51 GMT", "status": "200" } }, "timeTaken": "1260" } }, { "timestamp": 1516583608702, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:13:28 GMT", "status": "200" } }, "timeTaken": "1917" } }, { "timestamp": 1516583596624, "info": { "method": "GET", "path": "/config-client/dev/master", "headers": { "request": { "accept": "application/json, application/*+json", "user-agent": "Java/1.8.0_144", "host": "localhost:6201", "connection": "keep-alive" }, "response": { "X-Application-Context": "config-server:6201", "Content-Type": "application/json;charset=UTF-8", "Transfer-Encoding": "chunked", "Date": "Mon, 22 Jan 2018 01:13:16 GMT", "status": "200" } }, "timeTaken": "4715" } }]

2018-01-21

51单片机总线与非总线的程序对比

不多说，先来非总线型的51的1602液晶显示器的显示程序： #include<reg52.h> #include <intrins.h> #define uchar unsigned

2017-10-07

C#总结（六）EventBus事件总线的使用-自己实现事件总线

事件总线便可以用来解耦并重复利用应用中的逻辑。事件总线带来的好处和引入的问题好处比较明显，就是独立出一个发布订阅模块，调用者可以通过使用这个模块，屏蔽一些线程切换问题，简单地实现发布订阅功能。

2018-03-11

死磕Spark事件总线

是SparkListener，Spark-Streaming的核心监听triat StreamingListener，两者都代表了一类监听的抽象下图是一些监听实体类： ListenerBus 监听器总线对象

2021-07-12

消息总线(Spring Cloud Bus)

spring CloudBus 将分布式的节点和轻量的消息代理连接起来。这可以用于广播配置文件的更改或者其他的管理工作。一个关键的思想就是，消息总线可以为微服务做监控，也可以作为应用程序之间相互通讯。

2017-08-14

温故知新：软件总线

做过程序开发的朋友大多有同款烦恼：项目初期代码清爽简单，随着功能不断叠加，模块之间缠绕成一团乱麻。新增一个功能，要改动十多处关联代码；修改其中一个模块，整套系统都有崩溃风险；不同程序员写的程序语言、运行环境各不相同，想让它们互相调用更是难上加难。

2026-07-23

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。