flex+blazeds+java+spring后台消息推送，有界面维护

之前写过一篇文章：flex+blazeds+java后台消息推送(简单示例)  ，现在要写的是这个的升级版，改动还是挺多的，在上面的基础上增加了spring配置，还有界面的维护。后台基本上全变了。呵呵 。。。下面看实现过程
大体的思路是：服务器启动时，查询数据库获取为推送的消息，存储到内存中，定义了一个全局变量MESSAGE_LIST，集合类型。以后的每次维护，包括(增、删、改)，都同时维护两份，及数据库和内存，保证两者的一致。当一条消息推送完成，即从MESSAGE_LIST中删除。
首先，添加spring的配置，在web-application-config.xml文件中添加

1.   <flex:message-brokerid="_messageBroker">  

2.          <flex:message-service  

3.             default-channels="my-streaming-amf,my-polling-amf"/>  

4.          </flex:message-broker>

5.          <flex:message-destination id="tick-data-feed"channels="my-streaming-amf,my-polling-amf"allow-subtopics="true" subtopic-separator="."/>

复制代码

没添加之前时：

1.   <flex:message-broker />

复制代码

主要是为了在后台获取message-broker，services-config.xml的配置还是一样，不变。
然后，后台java类：

1.           /**

2.            * 新增消息

3.            *@param paramMessage

4.            *@return

5.            *@throws ServiceException

6.            *@throws SQLException

7.            * @author:IT氧吧

8.            *@createDate: 2011-5-17

9.            *@modifiedBy:IT氧吧

10.           *@modifiedDate:2011-5-17

11.           */

12.         public String savePushMessage(PushMessage paramMessage)

13.                         throwsServiceException,SQLException {

14.                

15.                paramMessage.setStartDate(DateUtil.parseDate(paramMessage.getStartDateCN(),DateUtil.YMDHMS_PATTERN));

16.                paramMessage.setEndDate(DateUtil.parseDate(paramMessage.getEndDateCN(),DateUtil.YMDHMS_PATTERN));

17.                 Date d = systemService.getDateFromDataBase();

18.                 if(paramMessage.getStartDate().compareTo(d)< 0 || paramMessage.getEndDate().compareTo(d) < 0){

19.                         thrownew ServiceException("推送日期不能早于当前日期");

20.                 }

21.                if(paramMessage.getStartDate().compareTo(paramMessage.getEndDate()) > 0){

22.                         thrownew ServiceException("推送起始日期不能晚于推送结束日期");

23.                 }

24.                 /** 保存到数据库 */

25.                 Long messageId = systemService.savePushMessage(paramMessage);

26.                 /** 添加到集合中 */

27.                 GlobalNames.MESSAGE_LIST.add(paramMessage);

28.                

29.                 /** 集合重新排序降序

30.                 Comparator<PushMessage> comparator = newComparator<PushMessage>(){

31.                          @Override

32.                       public intcompare(PushMessage o1,PushMessage o2) {

33.                         returno1.getStartDate().compareTo(o2.getStartDate());

34.                       }

35.                 };

36.                 Collections.sort(GlobalNames.MESSAGE_LIST,comparator); */

37.                 /**

38.                  * 如果GlobalNames.MESSAGE_LIST没有消息，此时新增消息的时候就得推送，否则只是把消息添加到GlobalNames.MESSAGE_LIST并排序

39.                  * */

40.                 if(GlobalNames.MESSAGE_LIST.size() == 1){

41.                        PushMessageUtil.startPush(systemService);

42.                 }

43.                 return messageId.toString();

44.          }

复制代码

下面看一下PushMessageUtil

1.          public static void startPush(SystemService systemService){

2.                  if(GlobalNames.MESSAGE_LIST.size() > 0){

3.                          if(t ==null){

4.                                 t = new Timer();

5.                                 try {

6.                                         dbDate =systemService.getDateFromDataBase();

7.                                 } catch (ServiceException e) {

8.                                         // TODOAuto-generated catch block

9.                                         e.printStackTrace();

10.                                } catch (SQLException e) {

11.                                        // TODOAuto-generated catch block

12.                                        e.printStackTrace();

13.                                }

14.                         }

15.                         /**

16.                          * 下面一段代码在一种情况下会报错，即系统刚启动还没有任何人登录，

17.                          * 此时系统flex框架部分还未初始化,获取到msgBroker为空

18.                         *  */

19.                        msgBroker = MessageBroker.getMessageBroker("_messageBroker");

20.                         clientID= UUIDUtils.createUUID();

21.                        t.scheduleAtFixedRate(new TimerTask() {

22.                                @Override

23.                                public void run() {

24.                                        // TODOAuto-generated method stub

25.                                        if(msgBroker ==null){

26.                                               msgBroker = MessageBroker.getMessageBroker("_messageBroker");

27.                                        }

28.                                        PushMessage message;

29.                                       dbDate.setMinutes(dbDate.getMinutes()+1);

30.                                        /** 每隔1分钟轮询一次 */

31.                                        /** 注意下面的循环不能用foreach，否则报java.util.ConcurrentModificationException*/

32.  //                                      for(PushMessagemessage : GlobalNames.MESSAGE_LIST){

33.                                        for(inti=0;i<GlobalNames.MESSAGE_LIST.size();i++){

34.                                               String dateStr = DateUtil.format(dbDate,DateUtil.YMDHMS_PATTERN);

35.                                               message = GlobalNames.MESSAGE_LIST.get(i);

36.                                               if((message.getStartDate().getMinutes()-dbDate.getMinutes())% message.getInterval() == 0){

37.                                                       pMessage = message;

38.                                                       start();

39.                                               }

40.                                               

41.                                               //是否等于结束时间

42.                                               if(message.getEndDateCN().substring(0,message.getEndDateCN().lastIndexOf(":")).equals(dateStr.substring(0,dateStr.lastIndexOf(":")))){

43.                                                      GlobalNames.MESSAGE_LIST.remove(message);

44.                                                       System.out.println("大小："+GlobalNames.MESSAGE_LIST.size());

45.                                                       stopMessage = message;

46.                                                       stop();

47.                                                       if(GlobalNames.MESSAGE_LIST.size()== 0){

48.                                                              t.cancel();

49.                                                              t = null;

50.                                                              break;

51.                                                       }

52.                                               }

53.                                        }

54.                                }

55.                         },1000*60,1000*60);

56.                 }

57.          }

58.          

59.          /**

60.           * 开始推送

61.           *@author: IT氧吧

62.           *@createDate: 2011-5-20

63.           *@modifiedBy: IT氧吧

64.           *@modifiedDate:2011-5-20

65.           */

66.         private static void start() {

67.                 AsyncMessage msg = new AsyncMessage();

68.                msg.setDestination("tick-data-feed");

69.                 msg.setHeader("DSSubtopic","tick");

70.                 msg.setClientId(clientID);

71.                 msg.setMessageId(UUIDUtils.createUUID());

72.                 msg.setTimestamp(System.currentTimeMillis());

73.                 msg.setBody(pMessage);

74.                 if(msgBroker != null){

75.                        msgBroker.routeMessageToService(msg,null);

76.                        System.out.println("start!!");

77.                 }

78.          }

79.   

80.          /**

81.           * 停止推送

82.           *@author: IT氧吧

83.           *@createDate: 2011-5-20

84.           * @modifiedBy:IT氧吧

85.           *@modifiedDate:2011-5-20

86.           */

87.         private static void stop() {

88.                System.out.println(stopMessage.getContent()+"  已经推送完成");

89.          }

复制代码

不解释，应该都能看懂，该有的注释也都有
前台还是一样，该添加的监听还是得添加，只是多了个，如果有多个消息同时推送时，已经推送过的消息将不会显示

1.   private var msgList:ArrayCollection = newArrayCollection();

2.                          privatefunction messageHandler(event:MessageEvent):void   

3.                          {  

4.                                 var pmsg:ServerPushMessageVO = event.message.bodyas ServerPushMessageVO;

5.                                 /**

6.                                  * 返回指示视图是否包含指定对象的信息。与 IViewCursor.findxxx 方法不同，

7.                                  * 此搜索仅在找到完全与参数匹配的项目时才会成功。如果视图中包含已应用到该视图的滤镜，

8.                                  * 则即使基本集合确实包含该项目，此方法也会返回 false。

9.                                  * */

10.                                if(!msgList.contains(pmsg.id))

11.                                {

12.                                        var showTipMessageG:ShowTipMessageG= new ShowTipMessageG();

13.                                       msgList.addItem(pmsg.id);

14.                                       showTipMessageG.serverPushMessageVO = pmsg;

15.                                        PopUpEffect.show(showTipMessageG,this,true);

16.                                }

17.                         }  

复制代码

下面上几张效果图 新增消息页面 弹出提示页面 ok，消息推送的到此结束。。。