flex+java+blazeds 多通道好文

http://www.cnblogs.com/noam/archive/2010/08/05/1793504.html

blazeds, spring3整合实现RPC服务和消息服务

环境：

　　MyEclipse 7.5

　　Flash Builder 4 plugin for eclipse

　　Tomcat 6

　　BlazeDS 4.0.0

　　springframework 3.0.3

　　Spring-flex整合 org.springframework.flex-1.0.3.RELEASE.jar （适用于spring2.5.6+，blazeds3.2+）

步骤：

通过J2EE Web工程添加Flex项目，进行BlazeDS开发。

　　2. 导入spring包和spring-flex集成包。

　　3. 配置web.xml，配置DispatcherServlet，使用spring进行管理，并将请求映射到MessageBroker。

　　4. 创建web-application-config.xml，配置flex服务，主要是在spring中配置MessageBroker。

　　5. 创建remoting-destination和 message-destination，修改channel属性。

　　6. 创建mxml文件，定义channelSet，注册remote-object和定义Productor, Consumer.

注意：

　　当不使用spring直接配置blazeDS实现RPC和消息服务时，仅需要在remoting-config.xml和messaging-config.xml中配置destination，只要在这些文件中配置了默认通道，mxml文件中不需要再定义channelSet即可执行。而使用spirng时，仅当将default-channels定义在services-config.xml的services标签中才有效，若在services-config.xml的services标签中加载其他配置文件，在这些文件中配置各自的default-channels，会报如下错误：[MessagingError message='×××'artgallerydataservice' either does not exist or the destination has no channels defined (and the application does not define any default channels.)']，原因是没有找到通道。如果仅将通道定义在<flex:message-destination>或<flex:remoting-destination>中，也会出现同样的情况。

　　对于以上的两个问题，我觉得几乎不可理解，解决方案是在mxml文件中定义channelSet以找到amf通道。

项目代码：

　　目录结构：

　　Web.xml:

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.4"
    xmlns="http://java.sun.com/xml/ns/j2ee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
    http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

    <servlet>
      <servlet-name>Spring MVC Dispatcher Servlet</servlet-name>
      <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
      <init-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/web-application-config.xml</param-value>
      </init-param>
      <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet-mapping>
      <servlet-name>Spring MVC Dispatcher Servlet</servlet-name>
      <url-pattern>/messagebroker/*</url-pattern>
    </servlet-mapping>

  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
</web-app>

　　web-application-config.xml:

　　　　<flex:message-broker/>是非常重要的，它还有其它的几种表示方法，但以这种最为简单，它通过MessageBrokerHandlerAdapter和HandlerMapping将请求发送给spring管理的MessageBroker。

　　　　注意这里一定要导入spring-flex集成的schemaLocation，remoting-destination和 message-destination也在这里定义。

web-application-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:flex="http://www.springframework.org/schema/flex"
    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.5.xsd
        http://www.springframework.org/schema/flex
        http://www.springframework.org/schema/flex/spring-flex-1.0.xsd">

    <flex:message-broker/>

    <flex:message-destination >
        <flex:remoting-destination/>
    </bean>
</beans>

　　services-config.xml:

　　　　这里最重要的是channels的定义和配置。

services-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<services-config>

    <services>
      <default-channels>
        <channel ref="my-amf"/>
      </default-channels>
    </services>

    <security>
        <login-command class="flex.messaging.security.TomcatLoginCommand" server="Tomcat"/>
        

        
        </redeploy>
    </system>

</services-config>

　　messaging-config.xml, proxy-config.xml, remoting-config.xml：

　　　　略。和blazeDS提供的几乎一样。

　　test.Test.java:

　　　　这里只定义了一个方法，用以测试远程方法调用。

package test;

public class Test {

    public void done(){
        System.out.println("OK.");
    }
}

　　flex_test.mxml:

　　　　这个不做过多解释。这里定义了AMFChannel和ChannelSet，避免找不到通道的问题。Productor和Consumer是实现BlazeDS消息服务的两个组件，AsyncMessage是用来发送消息的。

flex_test.mxml

<?xml version="1.0" encoding="utf-8"?>
<s:Application xmlns:fx="http://ns.adobe.com/mxml/2009"
               xmlns:s="library://ns.adobe.com/flex/spark"
               xmlns:mx="library://ns.adobe.com/flex/mx" minWidth="955" minHeight="600"
               creationComplete="consumer.subscribe();">

    <fx:Script>
        <![CDATA[
            import mx.controls.Alert;
            import mx.messaging.messages.*;
            import mx.messaging.events.*;
            import mx.rpc.events.FaultEvent;
            import mx.rpc.events.ResultEvent;

            // Write received message to TextArea control.
            private function messageHandler(event: MessageEvent):void {
            ta.text += event.message.body + " ";
            }

            // Compose the message as an instance of AsyncMessage,
            // then use the Producer.send() method to send it.
            private function sendMessage():void {
                var message: AsyncMessage = new AsyncMessage();
                message.body = userName.text + ": " + msg.text;
                producer.send(message);
                msg.text = "";
            }

            protected function button_clickHandler(event:MouseEvent):void
            {
                // TODO Auto-generated method stub
                object.done();
            }

            protected function resulth(event:ResultEvent):void
            {
                label.text="succeed!";
            }

            protected function faulth(event:FaultEvent):void
            {
                label.text="failed!";
                Alert.show("远程对象调用失败: "+event.fault);
            }

        ]]>
    </fx:Script>

    <fx:Declarations>
        
        <mx:AMFChannel />
</s:Application>

　　执行结果: