代码都是官方的,因为我在本地测试,所以得设置channelSet
producer可以通过设置AsyncMessage的header 设置消息头
cousumer可以通过设置selector来过滤消息(消息头中指定的消息),selector不写,说明不过滤,可以收到
写了,会跟消息头中的字段匹配,好像字符串不行如
message.headers["prop1"] = 10; //指定消息头 10不能是字符串
selector="prop1 = 10" //可以用比较运算符 如:selector="prop1 >5"
如果不想接收某个信息,把selector设置为不匹配的如:selector="prop1 > 10"这样就接收不到消息。
这样就可以通过 过滤消息来 分组发 ,p2p ,发给所有人。(可能这样更复杂了,希望高人提出更简单的办法)
producer_filter.mxml
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="init()">
<mx:Script>
<![CDATA[
import mx.messaging.channels.AMFChannel;
import mx.messaging.*;
import mx.messaging.messages.*;
import mx.messaging.events.*;
private function sendMessage():void {
init();
var message:AsyncMessage = new AsyncMessage();
message.headers = new Array();
message.headers["prop1"] = 10; //指定消息头
message.body = input.text;
producer.send(message);
}
//设置channelSet
private function init(){
var url="http://localhost:8400/BlazedsMessage/"; //随便的以个blazeds应用
// var myStreamingAMF:StreamingAMFChannel = new StreamingAMFChannel(url+"my-streaming-amf", url+"messagebroker/streamingamf");
var myPollingAMF:AMFChannel = new AMFChannel(url+"my-polling-amf", url+"messagebroker/amfpolling");
myPollingAMF.pollingEnabled = true;//轮询
myPollingAMF.pollingInterval = 1000;//隔多长时间询问一次 1miao
var channelSet:ChannelSet = new ChannelSet();
// channelSet.addChannel(myStreamingAMF);
channelSet.addChannel(myPollingAMF);
producer.channelSet = channelSet;
}
]]>
</mx:Script>
<mx:Producer id="producer"
destination="mychat">
</mx:Producer>
<mx:TextInput id="userName"/>
<mx:TextInput id="input"/>
<mx:Button label="Send"
click="sendMessage();"/>
</mx:Application>
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="init()">
<mx:Script>
<![CDATA[
import mx.messaging.channels.AMFChannel;
import mx.messaging.*;
import mx.messaging.messages.*;
import mx.messaging.events.*;
private function sendMessage():void {
init();var message:AsyncMessage = new AsyncMessage();
message.headers = new Array();
message.headers["prop1"] = 10; //指定消息头message.body = input.text;producer.send(message);}
//设置channelSetprivate
function init(){var url="http://localhost:8400/BlazedsMessage/";
//随便的以个blazeds应用
var myStreamingAMF:StreamingAMFChannel = new StreamingAMFChannel(url+"my-streaming-amf", url+"messagebroker/streamingamf");
var myPollingAMF:AMFChannel = new AMFChannel(url+"my-polling-amf", url+"messagebroker/amfpolling");
myPollingAMF.pollingEnabled = true;//轮询
myPollingAMF.pollingInterval = 1000;//隔多长时间询问一次 1miaovar
channelSet:ChannelSet = new ChannelSet();
channelSet.addChannel(myStreamingAMF);
channelSet.addChannel(myPollingAMF);
producer.channelSet = channelSet;}
]]>
</mx:Script>
<mx:Producer id="producer"destination="mychat">
</mx:Producer> <mx:TextInput id="userName"/>
<mx:TextInput id="input"/>
<mx:Button label="Send"click="sendMessage();"/>
</mx:Application>
Flex_consumer代码
<?xml version="1.0" encoding="utf-8"?>
<!-- ds\messaging\CreateConsumerMXML.mxml -->
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"
creationComplete="logon();">
<mx:Script>
<![CDATA[
import mx.messaging.channels.AMFChannel;
import mx.messaging.*;
import mx.messaging.messages.*;
import mx.messaging.events.*;
// Subscribe to destination.
private function logon():void {
init();
consumer.subscribe();//订阅
}
// Write received message to TextArea control.
//收到信息
private function messageHandler(event:MessageEvent):void {
// Handle message event.
ta.text += event.message.body + "\n";
}
private function init(){
var url="http://localhost:8400/BlazedsMessage/";
// var myStreamingAMF:StreamingAMFChannel = new StreamingAMFChannel(url+"my-streaming-amf", url+"messagebroker/streamingamf");
var myPollingAMF:AMFChannel = new AMFChannel(url+"my-polling-amf", url+"messagebroker/amfpolling");
myPollingAMF.pollingEnabled = true;
myPollingAMF.pollingInterval = 1000;
var channelSet:ChannelSet = new ChannelSet();
// channelSet.addChannel(myStreamingAMF);
channelSet.addChannel(myPollingAMF);
consumer.channelSet = channelSet;
}
]]>
</mx:Script>
<mx:Consumer id="consumer"
destination="mychat"
selector="prop1 = 10"
message="messageHandler(event);">
<!--上边的selector可以改成 selector="prop1 > 9" 也能受到信息,说明可以用比较 官方文档也很少。郁闷-->
</mx:Consumer>
<mx:TextArea id="ta" width="100%" height="100%"/>
</mx:Application>
<?xml version="1.0" encoding="utf-8"?>
<!-- ds\messaging\CreateConsumerMXML.mxml --><mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"creationComplete="logon();">
<mx:Script>
<![CDATA[
import mx.messaging.channels.AMFChannel;
import mx.messaging.*;
import mx.messaging.messages.*;
import mx.messaging.events.*;// Subscribe to destination.
private function logon():void {init();consumer.subscribe();//订阅
}
// Write received message to TextArea control.
//收到信息
private function messageHandler(event:MessageEvent):void {
// Handle message
event.ta.text += event.message.body + "\n";
}
private function init(){var url="http://localhost:8400/BlazedsMessage/";//var myStreamingAMF:StreamingAMFChannel = new StreamingAMFChannel(url+"my-streaming-amf", url+"messagebroker/streamingamf");
var myPollingAMF:AMFChannel = new AMFChannel(url+"my-polling-amf", url+"messagebroker/amfpolling");
myPollingAMF.pollingEnabled = true;
myPollingAMF.pollingInterval = 1000;
var channelSet:ChannelSet = new ChannelSet();
//channelSet.addChannel(myStreamingAMF);
channelSet.addChannel(myPollingAMF);
consumer.channelSet = channelSet;}
]]>
</mx:Script>
<mx:Consumer id="consumer"destination="mychat"selector="prop1 = 10" message="messageHandler(event);">
<!--上边的selector可以改成 selector="prop1 > 9" 也能受到信息,说明可以用比较 官方文档也很少。郁闷-->
</mx:Consumer><mx:TextArea id="ta" width="100%" height="100%"/>
</mx:Application>
服务器端 message-config.xml
<?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-polling-amf"/>
</default-channels>
<destination id="mychat">
</destination>
</service>
<?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-polling-amf"/>
</default-channels><destination id="mychat">
</destination></service>
分享到:
相关推荐
基于Java_BlazeDS_Flex_服务器消息推的聊天室 了解BlazeDS推送机制,flex调用java web BlazeDS的过程 服务器推,摒弃ajax的轮询,减轻服务器压力!
FLEX——blazeDS原理.pdfFLEX——blazeDS原理.pdf
BlazeDS通信到Java的PureMVC——Flex框架,BlazeDS的服务器配置比较麻烦,这里使用的是直接下载blazeds_turnkey_3-0-0-544.zip中的tomcat BlazeDS模板路径为: blazeds_turnkey_3-0-0-544.zip解压后路径\tomcat\...
BlazeDS是一个基于服务器的Java远程调用(remoting)和Web消息传递(messaging)技术,使得后台的Java应用程序和运行在浏览器上的Flex应用程序能够相互通信。
elipse下配置的spring+flex+blazeds,进行消息推送,还加入了了quarz定时策略。希望对大家有帮助。
Flex技术本身和Java就有很强的关联性,它提供了一个基于Eclipse的IDE和BlazeDS.BlazeDS是个基于服务端的Java远程调用和Web消息的一个开源的技术。有许多应用都是以Java为后端处理的。Flex用于前端。由于Java和Flex...
Flex 应用,BlazeDS通信,Flex 应用,BlazeDS通信
关于blazeds应用的一个例子,也是从其他的地方下载的,希望大家能用得上
BlazeDs开发应用.pdf
blazeds.war blazeds
Flex+blazeds+java发布/订阅信息模式实现的聊天程序(需要blazeds.war及flex-message相关jar包)
一个blazeds的eclipse工程的消息推送的例子,导入就可以运行例子
基于Flex与BlazeDS在企业开发中的应用
flex+blazeds+java后台消息推送(简单示例)[借鉴].pdf
Flex+blazeds+java发布/订阅信息模式实现的聊天程序(包含flex工程和java工程)
包含blazeds.war blazeds-spring.war 以及解压后的blazeds,blazeds-spring文件夹, 可直接拷贝到javaee项目下的WebRoot文件夹下
压缩包内包含java后端、flex前端代码,配置文档,jar包
Blazeds入门教程.doc