JMS的代码怎么写

本篇内容介绍了“JMS的代码怎么写”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

private Session session; private boolean transacted = false; private MessageProducer replyProducer; private MessageProtocol messageProtocol; static {     messageBrokerUrl = "tcp://localhost:61616";     messageQueueName = "client.messages";     ackMode = Session.AUTO_ACKNOWLEDGE; } public Server() {     try {         //This message broker is embedded         BrokerService broker = new BrokerService();         broker.setPersistent(false);         broker.setUseJmx(false);         broker.addConnector(messageBrokerUrl);         broker.start();     } catch (Exception e) {         //Handle the exception appropriately     }     //Delegating the handling of messages to another class, instantiate it before setting up JMS so it     //is ready to handle messages     this.messageProtocol = new MessageProtocol();     this.setupMessageQueueConsumer(); } private void setupMessageQueueConsumer() {     ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(messageBrokerUrl);     Connection connection;     try {         connection = connectionFactory.createConnection();         connection.start();         this.session = connection.createSession(this.transacted, ackMode);         Destination adminQueue = this.session.createQueue(messageQueueName);         //Setup a message producer to respond to messages from clients, we will get the destination         //to send to from the JMSReplyTo header field from a Message         this.replyProducer = this.session.createProducer(null);         this.replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);         //Set up a consumer to consume messages off of the admin queue         MessageConsumer consumer = this.session.createConsumer(adminQueue);         consumer.setMessageListener(this);     } catch (JMSException e) {         //Handle the exception appropriately     } } public void onMessage(Message message) {     try {         TextMessage response = this.session.createTextMessage();         if (message instanceof TextMessage) {             TextMessage txtMsg = (TextMessage) message;             String messageText = txtMsg.getText();             response.setText(this.messageProtocol.handleProtocolMessage(messageText));         }         //Set the correlation ID from the received message to be the correlation id of the response message         //this lets the client identify which message this is a response to if it has more than         //one outstanding message to the server         response.setJMSCorrelationID(message.getJMSCorrelationID());         //Send the response to the Destination specified by the JMSReplyTo field of the received message,         //this is presumably a temporary queue created by the client         this.replyProducer.send(message.getJMSReplyTo(), response);     } catch (JMSException e) {         //Handle the exception appropriately     } } public static void main(String[] args) {     new Server(); }

private boolean transacted = false; private MessageProducer producer; static {     clientQueueName = "client.messages";     ackMode = Session.AUTO_ACKNOWLEDGE; } public Client() {     ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");     Connection connection;     try {         connection = connectionFactory.createConnection();         connection.start();         Session session = connection.createSession(transacted, ackMode);         Destination adminQueue = session.createQueue(clientQueueName);         //Setup a message producer to send message to the queue the server is consuming from         this.producer = session.createProducer(adminQueue);         this.producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);         //Create a temporary queue that this client will listen for responses on then create a consumer         //that consumes message from this temporary queue...for a real application a client should reuse         //the same temp queue for each message to the server...one temp queue per client         Destination tempDest = session.createTemporaryQueue();         MessageConsumer responseConsumer = session.createConsumer(tempDest);         //This class will handle the messages to the temp queue as well         responseConsumer.setMessageListener(this);         //Now create the actual message you want to send         TextMessage txtMessage = session.createTextMessage();         txtMessage.setText("MyProtocolMessage");         //Set the reply to field to the temp queue you created above, this is the queue the server         //will respond to         txtMessage.setJMSReplyTo(tempDest);         //Set a correlation ID so when you get a response you know which sent message the response is for         //If there is never more than one outstanding message to the server then the         //same correlation ID can be used for all the messages...if there is more than one outstanding         //message to the server you would presumably want to associate the correlation ID with this         //message somehow...a Map works good         String correlationId = this.createRandomString();         txtMessage.setJMSCorrelationID(correlationId);         this.producer.send(txtMessage);     } catch (JMSException e) {         //Handle the exception appropriately     } } private String createRandomString() {     Random random = new Random(System.currentTimeMillis());     long randomLong = random.nextLong();     return Long.toHexString(randomLong); } public void onMessage(Message message) {     String messageText = null;     try {         if (message instanceof TextMessage) {             TextMessage textMessage = (TextMessage) message;             messageText = textMessage.getText();             System.out.println("messageText = " + messageText);         }     } catch (JMSException e) {         //Handle the exception appropriately     } } public static void main(String[] args) {     new Client(); }

    return responseText; }

“JMS的代码怎么写”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！