Duffblog

<bean id="jmsTemplate"
??????? class="org.springframework.jms.core.JmsTemplate102">
??????? <property name="connectionFactory" ref="connectionFactory"/>
??????? <property name="timeToLive" value="86400000"/>
??????? <property name="defaultDestinationName" value="cmpp" />
??????? <property name="messageConverter" ref="messageConverter" />
??????? <property name="receiveTimeout" value="30000" />
??? </bean>
上面的配置中用到了第一步配置的connectionFactory以及一個消息轉換的類 messageConverter，這個類實現了 org.springframework.jms.support.converter.MessageConverter接口，可以在消息發送之前和接受之后進行消息類型轉換。具體的看最后的實例代碼。配置代碼如下：
?<!-- Spring JMS SimpleConverter -->
?????? <bean id="simpleConverter"? class="org.springframework.jms.support.converter.SimpleMessageConverter" />
<!-- Message Converter -->
??? <bean id="messageConverter"
??????? class="com.liangj.apmgt.jms.ApmgtMessageConverter">
??????? <property name="converter">
??????????? <ref local="simpleConverter" />
??????? </property>
??? </bean>

4。配置發送代碼
??? <bean id="producer"
??????? class="com.liangj.apmgt.jms.DefaultApmgtMessageProducer">
??????? <property name="jmsTemplate" ref="jmsTemplate" />
??? </bean>
5。接著配置監聽器，這是Spring2.0新增的功能，配置如下：
<!-- this is the Message Driven POJO (MDP) -->
??? <bean id="messageListener"
??????? class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
??????? <constructor-arg>
??????????? <bean
??????????????? class="com.liangj.apmgt.jms.DefaultApmgtMessageListener" />
??????? </constructor-arg>
??????? <property name="defaultListenerMethod" value="onMessage" />
??????? <property name="messageConverter" ref="messageConverter" />
??? </bean>

??? <!-- and this is the attendant message listener container -->
??? <bean id="listenerContainer"
??????? class="org.springframework.jms.listener.DefaultMessageListenerContainer">
??????? <property name="connectionFactory" ref="connectionFactory" />
??????? <property name="destinationName" value="${jms.destinationName.cmpp}" />
??????? <property name="messageSelector" value="${jms.messageSelector}" />
??????? <property name="messageListener" ref="messageListener" />
??? </bean>

?Spring配置監聽器有很多種選擇，在這里我選擇這回種MessageListenerAdapter方法主要是因為這個方法比較靈活。實現他只要一個很普通的java類即可，和JMS以及Spring的耦合度最低。其中方法onMessage可以隨便修改方法名，只要在配置文件中對應的修改就好了。
???? MessageListenerAdapter還有一個功能就是如果處理方法(我這里是onMessage)返回一個非空值，它將自動返回一個響應消息。這個消息會返回給JMS Reply-To屬性定義的目的地(如果存在)，或者是MessageListenerAdapter設置(如果配置了)的缺省目的地；如果沒有定義目的地，那么將產生一個InvalidDestinationException異常(此異常將不會只被捕獲而不處理，它將沿著調用堆棧上傳)。
???? 這樣我們的配置就都完成了。接下來我們來實現對應的Java文件
先是接口文件發送消息接口IApmgtMessageProducer.java
public interface IApmgtMessageProducer {
??? public abstract void sendMessage(ApmgtMessageData messageData);
}
接受消息接口IApmgtMessageListener.java
public interface IApmgtMessageListener {
??? public void onMessage(ApmgtMessageData message);
}
發消息的文件DefaultApmgtMessageProducer.java
?public class DefaultApmgtMessageProducer implements IApmgtMessageProducer {
???
??? private JmsTemplate jmsTemplate;

??? public void setJmsTemplate(JmsTemplate jmsTemplate) {
??????? this.jmsTemplate = jmsTemplate;
??? }

??? public void sendMessage(ApmgtMessageData messageData) {
??????? this.jmsTemplate.convertAndSend(messageData);
??? }
}
收消息文件DefaultApmgtMessageListener.java
public class DefaultApmgtMessageListener implements IApmgtMessageListener {
??? public void onMessage(ApmgtMessageData message) {
??????? System.out.println("監聽到消息："+message);
??? }
}
消息轉換類ApmgtMessageConverter.java
public class ApmgtMessageConverter implements MessageConverter {

??? private Log log = LogFactory.getLog(ApmgtMessageConverter.class);

??? private SimpleMessageConverter converter;

??? public void setConverter(SimpleMessageConverter converter) {
??????? this.converter = converter;
??? }

??? public Object fromMessage(Message message) throws JMSException, MessageConversionException {
??????? if (message instanceof ObjectMessage) {
??????????? ObjectMessage o_message = (ObjectMessage)message;
??????????? MessageHeader header = new MessageHeader();
??????????? header.setId(message.getLongProperty("id"));
??????????? header.setReceiver(message.getIntProperty("receiver"));
??????????? header.setSender(message.getIntProperty("sender"));
??????????? header.setSendPerson(message.getStringProperty("sendPerson"));
??????????? header.setType(message.getIntProperty("type"));
??????????? Serializable messageContent = o_message.getObject();
??????????? ApmgtMessageData<Serializable> messageData = new ApmgtMessageData<Serializable>();
??????????? messageData.setMessageContent(messageContent);
??????????? messageData.setMessageHeader(header);
??????????? return messageData;
??????? }
??????? return null;
??? }

??? public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
??????? if (object instanceof ApmgtMessageData) {
??????????? ApmgtMessageData data = (ApmgtMessageData) object;
??????????? Message message = converter.toMessage(data.getMessageContent(), session);
??????????? message.setLongProperty("id", data.getMessageHeader().getId());
??????????? message.setIntProperty("receiver", data.getMessageHeader().getReceiver());
??????????? message.setIntProperty("sender", data.getMessageHeader().getSender());
??????????? message.setIntProperty("type", data.getMessageHeader().getType());
??????????? message.setStringProperty("sendPerson", data.getMessageHeader().getSendPerson());
??????????? log.info("發送消息[MessageSender]:\n" + message);
???????????? return message;
??????? } else {
??????????? return null;
??????? }
??? }

}
消息類文件? 消息父類：ApmgtMessageData.java
public class ApmgtMessageData<T extends Serializable>{

??? protected T messageContent;
???
??? protected MessageHeader messageHeader;

??? public T getMessageContent() {
??????? return this.messageContent;
??? }

??? public MessageHeader getMessageHeader() {
??????? return this.messageHeader;
??? }

??? public void setMessageContent(T messageContent) {
??????? this.messageContent = messageContent;
??? }
??? public void setMessageHeader(MessageHeader messageHeader) {
??????? this.messageHeader = messageHeader;
??? }

}
消息屬性的一個類MessageHeader.java
public class MessageHeader {

??? /**
???? * 消息ID
???? */
??? private long id;

??? /**
???? * 消息類型
???? */
??? private int type;

??? /**
???? * 消息發送方，發送消息的模塊
???? */
??? private int sender;

??? /**
???? * 消息接收方，接收消息的模塊
???? */
??? private int receiver;

??? /**
???? * 消息發送者，具體的用戶
???? */
??? private String sendPerson;

??? public MessageHeader(){
??????? this.id = System.currentTimeMillis() ;
??? }
???
??? public long getId() {
??????? return id;
??? }

??? public void setId(long id) {
??????? this.id = id;
??? }

??? public String getSendPerson() {
??????? return sendPerson;
??? }

??? public void setSendPerson(String sendPerson) {
??????? this.sendPerson = sendPerson;
??? }

??? public int getReceiver() {
??????? return receiver;
??? }

??? public void setReceiver(int receiver) {
??????? this.receiver = receiver;
??? }

??? public int getSender() {
??????? return sender;
??? }

??? public void setSender(int sender) {
??????? this.sender = sender;
??? }

??? public int getType() {
??????? return type;
??? }

??? public void setType(int type) {
??????? this.type = type;
??? }

}

消息體的類ModPasswordRequest.java
public class ModPasswordRequest implements Serializable{