activemq的安装与java代码学习笔记

古城微笑少年丶 2023-07-04 15:55 37阅读 0赞

# 1、安装过程，运行起来访问地址：[http://localhost:8161/admin/index.jsp][http_localhost_8161_admin_index.jsp] #

进入bin目录，发现有win32和win64两个文件夹，这2个文件夹分别对应windows32位和windows64位操作系统的启动脚本。

我的实验环境是windows10的64位系统，就进入win64目录，其中activemq.bat便是启动脚本，双击启动。

ActiveMQ默认启动到8161端口，启动完了后在浏览器地址栏输入：[http://localhost:8161/admin][http_localhost_8161_admin]要求输入用户名密码，默认用户名密码为admin、admin，这个用户名密码是在conf/users.properties中配置的。输入用户名密码后便可看到如下图的ActiveMQ控制台界面了。

首先学习第一步：原声的java带入学习：

<groupId>org.apache.activemq</groupId>
    <artifactId>activemq-core</artifactId>

# 2、java代码ActiveMq的生产者代码。纯Maven导入原生包代码 #

public class Producter {
    	/**
    	 * mq通讯地址
    	 */
    	private final static String URL = "tcp://localhost:61616";
    	/**
    	 * 队列名称
    	 */
    	private final static String QUEUENAME = "queue_master";
    
    	public static void main(String[] args) throws JMSException {
    		// 1.创建ActiveMQFactory
    		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URL);
    		// 2.创建连接
    		Connection cnnection = factory.createConnection();
    		// 3.启动连接
    		cnnection.start();
    		// 4.创建Session 不开启事务,自动签收模式
    		Session session = cnnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    		// 5.创建一个目标
    		Queue queue = session.createQueue(QUEUENAME);
    		// 6.创建生产者
    		MessageProducer producer = session.createProducer(queue);
    		// 设置消息持久化
    		producer.setDeliveryMode(DeliveryMode.PERSISTENT);
    		for (int i = 1; i <= 10; i++) {
    			// 7.创建消息
    			TextMessage textMessage = session.createTextMessage("消息" + i);
    			// 8.发送消息
    			producer.send(textMessage);
    			System.out.println(textMessage.toString());
    		}
    		// 9.关闭连接
    		cnnection.close();
    	}
    
    }

# 3、java代码ActiveMq的消费者代码。纯Maven导入原生包代码 #

public class Consumer {
    	/**
    	 * mq通讯地址
    	 */
    	private final static String URL = "tcp://localhost:61616";
    	/**
    	 * 队列名称
    	 */
    	private final static String QUEUENAME = "queue_master";
    
    	public static void main(String[] args) throws JMSException {
    		// 1.创建ActiveMQFactory
    		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URL);
    		// 2.创建连接
    		Connection cnnection = factory.createConnection();
    		// 3.启动连接
    		cnnection.start();
    		// 4.创建Session 不开启事务,自动签收模式
    		Session session = cnnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    		// 5.创建一个目标
    		Queue queue = session.createQueue(QUEUENAME);
    		// 6.创建消费者
    		MessageConsumer createConsumer = session.createConsumer(queue);
    		createConsumer.setMessageListener(new MessageListener() {
    
    			public void onMessage(Message message) {
    				try {
    					TextMessage textMessage = (TextMessage) message;
    					System.out.println("消费者消费消息:" + textMessage.getText());
    				} catch (Exception e) {
    					// TODO: handle exception
    				}
    			}
    		});
    		// 先不要关闭连接
    	}
    }

#     4、集成进SpringCloud的activeMq的实现方式 #

消费者application.yml配置：

spring:
      activemq:
        broker-url: tcp://127.0.0.1:61616
        user: admin
        password: admin
    queue: springcloudQueue
    server:
      port: 8091

生产者的application.yml配置

spring:
      activemq:
      #### activemq连接地址
        broker-url: tcp://127.0.0.1:61616
        ###账号
        user: admin
        ###密码
        password: admin
    queue: springcloudQueue
    server:
      port: 8090

SpringCloud的 activeMq的配置实现类，注解：

// 队列信息配置
    @Configuration
    public class QueueConfig {
    	@Value("${queue}")
    	private String queue;
    
    	@Bean
    	public Queue logQueue() {
    		return new ActiveMQQueue(queue);
    	}
    }

生产者的注解实现

@Component
    public class Producer {
    
    	/****
    	 * 注解类能够实现Mq的模板操作
    	 */
    	@Autowired
    	private JmsMessagingTemplate jmsMessagingTemplate;
    	@Autowired
    	private Queue queue;
    
    	@Scheduled(fixedDelay = 5000)
    	public void send() {
    		jmsMessagingTemplate.convertAndSend(queue, "生产者:" + System.currentTimeMillis());
    	}
    }

消费者接收到的信息，可以处理为：

@Component
    public class Consumer {
    	@JmsListener(destination = "${queue}")
    	public void receive(String msg) {
    		System.out.println("监听器收到msg:" + msg);
    	}
    }

[http_localhost_8161_admin_index.jsp]: http://localhost:8161/admin/index.jsp
[http_localhost_8161_admin]: http://localhost:8161/admin