Merge pull request #5995 from Spycsh/main-v4.3
chore: add cluster script for local machine
This commit is contained in:
Zaiming (Stone) Shi
GitHub
commit
dd4e307753
|
|
@ -0,0 +1,106 @@
|
|||
#!/bin/bash
|
||||
# shellcheck disable=2090
|
||||
###############
|
||||
## args and env validation
|
||||
###############
|
||||
|
||||
if ! [ -d "emqx" ]; then
|
||||
echo "[error] this script must be run at the same dir as the emqx"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
if [ $# -eq 0 ]
|
||||
then
|
||||
echo "[error] a new emqx name should be provided!"
|
||||
echo "Usage: ./one_more_emqx <new_name>"
|
||||
echo " e.g. ./one_more_emqx emqx2"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
NEW_EMQX=$1
|
||||
if [ -d "$NEW_EMQX" ]; then
|
||||
echo "[error] a dir named ${NEW_EMQX} already exists!"
|
||||
exit 2
|
||||
fi
|
||||
echo creating "$NEW_EMQX" ...
|
||||
|
||||
SED_REPLACE="sed -i "
|
||||
# shellcheck disable=2089
|
||||
case $(sed --help 2>&1) in
|
||||
*GNU*) SED_REPLACE="sed -i ";;
|
||||
*) SED_REPLACE="sed -i ''";;
|
||||
esac
|
||||
|
||||
PORT_INC_=$(cksum <<< "$NEW_EMQX" | cut -f 1 -d ' ')
|
||||
PORT_INC=$((PORT_INC_ % 1000))
|
||||
echo using increment factor: $PORT_INC
|
||||
|
||||
###############
|
||||
## helpers
|
||||
###############
|
||||
process_emqx_conf() {
|
||||
echo "processing config file: $1"
|
||||
$SED_REPLACE '/^#/d' "$1"
|
||||
$SED_REPLACE '/^$/d' "$1"
|
||||
|
||||
for entry_ in "${entries_to_be_inc[@]}"
|
||||
do
|
||||
echo inc port for "$entry_"
|
||||
ip_port_=$(grep -E "$entry_"'[ \t]*=' "$1" 2> /dev/null | tail -1 | cut -d = -f 2- | sed -e 's/^[[:space:]]*//' -e 's/[[:space:]]*$//')
|
||||
echo -- from: "$ip_port_"
|
||||
ip_=$(echo "$ip_port_" | cut -sd : -f 1)
|
||||
port_=$(echo "$ip_port_" | cut -sd : -f 2)
|
||||
if [ -z "$ip_" ]
|
||||
then
|
||||
new_ip_port=$(( ip_port_ + PORT_INC ))
|
||||
else
|
||||
new_ip_port="${ip_}:$(( port_ + PORT_INC ))"
|
||||
fi
|
||||
echo -- to: "$new_ip_port"
|
||||
$SED_REPLACE 's|'"$entry_"'[ \t]*=.*|'"$entry_"' = '"$new_ip_port"'|g' "$1"
|
||||
done
|
||||
}
|
||||
|
||||
###############
|
||||
## main
|
||||
###############
|
||||
|
||||
cp -r emqx "$NEW_EMQX"
|
||||
|
||||
## change the rpc ports
|
||||
$SED_REPLACE 's|tcp_server_port[ \t]*=.*|tcp_server_port = 5369|g' emqx/etc/rpc.conf
|
||||
$SED_REPLACE 's|tcp_client_port[ \t]*=.*|tcp_client_port = 5370|g' emqx/etc/rpc.conf
|
||||
$SED_REPLACE 's|tcp_client_port[ \t]*=.*|tcp_client_port = 5369|g' "$NEW_EMQX/etc/rpc.conf"
|
||||
$SED_REPLACE 's|tcp_server_port[ \t]*=.*|tcp_server_port = 5370|g' "$NEW_EMQX/etc/rpc.conf"
|
||||
$SED_REPLACE 's|.*node\.name.*|node.name='"$NEW_EMQX"'@127.0.0.1|g' "$NEW_EMQX/etc/emqx.conf"
|
||||
|
||||
conf_ext="*.conf"
|
||||
|
||||
find "$NEW_EMQX" -name "${conf_ext}" | while read -r conf; do
|
||||
if [ "${conf##*/}" = 'emqx.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("node.dist_listen_min"
|
||||
"node.dist_listen_max")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
elif [ "${conf##*/}" = 'listeners.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("listener.tcp.external"
|
||||
"listener.tcp.internal"
|
||||
"listener.ssl.external"
|
||||
"listener.ws.external"
|
||||
"listener.wss.external")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
elif [ "${conf##*/}" = 'emqx_management.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("management.listener.http"
|
||||
"management.listener.https")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
elif [ "${conf##*/}" = 'emqx_dashboard.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("dashboard.listener.http"
|
||||
"dashboard.listener.https")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
else
|
||||
echo "."
|
||||
fi
|
||||
done
|
||||
|
|
@ -0,0 +1,102 @@
|
|||
#!/bin/bash
|
||||
# shellcheck disable=2090
|
||||
###############
|
||||
## args and env validation
|
||||
###############
|
||||
|
||||
if ! [ -d "emqx" ]; then
|
||||
echo "[error] this script must be run at the same dir as the emqx"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
if [ $# -eq 0 ]
|
||||
then
|
||||
echo "[error] a new emqx name should be provided!"
|
||||
echo "Usage: ./one_more_emqx <new_name>"
|
||||
echo " e.g. ./one_more_emqx emqx2"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
NEW_EMQX=$1
|
||||
if [ -d "$NEW_EMQX" ]; then
|
||||
echo "[error] a dir named ${NEW_EMQX} already exists!"
|
||||
exit 2
|
||||
fi
|
||||
echo creating "$NEW_EMQX" ...
|
||||
|
||||
SED_REPLACE="sed -i "
|
||||
# shellcheck disable=2089
|
||||
case $(sed --help 2>&1) in
|
||||
*GNU*) SED_REPLACE="sed -i ";;
|
||||
*) SED_REPLACE="sed -i ''";;
|
||||
esac
|
||||
|
||||
PORT_INC_=$(cksum <<< "$NEW_EMQX" | cut -f 1 -d ' ')
|
||||
PORT_INC=$((PORT_INC_ % 1000))
|
||||
echo using increment factor: "$PORT_INC"
|
||||
|
||||
###############
|
||||
## helpers
|
||||
###############
|
||||
process_emqx_conf() {
|
||||
echo "processing config file: $1"
|
||||
$SED_REPLACE '/^#/d' "$1"
|
||||
$SED_REPLACE '/^$/d' "$1"
|
||||
$SED_REPLACE 's|.*node\.name.*|node.name='"$NEW_EMQX"'@127.0.0.1|g' "$1"
|
||||
|
||||
for entry_ in "${entries_to_be_inc[@]}"
|
||||
do
|
||||
echo inc port for "$entry_"
|
||||
ip_port_=$(grep -E "$entry_"'[ \t]*=' "$1" 2> /dev/null | tail -1 | cut -d = -f 2- | sed -e 's/^[[:space:]]*//' -e 's/[[:space:]]*$//')
|
||||
echo -- from: "$ip_port_"
|
||||
ip_=$(echo "$ip_port_" | cut -sd : -f 1)
|
||||
port_=$(echo "$ip_port_" | cut -sd : -f 2)
|
||||
if [ -z "$ip_" ]
|
||||
then
|
||||
new_ip_port=$(( ip_port_ + PORT_INC ))
|
||||
else
|
||||
new_ip_port="${ip_}:$(( port_ + PORT_INC ))"
|
||||
fi
|
||||
echo -- to: "$new_ip_port"
|
||||
$SED_REPLACE 's|'"$entry_"'[ \t]*=.*|'"$entry_"' = '"$new_ip_port"'|g' "$1"
|
||||
done
|
||||
}
|
||||
|
||||
###############
|
||||
## main
|
||||
###############
|
||||
|
||||
cp -r emqx "$NEW_EMQX"
|
||||
|
||||
## change the rpc ports
|
||||
$SED_REPLACE 's|tcp_server_port[ \t]*=.*|tcp_server_port = 5369|g' emqx/etc/emqx.conf
|
||||
$SED_REPLACE 's|tcp_client_port[ \t]*=.*|tcp_client_port = 5370|g' emqx/etc/emqx.conf
|
||||
$SED_REPLACE 's|tcp_client_port[ \t]*=.*|tcp_client_port = 5369|g' "$NEW_EMQX/etc/emqx.conf"
|
||||
$SED_REPLACE 's|tcp_server_port[ \t]*=.*|tcp_server_port = 5370|g' "$NEW_EMQX/etc/emqx.conf"
|
||||
|
||||
conf_ext="*.conf"
|
||||
find "$NEW_EMQX" -name "${conf_ext}" | while read -r conf; do
|
||||
if [ "${conf##*/}" = 'emqx.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("node.dist_listen_min"
|
||||
"dist_listen_max"
|
||||
"listener.tcp.external"
|
||||
"listener.tcp.internal"
|
||||
"listener.ssl.external"
|
||||
"listener.ws.external"
|
||||
"listener.wss.external")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
elif [ "${conf##*/}" = 'emqx_management.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("management.listener.http"
|
||||
"management.listener.https")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
elif [ "${conf##*/}" = 'emqx_dashboard.conf' ]
|
||||
then
|
||||
declare -a entries_to_be_inc=("dashboard.listener.http"
|
||||
"dashboard.listener.https")
|
||||
process_emqx_conf "$conf" "${entries_to_be_inc[@]}"
|
||||
else
|
||||
echo "."
|
||||
fi
|
||||
done
|
||||
Loading…
Reference in New Issue