activeMq之hello(java)

Posted 2020-10-18 fjk

消息队列activeMq,   节省响应时间，解决了第三方响应时间长的问题让其他客户可以继续访问，

安装activeMq

apache-activemq-5.14.0-bin\\apache-activemq-5.14.0\\bin\\win64\\activeMq.bat

创建一个maven java project

在浏览器中访问路径　　http://localhost:8161/        登录名admin  密码为admin

 

 

1.pom.xml文件

<dependencies>
  <dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.14.0</version>
</dependency>
  </dependencies>
  <build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<version>2.3.2</version>
				<configuration>
					<source>1.7</source>
					<target>1.7</target>
				</configuration>
			</plugin>
		</plugins>
	</build>

　　

 生产任务

　　　　public static void main(String[] args) throws JMSException {
		
		//连接工厂
		ConnectionFactory factory = new ActiveMQConnectionFactory();
		//获取一个连接
		Connection connection = factory.createConnection();
		//建立会话
		Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
		//创建队列化话题对象
		Queue queue = session.createQueue("hello");
		MessageProducer producer = session.createProducer(queue);
		for (int i = 0; i < 10; i++) {
			producer.send(session.createTextMessage("ActiveMQ"+i));
		}
		session.commit();
	}

　　产生了十条任务

消费（处理业务）

public static void main(String[] args) throws Exception {
		//连接工厂
		ConnectionFactory factory = new ActiveMQConnectionFactory();
		//获取一个连接
		Connection connection = factory.createConnection();
		connection.start();
		//建立会话
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		//创建队列化话题对象
		Queue queue = session.createQueue("hello");
		MessageConsumer producer = session.createConsumer(queue);
		while(true){
			//接收消息
			TextMessage receive = (TextMessage) producer.receive();
			if(receive!=null){
				System.out.println(receive.getText());
			}
		}
	}