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的代碼怎么寫”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！