출처 :
http://dbin318.tistory.com/13
웹페이지 호출 후 오래 걸리는 작업을 실행하는 경우 응답을 바로 할 수 없어서
MQ 시스템을 적용하게 되었습니다.
MQ(Message Queue) 시스템은
Message를 Queue에 전달하고, MQ시스템은 다시 Queue에서 Message을 받아서
Message을 실행하는 것으로, 시스템에서 처리 가능한 용량 만큼만 Queue에 Message을 받아서
처리 하게 됩니다.
부하가 많이 걸리는 SMS 시스템과 같은 시스템에 적용하게 됩니다.
저의 경우는 부하가 많이 걸리는 작업은 아니지만
특정 작업이 1시간 이상 걸리는 작업을 웹페이지에서 호출하는데,
호출후 바로 응답을 받을 수 없는 문제로 MQ 시스템을 적용하게 되었습니다.
(Message을 Queue에 전달하고 바로 응답 페이지를 보여줄 수 있기때문에...비동기식 호출이 가능)
자세한 설명은 출처 페이지에서 보실수 있습니다.
적용환경
Tomcat 7
Spring 3.0.4
ActiveMQ 5.4.3
test-activemq.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
<!-- a pooling based JMS provider -->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>vm://localhost</value>
</property>
</bean>
<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="dbin.queue" />
</bean>
<bean id="msgConverter" class="test.dbin.MsgConverterImpl" />
<bean id="msgMdp" class="test.dbin.MsgMDP" />
<bean id="purePojoMdp"
class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<property name="delegate" ref="msgMdp" />
<property name="defaultListenerMethod" value="handleMessage" />
<property name="messageConverter" ref="msgConverter" />
</bean>
<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer">
<property name="connectionFactory" ref="jmsFactory" />
<property name="destination" ref="queueDestination" />
<property name="messageListener" ref="purePojoMdp" />
</bean>
<!-- Spring JMS Template -->
<bean id="producerJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory" />
<property name="defaultDestination" ref="queueDestination" />
<property name="messageConverter" ref="msgConverter" />
</bean>
<bean id="producer" class="test.dbin.MsgProducerImpl">
<property name="jmsTemplate" ref="producerJmsTemplate" />
</bean>
</beans>
Msg.java
package test.dbin;
public class Msg {
private String name;
private String value;
public void setName(String name) {
this.name = name;
}
public String getName() {
return name;
}
public void setValue(String value) {
this.value = value;
}
public String getValue() {
return value;
}
public String toString() {
return "name = " + name + ", value = " + value;
}
}
MsgProducer.java
package test.dbin;
import org.springframework.jms.core.JmsTemplate;
public interface MsgProducer {
public void send(final Msg map);
public void setJmsTemplate(JmsTemplate jmsTemplate);
}
MsgProducerImpl.java
package test.dbin;
import org.springframework.jms.core.JmsTemplate;
public class MsgProducerImpl implements MsgProducer {
private JmsTemplate jmsTemplate;
public void setJmsTemplate(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
public void send(final Msg msg) {
jmsTemplate.convertAndSend(msg);
}
}
MsgMDP.java
package test.dbin;
/**
* Message Driven POJO
*
*/
public class MsgMDP {
public void handleMessage(Msg msg) {
// handles the message
System.out.println("handler called");
System.out.println(msg);
}
}
MsgConverterImpl.java
package test.dbin;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.support.converter.MessageConversionException;
import org.springframework.jms.support.converter.MessageConverter;
/**
* MapMessage로의 conversion을 담당하는 class
*
*
*/
public class MsgConverterImpl implements MessageConverter {
public MsgConverterImpl() {
}
public Object fromMessage(Message message) throws JMSException, MessageConversionException {
if( !(message instanceof MapMessage)) {
throw new MessageConversionException("not MapMessage");
}
System.out.println("MsgConverterImpl.fromMessage");
MapMessage mapMessage = (MapMessage)message;
Msg msg = new Msg();
msg.setName(mapMessage.getString("name"));
msg.setValue(mapMessage.getString("value"));
return msg;
}
public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
if ( !(object instanceof Msg) ) {
throw new MessageConversionException("not Msg");
}
System.out.println("MsgConverterImpl.toMessage");
Msg msg = (Msg)object;
MapMessage mapMessage = session.createMapMessage();
mapMessage.setString("name", msg.getName());
mapMessage.setString("value", msg.getValue());
return mapMessage;
}
}
MQController.java
@Override
public ModelAndView handleRequest(HttpServletRequest request, HttpServletResponse response) throws Exception {
Msg msg = new Msg();
msg.setName("daniel yoon");
msg.setValue("lullaby");
// 전송
MsgProducer producer = (MsgProducer)BeanUtils.getBean("producer");
producer.send(msg);
System.out.println(msg + " sent");
ModelAndView mv = new ModelAndView();
mv.setViewName("/index");
return mv;
}실행결과
MsgConverterImpl.toMessage
MsgConverterImpl.fromMessage
handler called
name = daniel yoon, value = lullaby
name = daniel yoon, value = lullaby sent
jstl-1.2.jar