NixBus

NixBus：简化事件驱动开发

NixBus 是一个基于 HTTP 的安全、强大且高效的事件总线，旨在简化事件驱动开发并增强微服务架构。它允许开发人员解耦应用程序服务并遵循 SOLID 原则，而无需传统事件总线系统的复杂性。

什么是 NixBus？

NixBus 是一个基于 HTTP 的事件总线，为服务间通信提供了一个简单、安全且可扩展的解决方案。它提供了一种简单的方式来与现有基础设施集成，并确保强大而高效的事件处理。

NixBus 的主要特性

• 简单集成： NixBus 可以使用 NPM 包或 HTTP API 轻松集成到现有基础设施中。
• 安全通信： 所有数据都经过端到端加密，确保事件安全可靠。
• 可扩展且灵活： NixBus 可以根据您的需求进行扩展，无论您运行的是小型应用程序还是复杂的微服务架构。
• 内存选项： 对于较小的应用程序，可以使用内存事件总线，以避免持久存储的复杂性。

NixBus 如何工作？

NixBus 通过允许服务通过 HTTP 发布和订阅事件来简化事件驱动架构。以下是一个基本概述：

1. 安装： 使用 npm install @nixbus/event-bus --save -E 安装 NixBus NPM 包。
2. 创建事件总线： 创建一个事件总线文件，使用您的令牌和密码短语对其进行配置，并订阅相关事件。
3. 发布事件： 从应用程序中的任何位置将事件发布到事件总线。
4. 运行事件总线： 执行事件总线以开始处理事件。

使用场景

• 微服务通信： 通过解耦服务并确保强大的服务间交互，实现微服务之间的无缝通信。
• 实时应用程序： 适用于需要实时数据更新的应用程序，例如聊天应用程序、实时仪表板和通知系统。
• 事件驱动架构： 促进构建事件驱动系统，允许服务及时有效地响应事件。

定价

NixBus 提供多种根据不同需求量身定制的令牌选项：

• 免费：
  • 每日使用 500 个事件
  • 50,000 个事件储备（随时使用）
  • 3 天事件保留期
  • 最多 5 个订阅者
  • 1 个月令牌有效期
• Pro（€15）：
  • 每日 2,500 个事件
  • 500,000 个事件储备（随时使用）
  • 7 天事件保留期
  • 最多 20 个订阅者
  • 区域选择
  • 永不过期的令牌
• 自定义：
  • 量身定制的事件使用量和储备
  • 直接支持
  • 适用于高需求环境

如何使用 NixBus

1. 安装 NixBus：

   npm install @nixbus/event-bus --save -E
   

2. 创建事件总线：

   创建一个 event-bus.ts 文件，并使用您的令牌和密码短语配置事件总线：

   import { getNixBusHttp } from '@nixbus/event-bus'
   
   async function main() {
     const nixbus = getNixBusHttp({
       token: 'your_token',
       passphrase: 'your_passphrase',
     })
   
     await nixbus.subscribe('event_type', {
       id: 'subscriber_id',
       action: async (event) => {
         console.log('subscriber_id:', event)
       },
       config: {
         maxRetries: 3,
         timeout: 10,
         concurrency: 5
       },
     })
   
     nixbus.run()
   }
   
   main().catch(console.error)
   

3. 发布事件：

   从您的应用程序发布事件：

   import { getNixBusHttp } from '@nixbus/event-bus'
   
   async function runYourApp() {
     const nixbus = getNixBusHttp({
       token: 'your_token',
       passphrase: 'your_passphrase',
     })
   
     await nixbus.publish({
       type: 'event_type',
       payload: { welcome: 'to the event bus 0' },
     })
   
     // Simulate a delay before publishing another event
     await new Promise((resolve) => setTimeout(resolve, 2000))
   
     await nixbus.publish({
       type: 'event_type',
       payload: { welcome: 'to the event bus 1' },
     })
   }
   
   runYourApp().catch(console.error)
   

4. 运行事件总线和应用程序：

   执行事件总线和应用程序：

   tsx event-bus.ts
   tsx app.ts
   

结论

NixBus 提供了一个简单而高效的解决方案，用于实现事件驱动架构，简化微服务通信并确保安全且可扩展的事件处理。无论您是构建小型应用程序还是管理复杂系统，NixBus 都能提供简化开发过程所需的灵活性和工具。立即开始发送事件，并使用 NixBus 释放事件驱动架构的强大功能。