ActiveMQ使用

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

package
com.mzj.jmsActiveMQTest2;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageProducer;

import javax.jms.Session;

import
org.apache.activemq.ActiveMQConnectionFactory;

/**

 * 消息——生产者

 */

public
class Producer {

    public
static void main(String[] args) throws
JMSException {

        String jmsProviderAddress = "tcp://localhost:61616";// 地址

        ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(

                jmsProviderAddress);// 连接器

        Connection connection = connectionFactory.createConnection();// 创建连接

        Session session = connection.createSession(false,

                Session.AUTO_ACKNOWLEDGE);// 打开会话

        Destination dest = session.createQueue("demoQueue");// 消息目的地

        MessageProducer producer = session.createProducer(dest);// 消息发送者

        Message message = session.createTextMessage("hello world");// 消息

        producer.send(message);// 发送

        producer.close();// 关闭

        session.close();

        connection.close();

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

package
com.mzj.jmsActiveMQTest2;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.Session;

import
javax.jms.TextMessage;

import
org.apache.activemq.ActiveMQConnectionFactory;

/**

 * 消息——使用者

 */

public
class Consumer {

    public
static void main(String[] args) throws
JMSException {

        String jmsProviderAddress = "tcp://localhost:61616";// 地址

        ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(

                jmsProviderAddress);// 连接器

        Connection connection = connectionFactory.createConnection();// 创建连接

        Session session = connection.createSession(false,

                Session.AUTO_ACKNOWLEDGE);// 打开会话

        String destinationName = "demoQueue";

        Destination dest = session.createQueue(destinationName);// 消息目的地

        MessageConsumer consumer = session.createConsumer(dest);

        connection.start();

        Message message = consumer.receive();

        TextMessage textMessage = (TextMessage) message;

        String text = textMessage.getText();

        System.out.println("从ActiveMQ取回一条消息: "
+ text);

        consumer.close();

        session.close();

        connection.close();

    }

}