Spring

pom.xml에 아래 추가. 1 2 3 4 5 6 <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>4.0.5.RELEASE</version> <scope>test</scope> </dependency> test java코드 MemberServiceTest.java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration( { "classpath:servlet-context.xml", "classpath:config/context-datasource.xml" } ) public class MemberServiceTest { @Autowired MemberService memberService; @Test public void testSr2002() throws Exception { RequestData req = new RequestData(null, new DbMap()); ResponseData res = new ResponseData(new DbMap()); memberService.sr2002(req, res); } } 이때 디비를 jndi-lookup 를 이용하는 경우를 위해 test/resources/config/context-datasource.xml 을 넣어서 아래와 같이 기존 id를 덮었다. ...

설치는 그냥 rpm 으로 설치 1 2 3 4 5 # 서버 시작. sbin/rabbitmq-server start # 서버 중지 sbin/rabbitmqctl stop spring-rabbit 연동 pom.xml 1 2 3 4 5 <dependency> <groupid>org.springframework.amqp</groupId> <artifactid>spring-rabbit</artifactId> <version>1.4.1.RELEASE</version> </dependency> context-rabbitmq.xml 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 <!-- A reference to the org.springframework.amqp.rabbit.connection.ConnectionFactory --> <rabbit:connection-factory id="connectionFactory" host="localhost" username="worker" password="workerpassword" /> <!-- Creates a org.springframework.amqp.rabbit.core.RabbitTemplate for access to the broker --> <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" /> <!-- Creates a org.springframework.amqp.rabbit.core.RabbitAdmin to manage exchanges, queues and bindings --> <rabbit:admin connection-factory="connectionFactory" /> <!-- Creates a queue for consumers to retrieve messages --> <rabbit:queue name="simple_queue" /> <rabbit:listener-container connection-factory="connectionFactory"> <rabbit:listener queues="simple_queue" ref="mqService" /> </rabbit:listener-container> MqService.java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 @Service public class MqService implements MessageListener { private static final Logger logger = LoggerFactory.getLogger(MqService.class); private static final String TASK_QUEUE_NAME = "simple_queue"; @Autowired private RabbitTemplate rabbitTemplate; public void send(String message) throws IOException { rabbitTemplate.convertAndSend(TASK_QUEUE_NAME, message); logger.info("send message={}", message); } @Override public void onMessage(Message message) { String msg = null; try { msg = new String(message.getBody(), "UTF-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } logger.info("recv message=" + msg ); } }

항상 json으로만 뱉다가 xml로 뱉어야 하는 상황이 발생해서 만든 spring view 클래스 결과가 map에 경우에만 해당됨 아래 설정하고… applicationServlet.xml 1 2 3 4 <beans:bean id="xmlView2" class="org.springframework.web.servlet.view.XmlViewResolver"> <beans:property name="order" value="1"/> <beans:property name="location" value="classpath:xml-views.xml"/> </beans:bean> xml-views.xml 내용. 1 2 3 4 5 6 7 8 9 10 <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> <beans> <bean name="xmlView" class="com.xxxxx.view.AjaxResponseXMLView"> <property name="contentType"> <value>text/xml;charset=utf-8</value> </property> </bean> </beans> AjaxResponseXMLView.java 아래 클래스를 이용함 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 public class AjaxResponseXMLView extends AbstractView { @Override protected void renderMergedOutputModel(Map map, HttpServletRequest request, HttpServletResponse response) throws Exception { String xmlHeader = "\r\n"; StringBuffer xmlSb = new StringBuffer(); xmlSb.append(xmlHeader); xmlSb.append(""); writeFromMap(xmlSb, map); xmlSb.append(""); response.setContentType("application/xml"); response.setCharacterEncoding("utf-8"); response.setHeader("Cache-Control", "no-cache"); response.setContentLength(xmlSb.toString().getBytes("utf-8").length); response.getWriter().print(xmlSb.toString()); } private void writeFromMap(StringBuffer sb, Map map) { for(Object str : map.keySet()) { Object v = map.get(str); sb.append("<" + str + ">"); if(v instanceof Map) { writeFromMap(sb, (Map) v); } else if(v instanceof List) { writeFromList(sb, (List) v); } else { writeFromData(sb, v); } sb.append("</" + str + ">"); } } private void writeFromList(StringBuffer sb, List list) { for(Object v : list) { sb.append(""); if(v instanceof Map) { writeFromMap(sb, (Map)v); } else if(v instanceof List) { writeFromList(sb, (List) v); } else { writeFromData(sb, v); } sb.append(""); } } private void writeFromData(StringBuffer sb, Object data) { sb.append(escapeXml(data+"")); } private String escapeXml(String src) { // " " // < < // > > // & & src = src.replace("\"", """); src = src.replace("<", "<"); src = src.replace(">", ">"); src = src.replace("&", "&"); return src; } }