import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class Producer { public static void main(String[] args) throws JMSException { ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("task_queue"); MessageProducer producer = session.createProducer(destination); for (int i = 0; i < 10; i++) { TextMessage message = session.createTextMessage("Task " + i); producer.send(message); System.out.println("Sent message: " + message.getText()); } connection.close(); } } import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class Consumer { public static void main(String[] args) throws JMSException { ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("task_queue"); MessageConsumer consumer = session.createConsumer(destination); consumer.setMessageListener(new MessageListener() { @Override public void onMessage(Message message) { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; try { System.out.println("Received message: " + textMessage.getText()); Thread.sleep(1000); e.printStackTrace(); } } } }); try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } connection.close(); } }


上一篇:
下一篇:
切换中文