Spring+ActiveMQ+Flex- 智慧公交 - JAVA

; } catch (JMSException e) { e.printStackTrace(); try { connection.close(); } catch (JMSException e1) { e1.printStackTrace(); } } } }); } } catch (Exception e) { } } }

3. ControlServlet1.java

package com.test.jms.servlet;

 
 

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.springframework.context.ApplicationContext;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;
 
 
 
 
public class ControlServlet1 extends HttpServlet {
    
 

	public void init() throws ServletException {
		 
 
	}
	 
	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		     doPost(request,response);
	}

	 
	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
 
		
	}

}

八．前台Flex的代码

  

  
	
	
   
     import mx.controls.Alert; import mx.messaging.events.MessageEvent; import mx.messaging.events.MessageFaultEvent; import mx.rpc.events.FaultEvent; import mx.messaging.ChannelSet; import mx.messaging.channels.AMFChannel; import mx.messaging.channels.SecureStreamingAMFChannel; import mx.messaging.channels.StreamingAMFChannel; protected function init():void{ //调用后台的Receive类中的doReceive方法，实现订阅和监听消息 ReceiveMessage.doReceive(); //给我们定义的consumer对象指定一个信道，我们定义了两种信道，在services-config.xml文件中，此处选用my-streaming-amf consumer.subscribe(); } //按钮点击触发的操作 protected function btnSendMessage_clickHandler(event:MouseEvent):void { Send.send(myinput.text); myinput.text=""; } //点击按钮后操作失败的处理 protected function Send_faultHandler(event:FaultEvent):void { Alert.show("send is fail,because:"+ event.fault.toString()); } //收到消息的失败处理 protected function ReceiveMessage_faultHandler(event:FaultEvent):void { Alert.show("receive is fail,because:"+ event.fault.toString()); } //生产者收到消息的错误处理 protected function consumer_faultHandler(event:MessageFaultEvent):void { Alert.show("error"); Alert.show(event.faultString); } //生产者收到消息后的处理 protected function consumer_messageHandler(event:MessageEvent):void { txtMessage.text = txtMessage.text + event.message.body.toString() + "\n"; }

九．启动ActiveMQ

十．启动程序

十一.总结

1. ActiveMQ如何将对象推送到前端，前端又是如何接受对象？

2. Spring如何更有效地管理ActiveMQ？

3. 如何实现订阅的信息筛选？

4. jar包下载地址http://download.csdn.net/detail/allen_gang/6659767

Spring+ActiveMQ+Flex- 智慧公交(三)