1. Загрузите и установите Maven
Apache-RocketMQ, который мы собираемся установить, должен быть скомпилирован Maven, прежде чем его можно будет запустить, поэтому, прежде всего, мы должны убедиться, что на сервере Linux установлена среда java и Maven.
1. Загрузите maven и разархивируйте его.
адрес загрузки mavenmaven.apache.org/download.success...Найдите подходящую версию maven
wget http://mirrors.shu.edu.cn/apache/maven/maven-3/3.6.0/source/apache-maven-3.6.0-src.tar.gz
С помощью приведенной выше команды загрузите архив maven в каталог, который вы хотите установить. Разархивируйте установочный пакет
tar -zxvf apache-maven-3.6.0-src.tar.gz
После распаковки можно установить мягкое соединение для облегчения настройки переменных среды.
ln -s apache-maven-3.6.0-src.tar.gz maven
2. Настройте переменные среды
Откройте файл конфигурации
vim /etc/profile
Добавить переменные среды в конец файла
MAVEN_HOME=/usr/local/maven
export MAVEN_HOME
export PATH=${PATH}:${MAVEN_HOME}/bin
/usr/local — это каталог, в котором вы храните maven
Сделайте так, чтобы файл конфигурации вступил в силу немедленно
source /etc/profile
3. Установка прошла успешно
консольный ввод mvn -v Появляется номер версии, указывающий, что установка maven прошла успешно.
2. Загрузите и установите RocketMQ.
1. Загрузите и разархивируйте Apache-RocketMQ.
GitHub.com/Apache/рок…Этот URL может видеть несколько версий RocketMQ
wget https://github.com/apache/rocketmq/archive/rocketmq-all-4.3.0.tar.gz
Создайте новую папку RocketMQ в /user/local/, загрузите сжатый пакет в эту папку и разархивируйте его.
tar -zxvf rocketmq-all-4.3.0.tar.gz
После распаковки папка выглядит следующим образом
2. Скомпилируйте
Чтобы скомпилировать проект с помощью maven,
mvn -Prelease-all -DskipTests clean install -U
начать компиляцию
Наконец, когда появляется сообщение BUILD SUCCESS, это означает, что компиляция прошла успешно.
3. Настройте переменные среды
cd distribution/target/apache-rocketmq/
pwd
Чтобы записать этот путь, вам нужно настроить его на переменную среды Откройте файл конфигурации
vim /etc/profile
Добавьте две строки в конце, wq сохраните и выйдите
export rocketmq=/usr/local/rockemq-source/rocketmq/distribution/target/apache-rocketmq
export PATH=$PATH:$rocketmq/bin
Сделайте так, чтобы файл конфигурации вступил в силу немедленно
source /etc/profile
Новая папка журнала
mkdir /usr/local/log/rocketmqlogs
4. Запустите RocketMQ
запускать:
nohup mqnamesrv >/usr/local/log/rocketmqlogs/namesrv.log 2>&1 &
Посмотреть журнал:
tail -f /user/local/log/rocketmqlogs/namesrv.log
Если он запустится нормально, он появится
Запустите службу брокера:
nohup mqbroker -n localhost:9876 >/usr/local/log/rocketmqlogs/broker.log 2>&1 &
Посмотреть журнал:
tail -f /user/local/log/rocketmqlogs/broker.log
Если он запустится нормально, он появится
Однако, поскольку конфигурация памяти Java по умолчанию для RocketMQ немного велика, память сервера сообщит об ошибке, если память сервера не так велика.
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
Java HotSpot(TM) 64-Bit Server VM warning: MaxNewSize (131072k) is equal to or greater than the entire heap (131072k). A new max generation size of 131008k will be used.
Просто измените конфигурацию файлов runserver.sh и runbroker.sh в каталоге bin.
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn128m"
Должно быть нормально после перезагрузки Запустите следующую команду, чтобы просмотреть процесс RocketMQ.
ps -ef|grep rocketmq
5. Закрыть
mqshutdown namesrv
mqshutdown broker
В-третьих, создайте консоль визуального управления RocketMQ Console
1. Скачать
После успешной установки RocketMQ вы можете использовать консоль RocketMQ, если хотите получить к ней более легкий доступ. У RocketMQ есть проект с открытым исходным кодом, который расширяет его.rocketmq-externals, в нем есть элемент, которыйRocketMQ ConsoleВесь проект загружается немного медленно, поэтому просто загрузите ветку проекта Console.
2. Настройте запуск
Импортируйте проект, затем настройте файл конфигурации
Настроить адрес сервера
Стартовый проект
Если следующая ссылка не работает, возможно, порт вашего сервера не открыт. Просто настройте правила группы безопасности. Лучше всего открывать 9876, 10909 и 10911.
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException:
connect to <x.x.x.x:9876> failed
Если порт открыт, но по-прежнему сообщает о подключении кx.x.x.x:10911не удалось, то вам нужно настроить brokerIP1.При запуске брокера IP-адрес по умолчанию является локальным IP-адресом, но этот IP-адрес может быть недоступен удаленно.
Создайте новые свойства в каталоге RocketMQ.
echo "brokerIP1=外网IP" > broker.properties
Закройте и перезапустите брокера
mqshutdown broker
nohup mqbroker -n localhost:9876 -c 配置文件路径/broker.properties >/usr/local/log/rocketmqlog/broker.log 2>&1 &
Перезапустите консольный проект, доступ к браузеру