问题描述 使用Azure Event Hub服务，除了正常的生产，消费消息以外，如果想拿到Event Hub中存储的历史消息？有什么方法呢？ 问题解答 获取 Event Hubs 存储的历史消息，首先需要确保消息进入Event Hub的时间处于保留期限(Retention Days)内，因为超过这个
问题描述 在使用Azure Service Bus的时候，我们可以根据Queue中目前存在的消息数来判断当前消息是否有积压的情况。 但是，在Event Hub中，因为所有消息都会被存留到预先设定的保留时间(默认是7天)， 所以无法通过消息数来判断当前的消息是否有积压或者是有多余重复消费。 当消费端出
问题描述 在Event Hub的门户页面中，可以通过Process Data页面查看Event Hub中的数据，但是当使用JSON格式预览时（View in JSON），却出现错误。 消息一： No data was found for preview from 'test01'. Make sur
废话不多说(主要文笔比较差),直接上代码 一个简单的demo,如下 vue代码 imgLoaded(e) { deb
1、Solon Cloud Event？ 是 Solon 分布式事件总线的解决方案。也是 Solon “最终一致性”分布式事务的解决方案之一 2、事务特性 事务？就是要求 Event 有原子性，当多个 Event 发布时，要么全成功，要么全失败。 public class EventDemo { p
前言 B树（B-tree），也常被记作 B-树，其中“-”不发音。B树的发明者 Rudolf Bayer 和 Edward M. McCreight 并没有给B树中的 B 明确的定义，大家也不必对此纠结太多。 B+树是B树的变体，两者的适用场景是不一样的，以后也会给大家带来B+树的介绍。 本系列将用
前言 本文为系列文章 B树的定义及数据的插入 数据的读取及遍历（本文） 数据的删除 前一篇文章为大家介绍了 B树 的基本概念及其插入算法。本文将基于前一篇的内容，为大家介绍插入到 B树 中的数据该怎么读取及遍历， 本文的代码基于前一篇文章的代码，已经实现的功能可能会被省略，只介绍新增的功能。 在本文
前言 本文为系列文章 B树的定义及数据的插入 数据的读取及遍历 数据的删除 阅读本文前，建议先复习前两篇文章，以便更好的理解本文。 从删除的数据所在的节点可分为两种情况： 从叶子节点删除数据 从非叶子节点删除数据 无论从叶子节点还是非叶子节点删除数据时都需要保证B树的特性：非根节点每个节点的 key
AsyncLocal 用法简介 通过 AsyncLocal 我们可以在一个逻辑上下文中维护一份私有数据，该上下文后续代码中都可以访问和修改这份数据，但另一个无关的上下文是无法访问的。 无论是在新创建的 Task 中还是 await 关键词之后，我们都能够访问前面设置的 AsyncLocal 的数据。
前言 本文为系列博客 什么是 Task Task 的回调执行与 await async 与 AsyncMethodBuilder（本文） 总结与常见误区（TODO） 上文我们学习了 await 这个语法糖背后的实现，了解了 await 这个关键词是如何去等待 Task 的完成并获取 Task 执行结
LRU缓存替换策略 缓存是一种非常常见的设计，通过将数据缓存到访问速度更快的存储设备中，来提高数据的访问速度，如内存、CPU缓存、硬盘缓存等。 但与缓存的高速相对的是，缓存的成本较高，因此容量往往是有限的，当缓存满了之后，就需要一种策略来决定将哪些数据移除出缓存，以腾出空间来存储新的数据。 这样的策
CAS 的基本概念 CAS（Compare-and-Swap）是一种多线程并发编程中常用的原子操作，用于实现多线程间的同步和互斥访问。 它操作通常包含三个参数：一个内存地址（通常是一个共享变量的地址）、期望的旧值和新值。 CompareAndSwap(内存地址，期望的旧值，新值) CAS 操作会比较
Task.Wait 是 Task 的一个实例方法，用于等待 Task 完成，如果 Task 未完成，会阻塞当前线程。 非必要情况下，不建议使用 Task.Wait，而应该使用 await。 本文将基于 .NET 6 的源码来分析 Task.Wait 的实现，其他版本的实现也是类似的。
# 什么是 long-running thread long-running task 是指那些长时间运行的任务，比如在一个 while True 中执行耗时较长的同步处理。 下面的例子中，我们不断从队列中尝试取出数据，并对这些数据进行处理，这样的任务就适合交给一个 long-running tas
[TOC] # 前言 TimerQueue 是.NET中实现定时任务的核心组件，它是一个定时任务的管理器，负责存储和调度定时任务。它被用于实现很多 .NET 中的定时任务，比如 System.Threading.Timer、Task.Delay、CancellationTokenSource 等。
[TOC] # 前言 上文给大家介绍了 TimerQueue 的任务调度算法。 https://www.cnblogs.com/eventhorizon/p/17557821.html 这边做一个简单的复习。 TimerQueue 中的基本任务单元是 TimerQueueTimer，封装待执行的定时
[TOC] # 什么是系统的可观测性（Observability） 对软件行业来说，可观测性（Observability）是一个舶来词，出自控制论（Control Theory）。 **可观测性是系统的一个属性**，它是指系统的状态能否被观测，也就是说，系统的状态能否被监控、收集、分析、查询、可视化
[TOC] # 前世今生 ## OpenTracing OpenTracing 项目启动于 2016 年，旨在提供一套分布式追踪标准，以便开发人员可以更轻松地实现分布式追踪。 OpenTracing 定义了一套 Tracing 模型，以及一套 API，用于在应用程序中创建和管理这些数据模型。 下面是
2022-11-03 10:58:21.474 INFO --- [pool-7-thread-1] c.a.m.e.PartitionBasedLoadBalancer []: Load balancer already running 2022-11-03 10:58:51.014 WARN --- [ parallel-2] c.a.m.e.Partition
前面我们的EventBus已经弄好了，那么接下来通过EventBus来实现我们的消息推送就是自然而然的事情了。说到消息推送，很多人肯定会想到Websocket，既然我们使用Asp.net core，那么SignalR肯定是我们的首选。接下来就用SignalR来实现我们的消息实时推送。 Notific
