分享每一天-Liftbridge 是一个实现持久、复制和可扩展的消息日志的服务器

Liftbridge 是一个实现持久、复制和可扩展的消息日志的服务器

GoLang 1132 0 创建时间：2022-09-17 21:14:24

Liftbridge 消息流解决方案

#### Liftbridge简述

Liftbridge 是一个实现持久、复制和可扩展的消息日志的服务器。Liftbridge 的愿景是提供一个“Kafka-lite”解决方案，首先考虑到Go社区的设计。与构建在 JVM 之上且其规范客户端库是 Java（或基于 C 的 librdkafka）的 Kafka 不同，Liftbridge 及其规范客户端 go-liftbridge是在 Go 中实现的。Liftbridge 的最终目标是提供一个轻量级的消息流解决方案，专注于简单性和可用性。

Liftbridge 是在 NATS 之上实现的，NATS是一个轻量级、高性能的发布/订阅消息系统。这意味着它可以添加到现有的 NATS 部署中，以提供消息持久性而无需更改代码。如果您尚未使用 NATS 或不熟悉它，Liftbridge 可以与 NATS 一起部署作为实现细节。

Liftbridge 中的流被分区以实现水平可扩展性。默认情况下，流有一个分区。每个分区都有一个领导者，并被复制到一组跟随者以进行容错。消费者组 提供了实现分布式、可扩展和容错流处理的方法，包括消费者平衡、消费者位置跟踪、自动消费者故障转移。

#### 从源头构建
可以使用 Go从源代码构建和安装 Liftbridge 二进制文件。按照以下步骤从源代码安装。
```go
     go get github.com/liftbridge-io/liftbridge
```
Liftbridge 使用Go 模块，因此请确保已启用此功能，例如export GO111MODULE=on.

Liftbridge 依靠NATS进行集群内通信。默认情况下，它将连接到在 localhost 上运行的 NATS 服务器。该--nats-servers标志允许配置要连接的 NATS 服务器。Liftbridge 还可以运行嵌入在进程中的 NATS 服务器，使其能够作为一个完整的、自包含的系统运行，而无需外部依赖。该--embedded-nats标志将启动嵌入式 NATS 服务器。

另请注意，Liftbridge 默认情况下是集群的，并且依赖于 Raft 进行协调。这意味着通常运行三个或更多服务器的集群以实现高可用性，并且 Raft 管理选举领导者。单个服务器实际上是一个大小为 1 的集群。出于安全目的，服务器不能在不使用--raft-bootstrap-seed标志的情况下选举自己作为领导者，这将指示服务器将自己选举为领导者。这将启动一个可以开始处理请求的服务器。请谨慎使用此标志，因为它只能在引导集群时在一台服务器上设置。

```go
 liftbridge --raft-bootstrap-seed --embedded-nats
INFO[2022-03-11 13:31:30] Liftbridge Version:        v1.9.0
INFO[2022-03-11 13:31:30] Server ID:                 YymOUlm62FeQbn32I3OWSn
INFO[2022-03-11 13:31:30] Namespace:                 liftbridge-default
INFO[2022-03-11 13:31:30] NATS Servers:              [nats://127.0.0.1:4222]
INFO[2022-03-11 13:31:30] Default Retention Policy:  [Age: 1 week, Compact: false]
INFO[2022-03-11 13:31:30] Default Partition Pausing: disabled
INFO[2022-03-11 13:31:30] Starting embedded NATS server on 0.0.0.0:4222
INFO[2022-03-11 13:31:30] Starting Liftbridge server on 0.0.0.0:9292...
INFO[2022-03-11 13:31:32] Server became metadata leader, performing leader promotion actions
```

一旦选出了领导者，其他服务器将自动加入集群。我们设置--data-dirand--port标志以避免破坏第一台服务器。
```go
 liftbridge --data-dir /tmp/liftbridge/server-2 --port=9293
INFO[2022-03-11 13:32:26] Liftbridge Version:        v1.9.0
INFO[2022-03-11 13:32:26] Server ID:                 n9c07sbz0vaVH22HjAyhJw
INFO[2022-03-11 13:32:26] Namespace:                 liftbridge-default
INFO[2022-03-11 13:32:26] NATS Servers:              [nats://127.0.0.1:4222]
INFO[2022-03-11 13:32:26] Default Retention Policy:  [Age: 1 week, Compact: false]
INFO[2022-03-11 13:32:26] Default Partition Pausing: disabled
INFO[2022-03-11 13:32:26] Starting Liftbridge server on 0.0.0.0:9293...
```

我们还可以通过提供显式集群配置来引导集群。为此，我们使用 --raft-bootstrap-peers标志提供集群中参与对等方的 ID。然后，Raft 将处理选举领导者。

```go
   liftbridge --raft-bootstrap-peers server-2,server-3
```

#### 官网文档地址：
 liftbridge.io/docs/quick-start.html

####  github:
 github.com/liftbridge-io/liftbridge

Liftbridge 是一个实现持久、复制和可扩展的消息日志的服务器

商品推荐

广告推荐

推荐文章