BlazeDSTag Archive for blazeds archive at Flabo

Tag Archive for 'blazeds'

25AugMessaging中にRemoteObjectの処理をする

Messaging中にRemoteObjectにデータを保存したり、メソッド実行したりする際にRemotingObjectにアクセスする方法を忘れないようにメモ。

パッケージ名：packagename
Messagingをするクラス名：MessagingAdapter（ServiceAdapterのサブクラス）
Messagingのadapter-definition id：hoge-messaging-adapter
RemoteObjectのクラス名：ClassName
RemoteObjectのdestination id：hoge-remote-object

FlexContext.getServletContext()で取得したServletContextから、getAttribute('destination id')でRemoteObjectの参照を取得する。
これでメッセージングする度にRemoteObjectのsetDataにmessageのbodyが渡されるようになる。
あとは煮るなり焼くなり・・・

Java
ClassName.java
Source

package packagename;
 
import packagename.ClassName;
 
import flex.messaging.config.ConfigMap;
import flex.messaging.messages.Message;
import flex.messaging.FlexContext;
import flex.messaging.MessageBroker;
import flex.messaging.services.MessageService;
import flex.messaging.services.ServiceAdapter;
 
import java.util.HashMap;
 
import javax.servlet.ServletContext;
 
public class MessagingAdapter extends ServiceAdapter {
    private MessageBroker messageBroker;
    private MessageService messageService;
    private ServletContext servletContext;
    private ClassName remoteObject;
    
    @Override
    public void initialize(String id, ConfigMap properties) {
        
    }
    
    @Override
    public void start() {
        // MessagingService取得
        messageBroker = MessageBroker.getMessageBroker(null);
        messageService = (MessageService) messageBroker.getService("hoge-messaging-service");
        
        // RemoteObject取得
        servletContext = FlexContext.getServletContext();
        remoteObject = (IconManager) servletContext.getAttribute("hoge-remote-object");
    }
    
    @Override
    public void stop() {
        
    }
    
    @Override
    public Object invoke(Message message) {
        // Messaging配信
        messageService.pushMessageToClients(message, true);
        messageService.sendPushMessageFromPeer(message, true);
        
        // RemoteObjectへmessageのbodyを渡す
        HashMap hmMessage = (HashMap) message.getBody();
        remoteObject.setData(hmMessage);
        
        return null;
    }
    
}

ちなみにこの時の*-config.xmlたちはこんな感じ。

XML
messaging-config.xml
Source

<?xml version="1.0" encoding="UTF-8"?>
 
<service id="hoge-messaging-service"
    class="flex.messaging.services.MessageService">
 
    <adapters>
        <adapter-definition id="actionscript"
            class="flex.messaging.services.messaging.adapters.ActionScriptAdapter"
            default="true" />
        <adapter-definition id="hoge-messaging-service"
            class="packagename.MessagingAdapter" />
    </adapters>
 
    <!-- ...中略... -->
 
</service>

XML
remoting-config.xml
Source

<?xml version="1.0" encoding="UTF-8"?>
 
<service id="hoge-remoting-service" class="flex.messaging.services.RemotingService">
    
    <!-- ...中略... -->
    
    <destination id="hoge-remote-object">
        <properties>
            <source>packagename.ClassName</source>
            <scope>application</scope>
        </properties>
    </destination>
    
</service>

in Web. 0 Comments BlazeDS, Java

21Aug識別子なのに識別できなかった件

BlazeDSのMessaging APIsのServiceAdapterとAbstractBootstrapServiceのサブクラスを作っていた時のお話。

Java
MessagingAdapter.java
Source

public class MessagingAdapter extends ServiceAdapter {
    // ...中略...
    @Override
    public Object invoke(Message message) {
        System.out.println(message.getClientId());  // Result 19FF0FC6-1818-5450-D6BE-33FF6297BFD0
    }
}

Java
BootstrapService.java
Source

public class BootstrapService extends AbstractBootstrapService {
    // ...中略... 
    class ClientWatcher implements MessageClientListener {
        public void messageClientCreated(MessageClient msgClient) {
            System.out.println(msgClient.getClientId());    // Result 19FF11B5-B30A-3172-EDD2-0AB30F8A73EA
        }
    }
}

この二つで取得できるクライアントIDって同一のクライアントなはずなのに別モノ。
この二つのクラスからRemoteObjectにクライアントID渡してごにょごにょしようとしてたらできなくて、調べていくとこういうことだった。

同じものが取得できると思ったのに。同じものが取得できると思ったのに。

in Web. 0 Comments BlazeDS, Java

17JulBlazeDS - Messaging(Client)

BlazeDSの主要な機能の一つであるMessegingのクライアントサイドの処理について。

srcを右クリックして、「新規 > MXML アプリケーション」をクリック。「ファイル名」をmessaging.mxmlと入力して「終了」。
クライアントの処理を書く。
- ActionScript
- Source
1. <?xml version="1.0" encoding="utf-8"?>
2. <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="vertical" initialize="init()" viewSourceURL="srcview/index.html">
4. <mx:Script>
5. <![CDATA[
6. import mx.messaging.events.MessageFaultEvent;
7. import mx.messaging.messages.AsyncMessage;
8. import mx.messaging.messages.IMessage;
9. import mx.messaging.ChannelSet;
10. import mx.messaging.channels.AMFChannel;
11. import mx.messaging.channels.StreamingAMFChannel;
12. import mx.messaging.events.MessageEvent;
13. import mx.messaging.events.ChannelEvent;
14. import mx.messaging.Consumer;
15. import mx.messaging.Producer;
17. private var producer:Producer = new Producer();
18. private var consumer:Consumer = new Consumer();
20. private function init():void {
21. initConnectEvent();
23. connectToServer();
24. }
26. private function initConnectEvent():void {
27. consumer.addEventListener(ChannelEvent.CONNECT, hdlConsumerConnect);
28. consumer.addEventListener(ChannelEvent.DISCONNECT, hdlConsumerDisconnect);
29. consumer.addEventListener(MessageEvent.MESSAGE, hdlConsumerMessage);
30. }
32. private function hdlConsumerConnect(ce:ChannelEvent):void {
33. log("Connect to Server.");
35. setSend(true);
36. }
38. private function hdlConsumerDisconnect(ce:ChannelEvent):void {
39. log("Disconnect from Server.");
41. setSend(false);
42. }
44. private function hdlConsumerMessage(me:MessageEvent):void {
45. log(me.message.body.chat);
46. }
48. private function setSend(bln:Boolean):void {
49. if (bln) {
50. btnSend.addEventListener(MouseEvent.CLICK, hdlSendClick);
51. } else {
52. btnSend.removeEventListener(MouseEvent.CLICK, hdlSendClick);
53. }
54. btnSend.enabled = bln;
55. tiChat.enabled = bln;
56. }
58. private function hdlSendClick(e:*):void {
59. var msg:IMessage = new AsyncMessage();
60. msg.body = {chat:tiChat.text};
62. producer.send(msg);
63. tiChat.text = "";
64. }
66. private function connectToServer():void {
67. setChannel("localhost");
68. setDistination();
70. consumer.subscribe();
71. }
73. private function setChannel(hostname:String):void {
74. var channelSet:ChannelSet = new ChannelSet();
75. var myStreamingAMF:AMFChannel = new StreamingAMFChannel("my-streaming-amf", "http://" + hostname + ":8400/tutorial/messagebroker/streamingamf");
76. var myPollingAMF:AMFChannel = new AMFChannel("my-polling-amf", "http://" + hostname + ":8400/tutorial/messagebroker/amfpolling");
77. myPollingAMF.pollingEnabled = true;
78. myPollingAMF.pollingInterval = 1;
80. channelSet.addChannel(myStreamingAMF);
81. channelSet.addChannel(myPollingAMF);
83. producer.channelSet = channelSet;
84. consumer.channelSet = channelSet;
85. }
87. private function setDistination():void {
88. producer.destination = "messagingTutorial";
89. consumer.destination = "messagingTutorial";
90. }
92. private function log(str:String):void {
93. taLog.text = str + "\n" + taLog.text;
94. }
96. ]]>
97. </mx:Script>
99. <mx:ApplicationControlBar width="100%" height="100%">
100. <mx:TextArea width="100%" height="100%" id="taLog" editable="false"/>
101. </mx:ApplicationControlBar>
102. <mx:ApplicationControlBar width="100%">
103. <mx:TextInput id="tiChat" width="100%" enabled="false" enter="hdlSendClick(event)"/>
104. <mx:Button label="Send" id="btnSend" enabled="false"/>
105. </mx:ApplicationControlBar>
107. </mx:Application>
「ファイル > エクスポート」をクリックして、「Flex Builder > リリースビルド」を選択して「次へ」。
「書き出し先フォルダ」をtutorialにして「終了」。
ブラウザを二窓開いてhttp://localhost:8400/tutorial/messaging.htmlへアクセス。
一方の窓でテキストを入力し、Sendを押すと、両方のクライアントにストリーミングでテキストが配信される。

in Web. 0 Comments ActionScript 3.0, BlazeDS, Flex

17JulBlazeDS - Messaging(Server)

BlazeDSの主要な機能の一つであるMessegingのサーバーサイドの処理について。

services-config.xmlにstreamingの設定を書く。
- XML
- services-config.xml
- Source
1. <?xml version="1.0" encoding="UTF-8"?>
3. <service id="message-service" class="flex.messaging.services.MessageService">
5. <adapters>
6. <adapter-definition id="actionscript" class="flex.messaging.services.messaging.adapters.ActionScriptAdapter" default="true" />
7. 
8. </adapters>
10. <default-channels>
11. <channel ref="my-streaming-amf"/>
12. </default-channels>
14. <destination id="messagingTutorial"/>
16. </service>
messaging-config.xmlにデフォルトチャンネルの設定、サービスのIDを書く。
- XML
- messaging-config.xml
- Source
1. <channel-definition id="my-streaming-amf" class="mx.messaging.channels.StreamingAMFChannel">
2. <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/streamingamf" class="flex.messaging.endpoints.StreamingAMFEndpoint"/>
3. <properties>
4. <idle-timeout-minutes>0</idle-timeout-minutes>
5. <max-streaming-clients>100</max-streaming-clients>
6. <server-to-client-heartbeat-millis>5000</server-to-client-heartbeat-millis>
7. <user-agent-settings>
8. <user-agent match-on="MSIE" kickstart-bytes="2048" max-streaming-connections-per-session="10"/>
9. <user-agent match-on="Firefox" kickstart-bytes="2048" max-streaming-connections-per-session="10"/>
10. <user-agent match-on="AppleWebKit" kickstart-bytes="2048" max-streaming-connections-per-session="10"/>
11. </user-agent-settings>
12. </properties>
13. </channel-definition>
サーバーを再起動。

in Web. 0 Comments BlazeDS, Flex, Java

08JulBlazeDS - Remotoing(Client)

BlazeDSの主要な機能の一つであるRemotingのクライアントサイドの処理について。

「ファイル > 新規 > MXML アプリケーション」をクリックして、「ファイル名」にRemoting.mxmlと入力して、「終了」。
remoting.mxmlにクライアントの処理を書く。
- ActionScript
- remoting.mxml
- Source
1. <?xml version="1.0" encoding="utf-8"?>
2. <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="vertical" initialize="init()" viewSourceURL="srcview/index.html">
4. <mx:Script>
5. <![CDATA[
6. import mx.rpc.remoting.RemoteObject;
7. import mx.rpc.events.ResultEvent;
8. import mx.rpc.events.FaultEvent;
10. private var remoteObject:RemoteObject = new RemoteObject();
12. private function init():void {
13. initRemoteObject();
14. initButtons();
15. }
17. private function initRemoteObject():void {
18. remoteObject.destination = "remotingTutorial";
19. remoteObject.addEventListener("result", hdlROResult);
20. remoteObject.addEventListener("fault", hdlROFault);
21. }
23. private function hdlROResult(re:ResultEvent):void {
24. var result:int = re.message.body.result;
25. setResult(result.toString());
26. }
28. private function hdlROFault(fe:FaultEvent):void {
29. setResult("Fail to get responce.");
30. }
32. private function setResult(str:String):void {
33. tiResult.text = str;
34. }
36. private function initButtons():void {
37. btnCalc.addEventListener(MouseEvent.CLICK, hdlGetCalcClick);
38. btnClear.addEventListener(MouseEvent.CLICK, hdlClearClick);
40. btnCalc.enabled = true;
41. btnClear.enabled = true;
42. }
44. private function hdlGetCalcClick(me:MouseEvent):void {
45. var obj:Object = new Object();
47. obj.param0 = int(tiParam_0.text);
48. obj.param1 = int(tiParam_1.text);
50. remoteObject.getCalcResult(obj);
51. }
53. private function hdlClearClick(me:MouseEvent):void {
54. setResult("");
55. }
57. ]]>
58. </mx:Script>
60. <mx:ApplicationControlBar>
61. <mx:TextInput id="tiParam_0" text="10"/>
62. <mx:Label text="+" textAlign="center"/>
63. <mx:TextInput id="tiParam_1" text="20"/>
64. <mx:Label text="=" textAlign="center"/>
65. <mx:TextInput id="tiResult"/>
66. </mx:ApplicationControlBar>
67. <mx:ApplicationControlBar>
68. <mx:Button label="getCalcResult" id="btnCalc" enabled="false"/>
69. <mx:Button label="clear" id="btnClear" enabled="false"/>
70. </mx:ApplicationControlBar>
72. </mx:Application>
「ファイル > エクスポート」より、「Flex Builder > リリースビルド」を選択して「次へ」。「書き出し先フォルダ」をtutorialにして、「終了」。
これで、クライアントの開発は完了。ブラウザでhttp://localhost:8400/tutorial/remoting.htmlにアクセスして確認。