Blazeds + MessageBroker

**issamjet** · 21/04/2009, 09h58

C'est juste une application simple de type HelloWorld.
Mon souci est que l'application doit agir d'une façon automatique et les messages doivent aller des classes Java vers Flex en utilisant le service Messaging (application de type DataPush).
Donc il ne faut pas utiliser les remoting objects à priori.
Je ne sais pas si mon problème se résume dans la construction d'une classe particulière pour définir un adaptateur particulier qui "extends ServiceAdapter" ou pas (je l'ai vu dans un exemple sur le net) mais probablement ce n'est pas nécessaire.

Bref j'ai besoin d'une application dont la mise à jour de la base de données implique une mise à jour dans l'interface graphique sans faire le rafraichissement de la page, comment je peux y arriver

un bout de code (avant que Jim Nastiq me le demande

)

Tout d'abord la classe Java

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
package com;
 
import flex.messaging.io.ArrayCollection;
import flex.messaging.messages.Message;
import flex.messaging.services.MessageService;
import flex.messaging.services.ServiceAdapter;
import flex.messaging.util.UUIDUtils;
 
import flex.messaging.MessageBroker;
import flex.messaging.io.ArrayList;
import flex.messaging.messages.AsyncMessage;
import flex.messaging.util.UUIDUtils;
 
public class MyTestClass {
	public static void main(String[] args) {
	AsyncMessage msg = new AsyncMessage();
	String clientID = UUIDUtils.createUUID();
 
	msg.setClientId(clientID);
	//msg.setTimestamp(new Date().getTime());
	//you can create a unique id
	msg.setMessageId(UUIDUtils.createUUID());
	//destination to which the message is to be sent
	msg.setDestination("MyDestination");		
	//set message body
 
	msg.setBody("Hi this is a message from a Java class :)");
	//set message header
	//msg.setHeader("sender", "From the server");
 
	System.out.println("ClientID:"+msg.getClientId()+"\nDestination:"+msg.getDestination()+"\nBody:"+msg.getBody());
 
	MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
	if(msgBroker==null)
		System.out.println("msgBroker is null ");
 
	try {
		//send message to destination
		msgBroker.routeMessageToService(msg, null);	
 
	} catch (Exception e) {
		System.out.println(e.toString());
	}
	}
}

et ensuite l'interface mxml

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
<mx:Script> 
  <![CDATA[
  	import mx.binding.utils.BindingUtils; 
      import mx.messaging.channels.AMFChannel; 
      import mx.messaging.ChannelSet; 
      import mx.messaging.events.MessageFaultEvent; 
      import mx.messaging.events.MessageAckEvent; 
      import mx.messaging.messages.AsyncMessage; 
      import mx.controls.Alert; 
      import mx.rpc.remoting.mxml.RemoteObject; 
      import mx.rpc.events.ResultEvent; 
 
      import mx.messaging.messages.IMessage; 
 
	  import mx.collections.ArrayCollection; 
 
            [Bindable] 
           public var myMessage:String;
 
 
      		private function messageHandler(message:IMessage):void 
      		{ 
       		 	myMessage = message.body as String;
       		 	myLabel.text=myMessage;
      		} 
 
      		private function init():void 
      		{ 
         		var msg:AsyncMessage = new AsyncMessage(); 
				//creating new msg with “New” to get current state. 
            	msg.body = "New"; 
        		producer.send(msg); 
        		consumer.subscribe(); 
      		} 
 
            private function handleFault(event:MessageFaultEvent):void 
      		{   
      			Alert.show(event.faultString); 
      		} 
 
      		private function ack(event:MessageAckEvent):void 
      		{
        		myMessage = event.message.body as String;
        		myLabel.text=myMessage;        		
      		}
 
    	]]> 
	</mx:Script> 
 
	<mx:Producer id="producer" destination="MyDestination" acknowledge="ack(event)"/> 
	<mx:Consumer id="consumer" destination="MyDestination" message="messageHandler(event.message)" />
 
	<mx:Label id="myLabel" text="HelloWorld"/>
 
</mx:Application>

Je crois que c'est pas nécessaire de mettre le web.xml et et les autres fichiers de configuration remoting-config, messaging-config et services-config

Merci

**babass77** · 22/04/2009, 17h12

Salut

je n'ai pas encore mis mon nez dans le messaging, mais je pense démarrer ca demain, je te tiens au jus dès que j'ai réussi à faire tourner un truc avec le messaging de Blaze dS, en espérant que ca ne soit pas trop tard

Babass

**babass77** · 22/04/2009, 17h20

Je peux déjà te filer le lien que j'ai trouvé mais j'avoue ne pas avoir encore regarder le fonctionnement

http://www.flex-tutorial.fr/wp-conte...g-blaze-ds.pdf

en espérant que cela peu t'aider

**babass77** · 23/04/2009, 12h38

Bonjour jet7fm,

j'ai fait un petite application de chat, que j'ai trouvé sur le net. Par contre j'ai séparé la partie cliente de la partie serveur.

Voici mon messaging-config.xml

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
<?xml version="1.0" encoding="UTF-8"?>
<service id="message-service" 
    class="flex.messaging.services.MessageService">
 
    <adapters>
        <adapter-definition id="actionscript" class="flex.messaging.services.messaging.adapters.ActionScriptAdapter" default="true" />
        <!-- <adapter-definition id="jms" class="flex.messaging.services.messaging.adapters.JMSAdapter"/> -->
    </adapters>
 
    <default-channels>
        <channel ref="my-long-polling-amf"/>
    </default-channels>
 
	<destination id="myChat"/>
 
</service>

Ensuite mon service-config.xml :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
 
<?xml version="1.0" encoding="UTF-8"?>
<services-config>
 
    <services>
        <service-include file-path="remoting-config.xml" />
        <service-include file-path="proxy-config.xml" />
        <service-include file-path="messaging-config.xml" />        
    </services>
 
    <security>
        <login-command class="flex.messaging.security.TomcatLoginCommand" server="Tomcat"/>
        <!-- Uncomment the correct app server
        <login-command class="flex.messaging.security.TomcatLoginCommand" server="JBoss">
		<login-command class="flex.messaging.security.JRunLoginCommand" server="JRun"/>        
        <login-command class="flex.messaging.security.WeblogicLoginCommand" server="Weblogic"/>
        <login-command class="flex.messaging.security.WebSphereLoginCommand" server="WebSphere"/>
        -->
 
        <!-- 
        <security-constraint id="basic-read-access">
            <auth-method>Basic</auth-method>
            <roles>
                <role>guests</role>
                <role>accountants</role>
                <role>employees</role>
                <role>managers</role>
            </roles>
        </security-constraint>
         -->
    </security>
 
    <channels>
 
        <channel-definition id="my-amf" class="mx.messaging.channels.AMFChannel">
            <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amf" class="flex.messaging.endpoints.AMFEndpoint"/>
        </channel-definition>
 
        <channel-definition id="my-secure-amf" class="mx.messaging.channels.SecureAMFChannel">
            <endpoint url="https://{server.name}:{server.port}/{context.root}/messagebroker/amfsecure" class="flex.messaging.endpoints.SecureAMFEndpoint"/>
            <properties>
                <add-no-cache-headers>false</add-no-cache-headers>
            </properties>
        </channel-definition>
 
        <channel-definition id="my-polling-amf" class="mx.messaging.channels.AMFChannel">
            <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amfpolling" class="flex.messaging.endpoints.AMFEndpoint"/>
            <properties>
                <polling-enabled>true</polling-enabled>
                <polling-interval-seconds>4</polling-interval-seconds>
            </properties>
        </channel-definition>
 
        <channel-definition id="my-long-polling-amf" class="mx.messaging.channels.AMFChannel">
    		<endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amflongpolling" class="flex.messaging.endpoints.AMFEndpoint"/>
   			<properties>
        		<polling-enabled>true</polling-enabled>
        		<wait-interval-millis>-1</wait-interval-millis>
        		<polling-interval-millis>100</polling-interval-millis>
        		<max-waiting-poll-requests>50</max-waiting-poll-requests>
   		   </properties>
		</channel-definition>
 
 
        <!--
        <channel-definition id="my-http" class="mx.messaging.channels.HTTPChannel">
            <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/http" class="flex.messaging.endpoints.HTTPEndpoint"/>
        </channel-definition>
 
        <channel-definition id="my-secure-http" class="mx.messaging.channels.SecureHTTPChannel">
            <endpoint url="https://{server.name}:{server.port}/{context.root}/messagebroker/httpsecure" class="flex.messaging.endpoints.SecureHTTPEndpoint"/>
            <properties>
                <add-no-cache-headers>false</add-no-cache-headers>
            </properties>
        </channel-definition>
        -->
    </channels>
 
    <logging>
        <target class="flex.messaging.log.ConsoleTarget" level="Error">
            <properties>
                <prefix>[BlazeDS] </prefix>
                <includeDate>false</includeDate>
                <includeTime>false</includeTime>
                <includeLevel>false</includeLevel>
                <includeCategory>false</includeCategory>
            </properties>
            <filters>
                <pattern>Endpoint.*</pattern>
                <pattern>Service.*</pattern>
                <pattern>Configuration</pattern>
            </filters>
        </target>
    </logging>
 
    <system>
        <redeploy>
            <enabled>false</enabled>
            <!-- 
            <watch-interval>20</watch-interval>
            <watch-file>{context.root}/WEB-INF/flex/services-config.xml</watch-file>
            <watch-file>{context.root}/WEB-INF/flex/proxy-config.xml</watch-file>
            <watch-file>{context.root}/WEB-INF/flex/remoting-config.xml</watch-file>
            <watch-file>{context.root}/WEB-INF/flex/messaging-config.xml</watch-file>
            <watch-file>{context.root}/WEB-INF/flex/data-management-config.xml</watch-file>
            <touch-file>{context.root}/WEB-INF/web.xml</touch-file>
             -->
        </redeploy>
    </system>
 
</services-config>

et enfin mon mxml :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" creationComplete="init();">
 
 
 
<mx:Consumer id="consumer" destination="myChat"  fault="handlerFaults(event)" message="HandlerResponse(event.message)"/>
<mx:Producer id="producer" destination="myChat" fault="handlerFaults(event)" />
 
 
<mx:Script>
<![CDATA[
	import mx.messaging.ChannelSet;
	import mx.messaging.channels.AMFChannel;
	import mx.messaging.events.MessageAckEvent;
	import mx.messaging.events.MessageFaultEvent;
	import mx.controls.Alert;
	import mx.messaging.messages.AcknowledgeMessage;
	import mx.messaging.messages.AsyncMessage;
	import mx.messaging.messages.IMessage;
 
	private function init():void
	{
 
 
		var channSet:ChannelSet = new ChannelSet();
 
		var longpollChann:AMFChannel = new AMFChannel("myLongPoll", "http://localhost:8080/myChat/messagebroker/amflongpolling");
 
		channSet.addChannel(longpollChann);
 
		producer.channelSet = channSet;
		consumer.channelSet = channSet;
 
 
		consumer.subscribe();
 
 
	}
 
	private function send():void{
 
		var message:IMessage = new AsyncMessage();
		message.body.chatMessage = msg.text;
		producer.send(message);
		msg.text = "";
	}
 
	private function HandlerResponse(message:IMessage):void{
		chatMsgs.text += message.body.chatMessage + "\n";
	}
 
	private function HandlerAck(evnet:MessageAckEvent):void
	{		
		Alert.show(evnet.toString());
	}
 
	private function handlerFaults(event:MessageFaultEvent):void
	{
		Alert.show(event.toString());
	}
 
]]>
</mx:Script>
 
<mx:Panel title="My chat with BlazeDS" width="100%" height="100%">
	<mx:TextArea id="chatMsgs" width="100%" height="100%"/>
	<mx:ControlBar>
		<mx:TextInput id="msg" width="100%" enter="send()"/>
		<mx:Button label="Envoyer" click="send()"/>
	</mx:ControlBar>
</mx:Panel>
 
 
 
</mx:Application>