Apache ActiveMQ作为一款开源的消息中间件,凭借其跨平台、高吞吐量及灵活的应用场景,已成为企业级异步通信的核心组件之一。本文将从下载安装到安全配置,全面解析其使用要点,帮助开发者快速掌握这一工具。
ActiveMQ基于Java开发,支持跨平台部署,提供JMS 1.1规范实现,并兼容多种协议(如AMQP、MQTT、STOMP)。其核心优势包括:
1. 访问[Apache ActiveMQ官网],进入“Download”页面。
2. 选择与本地JDK匹配的压缩包(Windows为.zip,Linux为.tar.gz)。
3. 解压至目标目录,目录结构包含:
双击`binwin64activemq.bat`启动服务,命令行窗口显示“Broker started”即成功。
运行`InstallService.bat`后,在“服务”管理界面启动,实现后台运行。
bash
wget
tar -xzf apache-activemq-5.16.0-bin.tar.gz
cd apache-activemq-5.16.0/bin/linux-x86-64
/activemq start
开放8161(管理端口)和61616(通信端口):
bash
firewall-cmd --permanent --add-port={8161,61616}/tcp
firewall-cmd --reload
通过`authorizationPlugin`配置队列/主题的读写权限:
xml
此配置限制仅`user_group`成员可消费消息,`admin_group`可生产消息。
访问`
java
// 生产者
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = factory.createConnection;
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination queue = session.createQueue("SampleQueue");
MessageProducer producer = session.createProducer(queue);
producer.send(session.createTextMessage("Hello ActiveMQ!"));
// 消费者
MessageConsumer consumer = session.createConsumer(queue);
consumer.setMessageListener(message -> System.out.println("Received: " + message));
connection.start;
ActiveMQ凭借其成熟度与灵活性,在消息中间件领域持续占据重要地位。开发者需结合业务需求选择合适的版本与配置,同时重视安全加固与版本更新,以确保系统稳定高效运行。