docker pull apache/pulsar

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

services:
  # Pulsar 服務(wù)定義，負(fù)責(zé)消息傳遞的主要工作
  pulsar:
    image: apache/pulsar  # 使用官方的Pulsar鏡像
    environment:
      # 配置JVM內(nèi)存大小
      - PULSAR_MEM="-Xms2g -Xmx2g"  # 設(shè)置Pulsar的堆內(nèi)存大小
      # 設(shè)置Pulsar的租戶和集群名稱
      - PULSAR_TENANT=public  # 設(shè)置默認(rèn)的租戶
      - PULSAR_CLUSTER=standalone  # 設(shè)置集群名稱為"standalone"
      # 配置Zookeeper服務(wù)的地址，Pulsar依賴Zookeeper來管理集群元數(shù)據(jù)
      - PULSAR_ZOOKEEPER_SERVERS=zookeeper:2181  # 指定Zookeeper的服務(wù)地址
      # 配置Pulsar的客戶端、HTTP、管理服務(wù)端口
      - PULSAR_BROKER_SERVICE_PORT=6650  # Pulsar的客戶端服務(wù)端口
      - PULSAR_HTTP_SERVICE_PORT=8080  # Pulsar的HTTP接口服務(wù)端口（用于Web UI）
      - PULSAR_MANAGEMENT_SERVICE_PORT=8090  # Pulsar的管理接口服務(wù)端口
    ports:
      # 綁定本地端口到容器端口
      - "6650:6650"  # 映射Pulsar客戶端連接端口
      - "8080:8080"  # 映射Web UI端口（用于訪問Pulsar Dashboard）
      - "8090:8090"  # 映射管理接口端口
    depends_on:
      # Pulsar依賴于Zookeeper和Bookkeeper服務(wù)啟動(dòng)
      - zookeeper
      - bookkeeper
    command: >
      bin/pulsar standalone  # 啟動(dòng)Pulsar的standalone模式（適合單機(jī)部署）
    networks:
      - pulsar-net  # 使用名為pulsar-net的網(wǎng)絡(luò)

  # Zookeeper 服務(wù)定義，Pulsar集群的協(xié)調(diào)服務(wù)
  zookeeper:
    image: wurstmeister/zookeeper  # 使用Wurstmeister提供的Zookeeper鏡像
    environment:
      - ZOOKEEPER_CLIENT_PORT=2181  # Zookeeper的客戶端連接端口
    ports:
      - "2181:2181"  # 映射Zookeeper客戶端連接端口
    networks:
      - pulsar-net  # 同樣使用pulsar-net網(wǎng)絡(luò)，以便服務(wù)之間通信

  # Bookkeeper 服務(wù)定義，Pulsar的持久化存儲(chǔ)
  bookkeeper:
    image: apache/pulsar  # 使用Pulsar官方鏡像，因?yàn)锽ookkeeper是Pulsar的一部分
    environment:
      - PULSAR_MEM="-Xms2g -Xmx2g"  # 設(shè)置Bookkeeper的JVM內(nèi)存大小
      - PULSAR_ZOOKEEPER_SERVERS=zookeeper:2181  # 配置Zookeeper地址（Bookkeeper也需要Zookeeper來協(xié)調(diào)）
      - PULSAR_METRICS_PROVIDER=org.apache.pulsar.broker.PulsarMetricsProvider  # 配置性能度量提供者
    depends_on:
      # Bookkeeper依賴于Zookeeper服務(wù)啟動(dòng)
      - zookeeper
    networks:
      - pulsar-net  # 同樣使用pulsar-net網(wǎng)絡(luò)

# 定義網(wǎng)絡(luò)
networks:
  pulsar-net:
    driver: bridge  # 使用橋接網(wǎng)絡(luò)驅(qū)動(dòng)程序，確保容器能夠相互通信

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