#安装时会默认安装erlang相关依赖包。 #加入系统自动启动并立即运行rabbit systemctl enable rabbitmq-server.service --now

## 2. 配置hosts文件

在所有节点上编辑hosts文件,将各节点的IP地址和主机名映射到一起。这样可以通过主机名进行通信,而不是依赖IP地址。

这个就不在讲了,直接编辑 /etc/hosts这个文件即可

个人主机内容参考如下:

127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 ::1 localhost localhost.localdomain localhost6 localhost6.localdomain6

110.110.10.5 host1 110.110.10.6 host2 110.110.10.7 host3

## 3. 配置rabbit集群

一般情况下一个节点的rabbit也差不多够用了,但为了稳定性使用高可用集群还是有必要的,配置集群可以直接编辑每个节点上的RabbitMQ配置文件,可以在/etc/rabbitmq/rabbitmq.conf中修改。常见的配置项:

# 节点名称

node\_name = rabbit@node1

# 集群节点列表

cluster\_nodes = {['rabbit@node1', 'rabbit@node2', 'rabbit@node3'], disc}

# Cookie值,用于节点间通信

erlang\_cookie = abcde12345fghij

还有自定义rabbit的ip,各类服务端口,还有ssl等高级配置在这里不说了。

注意,这些配置项必须在所有节点上保持一致。

### 命令方式配置集群

**默认情况下rabbit会直接获取hostname作为节点名,所以不用去配置文件中修改,这里主要讲使用命令直接配置和启动rabbit集群。**

先配置管理节点,再将管理节点cookie复制到其他节点

for i in {host1,host2,host3};do ssh $i systemctl stop rabbitmq-server;done for i in {host1,host2,host3};do scp /var/lib/rabbitmq/.erlang.cookie $i:/var/lib/rabbitmq/.erlang.cookie;done for i in {host1,host2,host3};do ssh $i chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie;done for i in {host1,host2,host3};do ssh $i chmod 400 /var/lib/rabbitmq/.erlang.cookie;done for i in {host1,host2,host3};do ssh $i systemctl start rabbitmq-server;done

###节点加入集群,从拟定的主节点以外的其他节点操作,新加入节点操作也一样。; rabbitmqctl stop_app rabbitmqctl join_cluster --ram rabbit@host1 rabbitmqctl start_app

查看rabbitmq集群服务状态,每加入一个节点都可以查看一下是否加入成功

rabbitmqctl cluster_status

单个新节点加入集群操作,在新节点上操作,与上面多节点操作基本一致。

systemctl stop rabbitmq-server scp host1:/var/lib/rabbitmq/.erlang.cookie /var/lib/rabbitmq/.erlang.cookie chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie chmod 400 /var/lib/rabbitmq/.erlang.cookie systemctl start rabbitmq-server rabbitmqctl stop_app rabbitmqctl join_cluster --ram rabbit@host1 rabbitmqctl start_app

### 读写测试

写入和读取测试:

python

import pika

连接到 rabbitmq 服务器

connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost’)) channel = connection.channel()

定义队列名称

queue_name = ‘test_queue’

向队列写入消息

channel.queue_declare(queue=queue_name) channel.basic_publish(exchange=‘’, routing_key=queue_name, body=‘Hello World!’) print(" [x] Sent ‘Hello World!’")

从队列中读取消息

method_frame, header_frame, body = channel.basic_get(queue=queue_name, auto_ack=True) if method_frame: print(" [x] Received %r" % body) else: print(‘No message returned’)

关闭连接

connection.close()

在上述代码中,我们首先连接到了本地的 rabbitmq 服务器。然后定义了一个名为 test_queue 的队列,并向队列中写入了一条消息:Hello World!。接着,我们又从队列中读取了一条消息,并将其打印出来。

### 在Node.js中使用RabbitMQ

在Node.js中使用RabbitMQ需要先安装amqplib库,可以通过npm进行安装: npm install amqplib

##以下是使用RabbitMQ的基本步骤: ##建立与RabbitMQ服务器的连接 const amqp = require(‘amqplib’); amqp.connect(‘amqp://localhost’).then(function(conn) { //执行后续操作 });

###创建通道(channel) conn.createChannel().then(function(ch) { //执行后续操作 });

#发送消息 const queueName = “hello”; ch.assertQueue(queueName, { durable: false }); ch.sendToQueue(queueName, new Buffer(‘Hello World!’));

接收消息

const queueName = “hello”; ch.assertQueue(queueName, { durable: false }); ch.consume(queueName, function(msg) { console.log(“Received message: %s”, msg.content.toString()); }, { noAck: true });

#######完整示例代码:

const amqp = require(‘amqplib’);

amqp.connect(‘amqp://localhost’).then(function(conn) { conn.createChannel().then(function(ch) { const queueName = “hello”; ch.assertQueue(queueName, { durable: false }); ch.sendToQueue(queueName, new Buffer(‘Hello World!’));

ch.assertQueue(queueName, { durable: false });

ch.consume(queueName, function(msg) {

console.log("Received message: %s", msg.content.toString());

}, { noAck: true });

}); }).catch(function(err) { console.log(‘Error:’, err); });

##

## 4. 常用管理命令

#添加新用户 sudo rabbitmqctl add_user username password

#删除用户 sudo rabbitmqctl delete_user username

#分配用户权限 sudo rabbitmqctl set_permissions -p / virtual-hostname ‘username’ ‘.’ '.’ ‘.*’

#查看用户列表 sudo rabbitmqctl list_users

#查看队列列表 sudo rabbitmqctl list_queues

#查看交换机列表 sudo rabbitmqctl list_exchanges

#查看绑定列表 sudo rabbitmqctl list_bindings

#查看 vhost 列表 sudo rabbitmqctl list_vhosts

#查看某个 vhost 的权限控制列表 sudo rabbitmqctl list_permissions -p virtual-hostname

#查看 RabbitMQ 服务器信息 sudo rabbitmqctl status

## 5. 设置集群policy设置

##语句格式 rabbitmqctl set_policy [-p ] rabbitmqctl clear_policy [-p ] rabbitmqctl list_policies [-p ]

[ host1 ] 设置 ha-mode 高可用模式

rabbitmqctl set_policy ha-all ‘^(?!amq.).*’ ‘{“ha-mode”: “all”}’;

置一个队列的最大长度为1000条消息:

rabbitmqctl set_policy max-length-1000 “^my-queue$” ‘{“max-length”:1000}’ --apply-to queues

## 6. 启用web面板插件

启用web插件

rabbitmq-plugins enable rabbitmq_management

##在本服务器或者同网段其他主机打开浏览器即可访问rabbitmq集群状态和管理页面

![](https://img-blog.csdnimg.cn/e393bc34c237446ebc6c6687347a4d9e.png)

使用前面命令添加用户并设置为管理员即可登陆web界面。 

![](https://img-blog.csdnimg.cn/73962817eaad4832aac7c4aa9d3c706c.png)

## 7. rabbitmq配置文件参考

###一般情况下不用在这里修改配置文件,但自定义参数的时候还是很有用的。 cat /etc/rabbitmq/rabbitmq.conf

This example configuration file demonstrates various settings

available via rabbitmq.conf. It primarily focuses core broker settings

but some tier 1 plugin settings are also covered.

This file is AN EXAMPLE. It is NOT MEANT TO BE USED IN PRODUCTION. Instead of

copying the entire (large!) file, create or generate a new rabbitmq.conf for the target system

and populate it with the necessary settings.

See https://rabbitmq.com/configure.html to learn about how to configure RabbitMQ,

the ini-style format used by rabbitmq.conf, how it is different from advanced.config,

how to verify effective configuration, and so on.

See https://rabbitmq.com/documentation.html for the rest of RabbitMQ documentation.

In case you have questions, please use RabbitMQ community Slack and the rabbitmq-users Google group

instead of GitHub issues.

======================================

Core broker section

======================================

####这下面的5672,5671如果已经被占用时或者为了安全考虑可修改为其他端口,在服务应用时也需要调整成新的端口

Networking

====================

Related doc guide: https://rabbitmq.com/networking.html.

By default, RabbitMQ will listen on all interfaces, using

the standard (reserved) AMQP 0-9-1 and 1.0 port.

listeners.tcp.default = 5672

To listen on a specific interface, provide an IP address with port.

For example, to listen only on localhost for both IPv4 and IPv6:

IPv4

listeners.tcp.local = 127.0.0.1:5672

IPv6

listeners.tcp.local_v6 = ::1:5672

You can define multiple listeners using listener names

listeners.tcp.other_port = 5673

listeners.tcp.other_ip = 10.10.10.10:5672

TLS listeners are configured in the same fashion as TCP listeners,

including the option to control the choice of interface.

listeners.ssl.default = 5671

It is possible to disable regular TCP (non-TLS) listeners. Clients

not configured to use TLS and the correct TLS-enabled port won’t be able

to connect to this node.

listeners.tcp = none

Number of Erlang processes that will accept connections for the TCP

and TLS listeners.

num_acceptors.tcp = 10

num_acceptors.ssl = 10

Socket writer will force GC every so many bytes transferred.

Default is 1 GiB (1000000000). Set to ‘off’ to disable.

socket_writer.gc_threshold = 1000000000

To disable:

socket_writer.gc_threshold = off

Maximum amount of time allowed for the AMQP 0-9-1 and AMQP 1.0 handshake

(performed after socket connection and TLS handshake) to complete, in milliseconds.

handshake_timeout = 10000

Set to ‘true’ to perform reverse DNS lookups when accepting a

connection. rabbitmqctl and management UI will then display hostnames

instead of IP addresses. Default value is false.

reverse_dns_lookups = false

Security, Access Control

==============

Related doc guide: https://rabbitmq.com/access-control.html.

The default “guest” user is only permitted to access the server

via a loopback interface (e.g. localhost).

{loopback_users, [<<“guest”>>]},

loopback_users.guest = true

Uncomment the following line if you want to allow access to the

guest user from anywhere on the network.

loopback_users.guest = false

TLS configuration.

Related doc guide: https://rabbitmq.com/ssl.html.

listeners.ssl.1 = 5671

ssl_options.verify = verify_peer

ssl_options.fail_if_no_peer_cert = false

ssl_options.cacertfile = /path/to/cacert.pem

ssl_options.certfile = /path/to/cert.pem

ssl_options.keyfile = /path/to/key.pem

ssl_options.honor_cipher_order = true

ssl_options.honor_ecc_order = true

These are highly recommended for TLSv1.2 but cannot be used

with TLSv1.3. If TLSv1.3 is enabled, these lines MUST be removed.

ssl_options.client_renegotiation = false

ssl_options.secure_renegotiate = true

Limits what TLS versions the server enables for client TLS

connections. See https://www.rabbitmq.com/ssl.html#tls-versions for details.

Cutting edge TLS version which requires recent client runtime

versions and has no cipher suite in common with earlier TLS versions.

ssl_options.versions.1 = tlsv1.3

Enables TLSv1.2 for best compatibility

ssl_options.versions.2 = tlsv1.2

Older TLS versions have known vulnerabilities and are being phased out

from wide use.

Limits what cipher suites the server will use for client TLS

connections. Narrowing this down can prevent some clients

from connecting.

If TLSv1.3 is enabled and cipher suites are overridden, TLSv1.3-specific

cipher suites must also be explicitly enabled.

See https://www.rabbitmq.com/ssl.html#cipher-suites and https://wiki.openssl.org/index.php/TLS1.3#Ciphersuites

for details.

The example below uses TLSv1.3 cipher suites only

ssl_options.ciphers.1 = TLS_AES_256_GCM_SHA384

ssl_options.ciphers.2 = TLS_AES_128_GCM_SHA256

ssl_options.ciphers.3 = TLS_CHACHA20_POLY1305_SHA256

ssl_options.ciphers.4 = TLS_AES_128_CCM_SHA256

ssl_options.ciphers.5 = TLS_AES_128_CCM_8_SHA256

The example below uses TLSv1.2 cipher suites only

ssl_options.ciphers.1 = ECDHE-ECDSA-AES256-GCM-SHA384

ssl_options.ciphers.2 = ECDHE-RSA-AES256-GCM-SHA384

ssl_options.ciphers.3 = ECDHE-ECDSA-AES256-SHA384

ssl_options.ciphers.4 = ECDHE-RSA-AES256-SHA384

ssl_options.ciphers.5 = ECDH-ECDSA-AES256-GCM-SHA384

ssl_options.ciphers.6 = ECDH-RSA-AES256-GCM-SHA384

ssl_options.ciphers.7 = ECDH-ECDSA-AES256-SHA384

ssl_options.ciphers.8 = ECDH-RSA-AES256-SHA384

ssl_options.ciphers.9 = DHE-RSA-AES256-GCM-SHA384

ssl_options.ciphers.10 = DHE-DSS-AES256-GCM-SHA384

ssl_options.ciphers.11 = DHE-RSA-AES256-SHA256

ssl_options.ciphers.12 = DHE-DSS-AES256-SHA256

ssl_options.ciphers.13 = ECDHE-ECDSA-AES128-GCM-SHA256

ssl_options.ciphers.14 = ECDHE-RSA-AES128-GCM-SHA256

ssl_options.ciphers.15 = ECDHE-ECDSA-AES128-SHA256

ssl_options.ciphers.16 = ECDHE-RSA-AES128-SHA256

ssl_options.ciphers.17 = ECDH-ECDSA-AES128-GCM-SHA256

ssl_options.ciphers.18 = ECDH-RSA-AES128-GCM-SHA256

ssl_options.ciphers.19 = ECDH-ECDSA-AES128-SHA256

ssl_options.ciphers.20 = ECDH-RSA-AES128-SHA256

ssl_options.ciphers.21 = DHE-RSA-AES128-GCM-SHA256

ssl_options.ciphers.22 = DHE-DSS-AES128-GCM-SHA256

ssl_options.ciphers.23 = DHE-RSA-AES128-SHA256

ssl_options.ciphers.24 = DHE-DSS-AES128-SHA256

ssl_options.ciphers.25 = ECDHE-ECDSA-AES256-SHA

ssl_options.ciphers.26 = ECDHE-RSA-AES256-SHA

ssl_options.ciphers.27 = DHE-RSA-AES256-SHA

ssl_options.ciphers.28 = DHE-DSS-AES256-SHA

ssl_options.ciphers.29 = ECDH-ECDSA-AES256-SHA

ssl_options.ciphers.30 = ECDH-RSA-AES256-SHA

ssl_options.ciphers.31 = ECDHE-ECDSA-AES128-SHA

ssl_options.ciphers.32 = ECDHE-RSA-AES128-SHA

ssl_options.ciphers.33 = DHE-RSA-AES128-SHA

ssl_options.ciphers.34 = DHE-DSS-AES128-SHA

ssl_options.ciphers.35 = ECDH-ECDSA-AES128-SHA

ssl_options.ciphers.36 = ECDH-RSA-AES128-SHA

ssl_options.bypass_pem_cache = true

Select an authentication/authorisation backend to use.

Alternative backends are provided by plugins, such as rabbitmq-auth-backend-ldap.

NB: These settings require certain plugins to be enabled.

Related doc guides:

* https://rabbitmq.com/plugins.html

* https://rabbitmq.com/access-control.html

auth_backends.1 = rabbit_auth_backend_internal

uses separate backends for authentication and authorisation,

see below.

auth_backends.1.authn = rabbit_auth_backend_ldap

auth_backends.1.authz = rabbit_auth_backend_internal

The rabbitmq_auth_backend_ldap plugin allows the broker to

perform authentication and authorisation by deferring to an

external LDAP server.

Relevant doc guides:

* https://rabbitmq.com/ldap.html

* https://rabbitmq.com/access-control.html

uses LDAP for both authentication and authorisation

auth_backends.1 = rabbit_auth_backend_ldap

uses HTTP service for both authentication and

authorisation

auth_backends.1 = rabbit_auth_backend_http

uses two backends in a chain: HTTP first, then internal

auth_backends.1 = rabbit_auth_backend_http

auth_backends.2 = rabbit_auth_backend_internal

Authentication

The built-in mechanisms are ‘PLAIN’,

‘AMQPLAIN’, and ‘EXTERNAL’ Additional mechanisms can be added via

plugins.

Related doc guide: https://rabbitmq.com/authentication.html.

auth_mechanisms.1 = PLAIN

auth_mechanisms.2 = AMQPLAIN

The rabbitmq-auth-mechanism-ssl plugin makes it possible to

authenticate a user based on the client’s x509 (TLS) certificate.

Related doc guide: https://rabbitmq.com/authentication.html.

To use auth-mechanism-ssl, the EXTERNAL mechanism should

be enabled:

auth_mechanisms.1 = PLAIN

auth_mechanisms.2 = AMQPLAIN

auth_mechanisms.3 = EXTERNAL

To force x509 certificate-based authentication on all clients,

exclude all other mechanisms (note: this will disable password-based

authentication even for the management UI!):

auth_mechanisms.1 = EXTERNAL

This pertains to both the rabbitmq-auth-mechanism-ssl plugin and

STOMP ssl_cert_login configurations. See the RabbitMQ STOMP plugin

configuration section later in this file and the README in

https://github.com/rabbitmq/rabbitmq-auth-mechanism-ssl for further

details.

To use the TLS cert’s CN instead of its DN as the username

ssl_cert_login_from = common_name

TLS handshake timeout, in milliseconds.

ssl_handshake_timeout = 5000

Cluster name

cluster_name = dev3.eng.megacorp.local

Password hashing implementation. Will only affect newly

created users. To recalculate hash for an existing user

it’s necessary to update her password.

To use SHA-512, set to rabbit_password_hashing_sha512.

password_hashing_module = rabbit_password_hashing_sha256

When importing definitions exported from versions earlier

than 3.6.0, it is possible to go back to MD5 (only do this

as a temporary measure!) by setting this to rabbit_password_hashing_md5.

password_hashing_module = rabbit_password_hashing_md5

Default User / VHost

====================

On first start RabbitMQ will create a vhost and a user. These

config items control what gets created.

Relevant doc guide: https://rabbitmq.com/access-control.html

default_vhost = /

default_user = guest

default_pass = guest

default_permissions.configure = .*

default_permissions.read = .*

default_permissions.write = .*

Tags for default user

For more details about tags, see the documentation for the

Management Plugin at https://rabbitmq.com/management.html.

default_user_tags.administrator = true

Define other tags like this:

default_user_tags.management = true

default_user_tags.custom_tag = true

Additional network and protocol related configuration

=====================================================

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

RabbitMQ nodes will send heartbeat frames at roughly

the (timeout / 2) interval. Two missed heartbeats from

a client will close its connection.

Values lower than 6 seconds are very likely to produce

false positives and are not recommended.

Related doc guides:

* https://rabbitmq.com/heartbeats.html

* https://rabbitmq.com/networking.html

heartbeat = 60

Set the max permissible size of an AMQP frame (in bytes).

frame_max = 131072

Set the max frame size the server will accept before connection

tuning occurs

initial_frame_max = 4096

Set the max permissible number of channels per connection.

0 means “no limit”.

channel_max = 128

Customising TCP Listener (Socket) Configuration.

Related doc guides:

* https://rabbitmq.com/networking.html

* https://www.erlang.org/doc/man/inet.html#setopts-2

tcp_listen_options.backlog = 128

tcp_listen_options.nodelay = true

tcp_listen_options.exit_on_close = false

tcp_listen_options.keepalive = true

tcp_listen_options.send_timeout = 15000

tcp_listen_options.buffer = 196608

tcp_listen_options.sndbuf = 196608

tcp_listen_options.recbuf = 196608

Resource Limits & Flow Control

==============================

Related doc guide: https://rabbitmq.com/memory.html.

Memory-based Flow Control threshold.

vm_memory_high_watermark.relative = 0.4

Alternatively, we can set a limit (in bytes) of RAM used by the node.

vm_memory_high_watermark.absolute = 1073741824

Or you can set absolute value using memory units (with RabbitMQ 3.6.0+).

Absolute watermark will be ignored if relative is defined!

vm_memory_high_watermark.absolute = 2GB

Supported unit symbols:

k, kiB: kibibytes (2^10 - 1,024 bytes)

M, MiB: mebibytes (2^20 - 1,048,576 bytes)

G, GiB: gibibytes (2^30 - 1,073,741,824 bytes)

kB: kilobytes (10^3 - 1,000 bytes)

MB: megabytes (10^6 - 1,000,000 bytes)

GB: gigabytes (10^9 - 1,000,000,000 bytes)

Fraction of the high watermark limit at which queues start to

page message out to disc in order to free up memory.

For example, when vm_memory_high_watermark is set to 0.4 and this value is set to 0.5,

paging can begin as early as when 20% of total available RAM is used by the node.

Values greater than 1.0 can be dangerous and should be used carefully.

One alternative to this is to use durable queues and publish messages

as persistent (delivery mode = 2). With this combination queues will

move messages to disk much more rapidly.

Another alternative is to configure queues to page all messages (both

persistent and transient) to disk as quickly

as possible, see https://rabbitmq.com/lazy-queues.html.

vm_memory_high_watermark_paging_ratio = 0.5

Selects Erlang VM memory consumption calculation strategy. Can be allocated, rss or legacy (aliased as erlang),

Introduced in 3.6.11. rss is the default as of 3.6.12.

See https://github.com/rabbitmq/rabbitmq-server/issues/1223 and rabbitmq/rabbitmq-common#224 for background.

vm_memory_calculation_strategy = rss

Interval (in milliseconds) at which we perform the check of the memory

levels against the watermarks.

memory_monitor_interval = 2500

The total memory available can be calculated from the OS resources

- default option - or provided as a configuration parameter.

total_memory_available_override_value = 2GB

Set disk free limit (in bytes). Once free disk space reaches this

lower bound, a disk alarm will be set - see the documentation

listed above for more details.

Absolute watermark will be ignored if relative is defined!

disk_free_limit.absolute = 50000

Or you can set it using memory units (same as in vm_memory_high_watermark)

with RabbitMQ 3.6.0+.

disk_free_limit.absolute = 500KB

disk_free_limit.absolute = 50mb

disk_free_limit.absolute = 5GB

Alternatively, we can set a limit relative to total available RAM.

Values lower than 1.0 can be dangerous and should be used carefully.

disk_free_limit.relative = 2.0

Clustering

=====================

cluster_partition_handling = ignore

Pauses all nodes on the minority side of a partition. The cluster

MUST have an odd number of nodes (3, 5, etc)

cluster_partition_handling = pause_minority

pause_if_all_down strategy require additional configuration

cluster_partition_handling = pause_if_all_down

Recover strategy. Can be either ‘autoheal’ or ‘ignore’

cluster_partition_handling.pause_if_all_down.recover = ignore

Node names to check

cluster_partition_handling.pause_if_all_down.nodes.1 = rabbit@localhost

cluster_partition_handling.pause_if_all_down.nodes.2 = hare@localhost

Mirror sync batch size, in messages. Increasing this will speed

up syncing but total batch size in bytes must not exceed 2 GiB.

Available in RabbitMQ 3.6.0 or later.

mirroring_sync_batch_size = 4096

Make clustering happen automatically at startup. Only applied

to nodes that have just been reset or started for the first time.

Relevant doc guide: https://rabbitmq.com//cluster-formation.html

###这里设置集群,所有节点必须保持一致,当然也可以按照前面命令的方式进行设置

cluster_formation.peer_discovery_backend = rabbit_peer_discovery_classic_config

cluster_formation.classic_config.nodes.1 = rabbit1@hostname

cluster_formation.classic_config.nodes.2 = rabbit2@hostname

cluster_formation.classic_config.nodes.3 = rabbit3@hostname

cluster_formation.classic_config.nodes.4 = rabbit4@hostname

DNS-based peer discovery. This backend will list A records

of the configured hostname and perform reverse lookups for

the addresses returned.

cluster_formation.peer_discovery_backend = rabbit_peer_discovery_dns

cluster_formation.dns.hostname = discovery.eng.example.local

This node’s type can be configured. If you are not sure

what node type to use, always use ‘disc’.

cluster_formation.node_type = disc

Interval (in milliseconds) at which we send keepalive messages

to other cluster members. Note that this is not the same thing

as net_ticktime; missed keepalive messages will not cause nodes

to be considered down.

cluster_keepalive_interval = 10000

Statistics Collection

=====================

Statistics collection interval (in milliseconds). Increasing

this will reduce the load on management database.

collect_statistics_interval = 5000

Fine vs. coarse statistics

This value is no longer meant to be configured directly.

See https://www.rabbitmq.com/management.html#fine-stats.

Ra Settings

=====================

raft.segment_max_entries = 65536

raft.wal_max_size_bytes = 1048576

raft.wal_max_batch_size = 4096

raft.snapshot_chunk_size = 1000000

Misc/Advanced Options

=====================

NB: Change these only if you understand what you are doing!

Timeout used when waiting for Mnesia tables in a cluster to

become available.

mnesia_table_loading_retry_timeout = 30000

Retries when waiting for Mnesia tables in the cluster startup. Note that

this setting is not applied to Mnesia upgrades or node deletions.

mnesia_table_loading_retry_limit = 10

Size in bytes below which to embed messages in the queue index.

Related doc guide: https://rabbitmq.com/persistence-conf.html

queue_index_embed_msgs_below = 4096

You can also set this size in memory units

queue_index_embed_msgs_below = 4kb

Whether or not to enable background periodic forced GC runs for all

最后的话

最近很多小伙伴找我要Linux学习资料,于是我翻箱倒柜,整理了一些优质资源,涵盖视频、电子书、PPT等共享给大家!

资料预览

给大家整理的视频资料:

给大家整理的电子书资料:

如果本文对你有帮助,欢迎点赞、收藏、转发给朋友,让我有持续创作的动力!

网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。

需要这份系统化的资料的朋友,可以点击这里获取!

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长! 10

Size in bytes below which to embed messages in the queue index.

Related doc guide: https://rabbitmq.com/persistence-conf.html

queue_index_embed_msgs_below = 4096

You can also set this size in memory units

queue_index_embed_msgs_below = 4kb

Whether or not to enable background periodic forced GC runs for all

最后的话

最近很多小伙伴找我要Linux学习资料,于是我翻箱倒柜,整理了一些优质资源,涵盖视频、电子书、PPT等共享给大家!

资料预览

给大家整理的视频资料:

[外链图片转存中…(img-9Cdfvy2U-1714543526215)]

给大家整理的电子书资料:

[外链图片转存中…(img-cYff8W3j-1714543526216)]

如果本文对你有帮助,欢迎点赞、收藏、转发给朋友,让我有持续创作的动力!

网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。

需要这份系统化的资料的朋友,可以点击这里获取!

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!

参考链接

评论可见,请评论后查看内容,谢谢!!!
 您阅读本篇文章共花了: