ActiveMq 自学（一）

拼搏现实的明天。 2022-07-24 08:25 206阅读 0赞

# ActiveMQ自学（一） #

使用的是apache-activemq-5.10.0,简单是说一下最基本的使用.

1.Window下启动/bin/win32(or win64)/activemq.bat

2.linux下启动/bin/activemq  start

3.访问控制台路径: localhost:8161/admin    默认的用户名/密码 admin/admin

4.代码中请求访问MQ的tcp地址是 tcp:localhost:61616  都是默认的

5.如果要修改ip或者端口  或者配置更多的功能信息  进入/conf中有大量mq配置文件，常用的就activemq.xml和jetty.xml.后续有更强大的功能描述和讲解。

JAVA中使用MQ建立最简单的生产者(Producer)和消费者(Consumer)类

Producer.java:

public class Producer {
    		//默认用户名
    		private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;
    		//默认密码
    		private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;
    		//默认地址
    		private static final String URL = ActiveMQConnection.DEFAULT_BROKER_URL;
    		
    		public static void main(String[] args) {
    			//连接工程
    			ConnectionFactory factory;
    			//连接
    			Connection connection = null;
    			//会话(接受或发送信息的线程)
    			Session session;
    			//消息的目的地
    			Destination destination;
    			//消息生产者
    			MessageProducer messageProducer;
    			//实例连接
    			factory = new ActiveMQConnectionFactory(USERNAME,PASSWORD, URL);
    			try {
    				//通过工厂获取连接
    				connection = factory.createConnection();
    				//开启连接
    				connection.start();
    				//创建session
    				session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
    				//创建一个名称为hello的消息队列
    				destination = session.createQueue("hello");
    				//创建消息生产者
    				messageProducer = session.createProducer(destination);
    				//发送消息
    				sendMessage(session,messageProducer);
    				session.commit();
    			} catch (JMSException e) {
    				e.printStackTrace();
    			}finally{
    				if(connection!=null){
    					try {
    						connection.close();
    					} catch (JMSException e) {
    						e.printStackTrace();
    					}
    				}
    			}
    		}
    
    		/**
    		 * 发送消息
    		 * @param session
    		 * @param messageProducer
    		 * @throws JMSException 
    		 */
    		private static void sendMessage(Session session,
    				MessageProducer messageProducer) throws JMSException {
    			for (int i = 0; i < 10; i++) {
    	            //创建一条文本消息 
    	            TextMessage message = session.createTextMessage("ActiveMQ 发送消息" +i);
    	            //通过消息生产者发出消息 
    	            messageProducer.send(message);
    	        }
    		}
    }

消费者Consumer.java

public class Consumer {
    		private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接用户名
    	    private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接密码
    	    private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//默认连接地址
    	    
    	    public static void main(String[] args) {
    	    	ConnectionFactory connectionFactory;//连接工厂
    	        Connection connection = null;//连接
    	        Session session;//会话 接受或者发送消息的线程
    	        Destination destination;//消息的目的地
    	        MessageConsumer messageConsumer;//消息的消费者
    	        //实例化连接工厂
    	        connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);
    	        try {
    	        	//通过连接工厂获取连接
    	        	connection  = connectionFactory.createConnection();
    	        	//启动连接
    	            connection.start();
    	          //创建session
    	            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    	          //创建一个连接HelloWorld的消息队列
    	            destination = session.createQueue("hello");
    	            //创建消息消费者
    	            messageConsumer = session.createConsumer(destination);
    	            while (true) {
    	                TextMessage textMessage = (TextMessage) messageConsumer.receive(100000);
    	                if(textMessage != null){
    	                    System.out.println("收到的消息:" + textMessage.getText());
    	                }else {
    	                    break;
    	                }
    	            }
    			} catch (JMSException e) {
    				e.printStackTrace();
    			}
    		}
    }

这样简单的MQ就使用完毕。

这里要简单的说一下  Mq支持发送的数据类型有很多种，这里使用的是TextMessage（字符串信息）  。

其中有

\--------ObjectMessage   传输对象数据

\--------MapMessage  传输Map集合数据

\--------BlobMessage  传输流信息（二进制） 文件信息  后面会重点讲解。