JMS与WebService负载均衡

  1 　　public class ServiceProxy extends HttpServlet {
  2 
  3 　　private ConnectionFactory factory;
  4 
  5 　　private Connection connection;
  6 
  7 　　private Queue queue;
  8 
  9 　　public void init() throws ServletException {
10 
11 　　super.init();
12 
13 　　try {
14 
15 　　//在这里为了简单起见，采用了ActiveMQ。在实际的J2EE应用中应通过JNDI查找相应的ConnectionFactory和Queue。
16 
17 　　factory = new ActiveMQConnectionFactory("vm://localhost");
18 
19 　　connection = factory.createConnection();
20 
21 　　connection.start();
22 
23 　　queue = new ActiveMQQueue("testQueue");
24 
25 　　} catch (JMSException e) {
26 
27 　　e.printStackTrace();
28 
29 　　}
30 
31 　　}
32 
33 　　protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
34 
35 　　if (req.getQueryString().endsWith("wsdl") || req.getQueryString().endsWith("WSDL")) {
36 
37 　　try {
38 
39 　　Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
40 
41 　　Message message = session.createMessage();
42 
43 　　//这个属性用来标示请求是否是WSDL请求，后面的Listener会根据它来调用具体的WebService。
44 
45 　　message.setBooleanProperty("isWsdl", true);
46 
47 　　message.setJMSReplyTo(session.createTemporaryQueue());
48 
49 　　session.createProducer(queue).send(message);
50 
51 　　//等待回复消息，它里面包含Service返回的WSDL，这里使用了一个选择器。
52 
53 　　String selector = String.format("JMSCorrelationID='%s'", message.getJMSMessageID());
54 
55 　　MessageConsumer consumer = session.createConsumer(message.getJMSReplyTo(), selector);
56 
57 　　TextMessage replyMessage = (TextMessage) consumer.receive();
58 
59 　　//将WSDL返回给客户端。
60 
61 　　resp.getWriter().write(replyMessage.getText());
62 
63 　　} catch (Exception e) {
64 
65 　　e.printStackTrace();
66 
67 　　}
68 
69 　　}
70 
71 　　}
72 
73 　　protected void doPost(HttpServletRequest req, HttpServletResponse resp) {
74 
75 　　try {
76 
77 　　//首先从客户端请求中得到SOAP请求部分。
78 
79 　　StringBuffer payLoad = new StringBuffer();
80 
81 　　BufferedReader reader = req.getReader();
82 
83 　　String temp;
84 
85 　　while ((temp = reader.readLine()) != null) {
86 
87 　　payLoad.append(temp);
88 
89 　　}
90 
91 　　//将SOAP请求封装成一个消息，发送到Queue。
92 
93 　　Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
94 
95 　　Message message = session.createTextMessage(payLoad.toString());
96 
97 　　message.setBooleanProperty("isWsdl", false);
98 
99 　　message.setJMSReplyTo(session.createTemporaryQueue());
100 
101 　　session.createProducer(queue).send(message);
102 
103 　　//等待回复，回复的消息中包含着服务端返回的SOAP响应。
104 
105 　　String selector = String.format("JMSCorrelationID='%s'", message.getJMSMessageID());
106 
107 　　MessageConsumer consumer = session.createConsumer(message.getJMSReplyTo(), selector);
108 
109 　　TextMessage replyMessage = (TextMessage) consumer.receive();
110 
111 　　//将SOAP响应返回给客户端。
112 
113 　　resp.getWriter().write(replyMessage.getText());
114 
115 　　} catch (Exception e) {
116 
117 　　e.printStackTrace();
118 
119 　　}
120 
121 　　}
122 
123 　　}

1 　　public class Listener {
2 
3 　　private ConnectionFactory factory;
4 
5 　　private Connection connection;
6 
7 　　private Queue queue;
8 
9 　　private Session session;
10 
11 　　public Listener() throws Exception {
12 
13 　　//为了简单，还是采用了ActiveMQ。
14 
15 　　factory = new ActiveMQConnectionFactory("vm://localhost");
16 
17 　　connection = factory.createConnection();
18 
19 　　connection.start();
20 
21 　　queue = new ActiveMQQueue("testQueue");
22 
23 　　session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
24 
25 　　}
26 
27 　　public void startUp() throws Exception {
28 
29 　　MessageConsumer consumer = session.createConsumer(queue);
30 
31 　　consumer.setMessageListener(new MessageListener() {
32 
33 　　public void onMessage(Message message) {
34 
35 　　try {
36 
37 　　String response;
38 
39 　　//通过判断isWSDL这个属性来判断是否是WSDL请求。
40 
41 　　if (message.getBooleanProperty("isWsdl")) {
42 
43 　　//如果是WSDL请求，则向服务器发送一个GET请求，并等待WSDL响应结果。
44 
45 　　HttpClient client = new HttpClient();
46 
47 　　//具体Service的地址，可以使用properties文件等。
48 
49 　　GetMethod m = new GetMethod("http://localhost:8081/hello?wsdl");
50 
51 　　client.executeMethod(m);
52 
53 　　response = m.getResponseBodyAsString();
54 
55 　　} else {
56 
57 　　//如果是SOAP请求，则将SOAP包发送给服务器，并等待SOAP响应。
58 
59 　　HttpClient client = new HttpClient();
60 
61 　　PostMethod m = new PostMethod("http://localhost:8081/hello");
62 
63 　　m.setRequestBody(((TextMessage) message).getText());
64 
65 　　client.executeMethod(m);
66 
67 　　response = m.getResponseBodyAsString();
68 
69 　　}
70 
71 　　//将WSDL响应或SOAP响应封装成一个消息，回复给Proxy。
72 
73 　　MessageProducer producer = session.createProducer(message.getJMSReplyTo());
74 
75 　　TextMessage replyMessage = session.createTextMessage(response);
76 
77 　　//设置JMSCorrelationID，Proxy通过它来得到该回复消息。
78 
79 　　replyMessage.setJMSCorrelationID(message.getJMSCorrelationID());
80 
81 　　producer.send(replyMessage);
82 
83 　　} catch (Exception ex) {
84 
85 　　ex.printStackTrace();
86 
87 　　}
88 
89 　　}
90 
91 　　});
92 
93 　　}
94 
95 　　}