Docker中安装和配置Apache Pulsar实现

docker pull apache/pulsar

version: '3'  # 使用的Docker Compose版本

services:
  # Pulsar 服务定义，负责消息传递的主要工作
  pulsar:
    image: apache/pulsar  # 使用官方的Pulsar镜像
    environment:
      # 配置JVM内存大小
      - PULSAR_MEM="-Xms2g -Xmx2g"  # 设置Pulsar的堆内存大小
      # 设置Pulsar的租户和集群名称
      - PULSAR_TENANT=public  # 设置默认的租户
      - PULSAR_CLUSTER=standalone  # 设置集群名称为"standalone"
      # 配置Zookeeper服务的地址，Pulsar依赖Zookeeper来管理集群元数据
      - PULSAR_ZOOKEEPER_SERVERS=zookeeper:2181  # 指定Zookeeper的服务地址
      # 配置Pulsar的客户端、HTTP、管理服务端口
      - PULSAR_BROKER_SERVICE_PORT=6650  # Pulsar的客户端服务端口
      - PULSAR_HTTP_SERVICE_PORT=8080  # Pulsar的HTTP接口服务端口（用于Web UI）
      - PULSAR_MANAGEMENT_SERVICE_PORT=8090  # Pulsar的管理接口服务端口
    ports:
      # 绑定本地端口到容器端口
      - "6650:6650"  # 映射Pulsar客户端连接端口
      - "8080:8080"  # 映射Web UI端口（用于访问Pulsar Dashboard）
      - "8090:8090"  # 映射管理接口端口
    depends_on:
      # Pulsar依赖于Zookeeper和Bookkeeper服务启动
      - zookeeper
      - bookkeeper
    command: >
      bin/pulsar standalone  # 启动Pulsar的standalone模式（适合单机部署）
    networks:
      - pulsar-net  # 使用名为pulsar-net的网络

  # Zookeeper 服务定义，Pulsar集群的协调服务
  zookeeper:
    image: wurstmeister/zookeeper  # 使用Wurstmeister提供的Zookeeper镜像
    environment:
      - ZOOKEEPER_CLIENT_PORT=2181  # Zookeeper的客户端连接端口
    ports:
      - "2181:2181"  # 映射Zookeeper客户端连接端口
    networks:
      - pulsar-net  # 同样使用pulsar-net网络，以便服务之间通信

  # Bookkeeper 服务定义，Pulsar的持久化存储
  bookkeeper:
    image: apache/pulsar  # 使用Pulsar官方镜像，因为Bookkeeper是Pulsar的一部分
    environment:
      - PULSAR_MEM="-Xms2g -Xmx2g"  # 设置Bookkeeper的JVM内存大小
      - PULSAR_ZOOKEEPER_SERVERS=zookeeper:2181  # 配置Zookeeper地址（Bookkeeper也需要Zookeeper来协调）
      - PULSAR_METRICS_PROVIDER=org.apache.pulsar.broker.PulsarMetricsProvider  # 配置性能度量提供者
    depends_on:
      # Bookkeeper依赖于Zookeeper服务启动
      - zookeeper
    networks:
      - pulsar-net  # 同样使用pulsar-net网络

# 定义网络
networks:
  pulsar-net:
    driver: bridge  # 使用桥接网络驱动程序，确保容器能够相互通信

docker-compose up -d

docker-compose ps

docker exec -it <pulsar_container_id> bash

bin/pulsar-client produce my-topic --messages "Hello Pulsar"

bin/pulsar-client consume my-topic -n 1

using Pulsar.Client;

class Program
{
    static async Task Main(string[] args)
    {
        var client = await PulsarClient.CreateAsync(new ClientConfiguration
        {
            ServiceUrl = "pulsar://localhost:6650"
        });

        var producer = await client.NewProducer()
            .Topic("my-topic")
            .CreateAsync();

        await producer.SendAsync(Encoding.UTF8.GetBytes("Hello Pulsar"));

        var consumer = await client.NewConsumer()
            .Topic("my-topic")
            .SubscriptionName("my-subscription")
            .SubscribeAsync();

        var message = await consumer.ReceiveAsync();
        Console.WriteLine(Encoding.UTF8.GetString(message.Data));

        await client.CloseAsync();
    }
}

docker-compose down