JMS解析（二）——JMS简介

String text = 'message! From: ' + Thread.currentThread().getName() + ' : ' + System.currentTimeMillis(); 
TextMessage message = session.createTextMessage(text); 
// 设置消息属性 
message.setStringProperty('subtype', “aaa'); 
// 7、通过producer 发送消息 
producer.send(message);

@JmsListener(destination = 'queue1', selector = 'subtype='bbb'')
 public void receive(String text, @Header('subtype') String subtype) {     
       System.out.println(Thread.currentThread().getName() + ' Received <' + text + '>     subtype=' + subtype); 
}

@Transactional // 在开启事务的情况下需要加事务注解
 public void sendMessage(String subtype) { 
    // 发送延时消息 
    jmsTemplate.convertAndSend('queue1', 'message with property', message -> { 
    // 设置消息属性 
    message.setStringProperty('subtype', subtype); return message; 
});
 System.out.println('Sending an message with subtype=' + subtype); }

默认的MessageConverter只能转换基本类型（如String、Map、Serializable），而我们的电子邮件不是故意序列化的。我们想用Jackson和将内容序列化为文本格式的json（即作为文本消息）。Spring Boot将检测到存在MessageConverter，并将其与默认JmsTemplate和任何由DefaultJmsListenerContainerFactoryConfigurer创建的JmsListenerContainerFactory。

@Bean // Serialize message content to json using TextMessage 
public MessageConverter jacksonJmsMessageConverter() { 
    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();    
 converter.setTargetType(MessageType.TEXT); 
 converter.setTypeIdPropertyName('_type'); return converter; 
}

@JmsListener

带注释的JMS侦听器方法允许具有类似于MessageMapping提供：

获取对jms会话的访问权javax.jms.Message或其子类之一，以访问原始jms消息

org.springframework.messaging.Message使用Spring的消息传递抽象对应方

• @有效负载-带注释的方法参数，包括对验证的支持
• @Header-带注释的方法参数，用于提取特定的头值，包括标准头值

由org.springframework.JMS.support.JmsHeaders@headers定义的JMS头-带注释的方法参数，该参数还必须可分配给获取对所有标头的访问权org.springframework.messaging.MessageHeaders用于获取对所有标题org.springframework.messaging.support.MessageHeaderAccessororg.springframework.jms.support.JmsMessageHeaderAccessor，方便访问所有方法参数带注释的方法可能具有非void返回类型。当他们这样做时，方法的结果调用作为JMS应答发送到由传入消息。如果未设置此标头，则可以通过添加@发送到方法声明。

DefaultJmsListenerContainerFactory 的配置

注释，该注释将方法标记为指定对象上JMS消息侦听器的目标目的地containerFactory标识用于构建jms的org.springframework.jms.config.JmsListenerContainerFactory侦听器容器。如果未设置，则假定默认容器工厂可用于beanjmsListenerContainerFactory的名称，除非通过提供了显式默认值

配置考虑设置习惯org.springframework.jms.config.defaultjmsListenerContainerFactorybean。用于生产为此，您通常会微调超时和恢复设置。最重要的是，违约“自动确认”模式不提供可靠性保证，因此请确保使用在可靠性需要的情况下处理会话。

@Configuration 
static class JmsConfiguration { 
 @Bean
  public DefaultJmsListenerContainerFactory myFactory(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { 
 DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); //This provides all boot's default to this factory, including the 
// message converter 
    configurer.configure(factory, connectionFactory);
 // You could still override some of Boot's default if necessary.
 // factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE); 
// factory.setSessionTransacted(true); 
 return factory; 
} 
}

@Component
 public class Receiver { 
  @JmsListener(destination = 'mailbox', containerFactory = 'myFactory') 
   public void receiveMessage(Email email) { 
   System.out.println('Received <' + email + '>'); 
  } 
}

此注释可用作元注释，以创建具有属性覆盖。

CachingConnectionFactory

CachingConnectionFactory extends SingleConnectionFactory

 缓存的连接工厂，创建的工厂。添加的配置

JmsPoolConnectionFactory

<dependency> 
 <groupId>org.messaginghub</groupId> 
 <artifactId>pooled-jms</artifactId> 
</dependency>

spring.activemq.pool.enabled=true
spring.activemq.pool.max-connections=50