Performance JMS: BytesMessage vs ObjectMessage

Question

En termes de performances JMS, j'ai lu que ObjectMessage doit être évité pour des raisons de performances.

À quel point les performances d'ObjectMessage sont-elles mauvaises? Devrais-je sérialiser vers un BytesMessage et désérialiser manuellement?

Answer 1

La surcharge de performances de ObjectMessage est due au processus de sérialisation java.io. Si vous faites cela vous-même et utilisez ByteMessage, vous faites juste ce que JMS ferait lui-même, et vous ne serez pas mieux lotis.

Si vous devez envoyer des objets Java via JMS, vous devez utiliser ObjectMessage, c'est ce que fournit l'API. Ceci permet au conteneur de faire quelques optimisations, par ex. JBoss utilisera son propre protocole de sérialisation propriétaire, qui est considérablement plus rapide que le protocole standard java.io.

Answer 2

Exemple avec Jackson sourire format de données qui peut être jusqu'à 50% plus rapide et plus petit que sérialisation JDK, donc BytesMessage dans ce cas va battre ObjectMessage:

import com.fasterxml.jackson.databind.ObjectMapper; 
import com.fasterxml.jackson.dataformat.smile.SmileFactory; 
import com.fasterxml.jackson.dataformat.smile.SmileGenerator; 
import org.springframework.jms.core.MessageCreator; 

import javax.jms.BytesMessage; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.Session; 

public class BytesMessageCreator<T> implements MessageCreator 
{ 
    public static final ObjectMapper 
    MAPPER=new ObjectMapper(new SmileFactory().disable(SmileGenerator.Feature.ENCODE_BINARY_AS_7BIT)); 

    final String messageId; 
    final T pojo; 

    public BytesMessageCreator(final T pojo) 
    { 
    messageId=null; 
    this.pojo=pojo; 
    } 

    public BytesMessageCreator(final String messageId, final T pojo) 
    { 
    this.messageId=messageId; 
    this.pojo=pojo; 
    } 

    @Override 
    public Message createMessage(final Session session) throws JMSException 
    { 
    try{ 
     final BytesMessage message=session.createBytesMessage(); 
     message.writeBytes(MAPPER.writeValueAsBytes(pojo)); 
     if(messageId != null){ 
     message.setJMSMessageID(messageId); 
     } 
     return message; 
    } catch(Exception e){ 
     throw new RuntimeException(e); 
    } 
    } 

}