Docker部署pulsar独立集群消息队列服务器

1、下载Pulsar docker 镜像

docker pull apachepulsar/pulsar:latest

2、生成Pulsar容器,把容器的6650和8080端口映射到宿主机的6650和8080端口,standalone参数表示pulsar为独立集群模式,把容器中的conf目录映射到宿主机的/var/lib/docker/volumes/pulsarconf,把容器中的data目录映射到宿主机的/var/lib/docker/volumes/pulsardata

docker run --name pulsar \
-p 6650:6650 \
-p 8080:8080 \
--mount source=pulsardata,target=/pulsar/data \
--mount source=pulsarconf,target=/pulsar/conf \
-d apachepulsar/pulsar bin/pulsar standalone

3、查看所有容器列表

docker ps -a

4、启动容器,可以通过容器名称来启动

docker start pulsar

 5、至此,pulsar消息队列就可以本地使用了,如果还需要外网使用,还需要修改几个文件,通过之前映射的conf目录修改容器中的配置文件,修改完成后 docker restart pulsar 重启容器生效

        5.1、修改/var/lib/docker/volumes/pulsarconf/_data/broker.conf文件,找到advertisedAddress=,后面填写外网能访问到的IP地址。

        5.2、修改/var/lib/docker/volumes/pulsarconf/_data/client.conf文件,找到webServiceUrl=和brokerServiceUrl=, 填写外网能访问的URL地址,注意端口一定要正确。

        5.3、如果需要用Pulsar Assistant 等工具进行远程管理,还需修改/var/lib/docker/volumes/pulsarconf/_data/standalone.conf文件,找到advertisedAddress=,填写外网能直接访问的IP地址。

        5.4、进入容器命令: docker exec -it pulsar /bin/bash

6、安装WEB可视化管理

        6.1、拉取容器

docker pull apachepulsar/pulsar-manager:latest

        6.2、生成容器,并启动容器


docker run -it 、--name pulsar-manager 、-p 9527:9527 -p 7750:7750 \--mount source=pulsarmanager,target=/pulsar-manager/pulsar-manager \-e SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties \apachepulsar/pulsar-manager:latest

 Pulsar Manager 分为前端和后端,前端服务端口为 9527,后端服务端口为 7750。
    SPRING_CONFIGURATION_FILE:spring的默认配置文件。
    默认情况下,Pulsar Manager 使用 herddb 数据库。

        6.3、设置管理员账号密码

CSRF_TOKEN=$(curl http://localhost:7750/pulsar-manager/csrf-token)
curl \-H 'X-XSRF-TOKEN: $CSRF_TOKEN' \-H 'Cookie: XSRF-TOKEN=$CSRF_TOKEN;' \-H "Content-Type: application/json" \-X PUT http://localhost:7750/pulsar-manager/users/superuser \-d '{"name": "admin", "password": "apachepulsar", "description": "test", "email": "username@test.org"}'

7、如果要打开 JWT 身份验证,请配置该文件。application.properties

backend.jwt.token=tokenjwt.broker.token.mode=PRIVATE
jwt.broker.public.key=file:///path/broker-public.key
jwt.broker.private.key=file:///path/broker-private.keyor
jwt.broker.token.mode=SECRET
jwt.broker.secret.key=file:///path/broker-secret.key
  • backend.jwt.token:超级用户的令牌。您需要在集群初始化时配置该参数。
  • jwt.broker.token.mode:多种代币生成模式,包括 PUBLIC、PRIVATE 和 SECRET。
  • jwt.broker.public.key:如果使用 PUBLIC 模式,请配置此选项。
  • jwt.broker.private.key:如果使用 PRIVATE 模式,请配置此选项。
  • jwt.broker.secret.key:如果使用 SECRET 模式,请配置此选项。 更多信息,请参见 Pulsar 的 Token 认证管理员

        7.1、Docker 命令添加配置文件和密钥文件挂载:

docker run -it \--name pulsar-manager \-p 9527:9527 -p 7750:7750 \--mount source=pulsarmanager,target=/pulsar-manager/pulsar-manager \-v /宿主机路径/private.key:/pulsar-manager/private.key-e SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties \apachepulsar/pulsar-manager:latest

         

8、pulsar-manager界面小常识

       8.1、进入http://x.x.x.x:9527,输入管理员账号密码登录,进入页面第一步先建立个环境。

         8.2、进入刚刚新建的环境,可以看到有以下几个概念: 租户、命名空间、订阅主题、角色。这时租户界面:

这是命名空间:

 

这是订阅主题:

 

 这几个概念对应订阅URL中路径:non-persistent://public/test_namespace/test2_topic

non-persistent: 表示非持久化

public: 租户

test_namespace: 命名空间

test2_topic: 订阅主题名称

消息生产者,可以生产不同主题的消息,只有订阅此主题的消费者才能收到消息。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/20746.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【QEMU中文文档】1.1 支持的构建平台

本文由 AI 翻译(ChatGPT-4)完成,并由作者进行人工校对。如有任何问题或建议,欢迎联系我。联系方式:jelin-shoutlook.com。 原文:Supported build platforms — QEMU documentation QEMU 旨在支持在多个主机…

Apache Calcite - 使用内置函数

前言 在上一篇文章中学习了如何适配来源数据,并使用sql查询数据。当我们获取数据后,通常还会进行各种计算、变换工作,这时使用内置函数可以极大提高我们的效率。 函数介绍 Apache Calcite 提供了广泛的 SQL 函数支持,包括但不限…

基础—SQL—DCL(数据控制语言)小结

一、总结 在SQL分类中的DCL语句部分,主要讲到了两个部分的知识。 1、用户管理 用户管理,主要是管理哪些用户可以访问当前 mysql 数据库。 包括:创建用户、修改用户密码以及删除用户 2、权限控制 权限管理,主要是控制我们当前用户…

vue前端Echars

<template><div :class"className" :style"{height:height,width:width}" /> </template><script> import * as echarts from echarts require(echarts/theme/macarons) // echarts theme 柱状图 import resize from ./mixins/re…

代码随想录算法训练营Day24|216.组合总和III、17.电话号码的字母组合

组合总和III 216. 组合总和 III - 力扣&#xff08;LeetCode&#xff09; 思路和昨日的组合题类似&#xff0c;但注意对回溯算法中&#xff0c;收获时的条件需要写对&#xff0c;path的长度要为k的同时&#xff0c;path中元素总和要为n。 class Solution { public:vector<…

禁用USB端口的办法,哪一种禁用USB端口的方法好

禁用USB端口的办法&#xff0c;哪一种禁用USB端口的方法好 禁用USB端口是保护公司数据安全的一种常见做法&#xff0c;旨在防止未经授权的数据传输和潜在的恶意软件传播。以下是几种常见的禁用USB端口方法及其效果评价。 1、硬件方法&#xff1a; BIOS设置&#xff1a;通过BIO…

混合动力电动汽车介绍(一)

电动汽车发展的技术背景主要包含环境问题和能源问题两大方面。环境问题的表现形式为空气污染&#xff0c;而能源问题的表现形式为现有能源供应体系对化石燃料的过分依赖。《新能源汽车产业发展规划&#xff08;2021-2035&#xff09;》中明确我国新能源汽车技术研发的“三纵”、…

探索Python机器学习:从基础到实践

探索Python机器学习&#xff1a;从基础到实践 本文将带您从机器学习的基础知识出发&#xff0c;逐步深入到实际应用&#xff0c;帮助您掌握Python机器学习的核心技能。 一、机器学习概述 1. 什么是机器学习&#xff1f; 机器学习是一种通过分析数据来自动发现模式并做出预测…

软件架构设计属性之5:可维护性属性分析与应用

文章目录 引言一、可维护性定义和重要性1.1 定义1.2 重要性 二、可维护性关键要素2.1 模块化2.2 单一职责2.3 低耦合2.4 高内聚2.5 抽象和封装2.6 实践建议 三、设计原则3.1 开闭原则3.2 依赖倒置原则3.3 评估方法3.4 挑战与解决方案 四、实战应用总结 引言 在当今数字化飞速发…

Java学习路径图

1.学习路径 JAVA架构师学习路径 2.路径拆解 2.1 Spring 2.1.1 SpringBoot原理 SpringBoot2学习视频 SpringBoot2笔记 SpringBoo2代码 2.2.2 SpringBoot项目 《谷粒商城》学习视频

Implicit-SDF-Planner代码详解(2)

Implicit-SDF-Planner代码详解&#xff08;2&#xff09; 第三部分:轨迹优化 在获得了一条初始路径后,下一步就是在此基础上生成一条光滑、安全、动力学可行的轨迹,这就是轨迹优化要解决的问题。 让我们回到plan_manager.cpp,看看PlannerManager的generateTraj函数: void P…

IPv6在军事中的价值

计算机网络作为信息传输的主要通道&#xff0c;将在未来战场上发挥主导作用。当前的网络是基于IPv4协议构建的&#xff0c;然而&#xff0c;IPv4面临着一系列问题&#xff0c;如地址枯竭、路由瓶颈等&#xff0c;这些问题导致网络安全和服务质量难以适应军事网络的高速发展。在…

一文了解JVM面试篇(上)

Java内存区域 1、如何解释 Java 堆空间及 GC? 当通过 Java 命令启动 Java 进程的时候,会为它分配内存。内存的一部分用于创建 堆空间,当程序中创建对象的时候,就从对空间中分配内存。GC 是 JVM 内部的一 个进程,回收无效对象的内存用于将来的分配。 2、JVM 的主要组成…

前端工程化工具系列(四)—— Commitlint(v19.3.0):规范化 Git 提交

commitlint 是对 Git 提交的信息进行校验的工具。 1. 环境要求 v19 以上的 Stylelint&#xff0c;支持 Node.js 的版本为 v18 。 在命令行中输入以下内容来查看当前系统中 node 的版本。 node -vNode.js 推荐使用 v18.20.3 或者 v20.13.1。 这里使用的包管理器是 PNPM&#…

NextJs 数据篇 - 数据获取 | 缓存 | Server Actions

NextJs 数据篇 - 数据获取 | 缓存 | Server Actions 前言一. 数据获取 fetch1.1 缓存 caching① 服务端组件使用fetch② 路由处理器 GET 请求使用fetch 1.2 重新验证 revalidating① 基于时间的重新验证② 按需重新验证revalidatePathrevalidateTag 1.3 缓存的退出方式 二. Ser…

PostgreSQL的多态函数

项目中遇到一个需求,需要模拟Oracle的NVL2函数实现一个对应功能的函数 于是就写了一个自定义函数 CREATE OR REPLACE FUNCTION bkdb3.nvl2(expr anyelement, expr2 anyelement, expr3 anyelement)RETURNS anyelementLANGUAGE plpgsql AS $$ BEGINIF expr IS NOT NULL AND expr…

windows操作系统提权之服务提权实战rottenpotato

RottenPotato&#xff1a; 将服务帐户本地提权至SYSTEM load incognito list_tokens –u upload /home/kali/Desktop rottenpotato.exe . execute -Hc -f rottenpotato.exe impersonate_token "NT AUTHORITY\SYSTEM" load incognito 这条命令用于加载 Metasploi…

vue 关闭页面前释放资源

mounted() {window.addEventListener(beforeunload, e > this.handleBeforeUnload(e)) }beforeDestroy() {//监听-关闭页面的时候释放资源window.removeEventListener(beforeunload, e > this.handleBeforeUnload(e))},methods: {handleBeforeUnload(event){event.preven…

【Linux】在Windows环境下配置两台Linux机器的文件互传

相信有很多云服务器小伙伴都有想把一台linux资源传到另一台机器&#xff0c;那么该怎样实现&#xff1f; 本篇文章的演示案例都是基于centous进行传输&#xff0c;ubuntu进行接收&#xff01; 别的方法也都是一样的&#xff01; 方法一&#xff08;基于xshell进行的压缩包win…

Java项目:92 基于SSM的办公管理系统

作者主页&#xff1a;舒克日记 简介&#xff1a;Java领域优质创作者、Java项目、学习资料、技术互助 文中获取源码 基于SSM的办公管理系统 1、项目介绍 基于SSM的办公管理系统主要是对于办公用品的申领进行管理&#xff0c;系统分为三种角色&#xff0c;超级管理员、企业 职…