如何在没有Flex客户端接收消息的情况下从BlazeDS推送数据？
我在我的Flex应用程序项目中使用BlazeDS进行数据推送function。 从官方教程BlazeDS入门 ，它显示了来自API的生产者/消费者的消息传递示例。
但是我如何实现不需要从Flex客户端调用的服务器端，而是从服务器端调用服务器端。 我有一些想法，但我不知道该怎么做，因为我是Flex开发人员，而不是Java开发人员，所以我认为你可以帮助我。
-
在Google中，有一个关于我需要在Java端扩展
ServiceAdapter类的教程，它扩展了Invoke方法。 我是否需要扩展其他类而不是这样做我想要的？ -
如何配置
message-config.xml以获得我上面描述的结果？
这是我编写的测试代码，有时用于测试向客户端发送数据。 它是ServiceAdapter实现的简单，简单的Java示例。 它从Web上的现有示例中删除了许多不必要的代码。 它编译，工作，我经常在测试中使用它。
package your.package.structure.adapter; import your.package.structure.device.DevicePort; import flex.messaging.messages.AsyncMessage; import flex.messaging.messages.Message; import flex.messaging.services.MessageService; import flex.messaging.services.ServiceAdapter; import flex.messaging.util.UUIDUtils; /** * Test service adapter. Great for testing when you want to JUST SEND AN OBJECT and nothing * else. This class has to stay in the main codebase (instead of test) because, when it's used * it needs to be deployed to Tomcat. * @author Kevin G * */ public class TestServiceAdapter extends ServiceAdapter { private volatile boolean running; private Message createTestMessage() { DevicePort objectToSend = new DevicePort("RouterDevice"); final AsyncMessage msg = new AsyncMessage(); msg.setDestination(getClass().getSimpleName() + "Destination"); msg.setClientId(UUIDUtils.createUUID()); msg.setMessageId(UUIDUtils.createUUID()); msg.setBody(objectToSend); return msg; } private void sendMessageToClients(Message msg) { ((MessageService) getDestination().getService()).pushMessageToClients(msg, false); } /** * @see flex.messaging.services.ServiceAdapter#start() */ @Override public void start(){ super.start(); Thread messageSender = new Thread(){ public void run(){ running = true; while(running){ sendMessageToClients(createTestMessage()); secondsToSleep(3); } } }; messageSender.start(); } /** * @see flex.messaging.services.ServiceAdapter#stop() */ @Override public void stop(){ super.stop(); running = false; } /** * This method is called when a producer sends a message to the destination. Currently, * we don't care when that happens. */ @Override public Object invoke(Message message) { if (message.getBody().equals("stop")) { running = false; } return null; } private void secondsToSleep(int seconds) { try{ Thread.sleep(seconds * 1000); }catch(InterruptedException e){ System.out.println("TestServiceAdapter Interrupted while sending messages"); e.printStackTrace(); } } }
您需要在tomcat中设置一些属性才能使其正常工作。
在messaging-config.xml ，您需要添加适配器和目标：
将此行添加到现有
将此目标添加到同一messaging-config.xml文件中：
最后，确保在services-config.xml定义了“my-streaming-amf”通道，如下所示：
0 10 5000
请注意，在blazeDS中，这两个配置文件（messaging-config.xml和services-config.xml）位于以下目录中：
/blazeds/tomcat/webapps/[nameOfYourApp]/WEB-INF/flex/
其中[nameOfYourApp]是您的webapp所在的目录。
我希望这一切都有帮助！
-公斤
您是否需要将消息从服务器推送到客户端？ 在这种情况下，请查看BlazeDS示例。 在名为traderdesktop的文件夹中有一个示例。 发送消息的代码段如下：
MessageBroker msgBroker = MessageBroker.getMessageBroker(null); AsyncMessage msg = new AsyncMessage(); msg.setDestination(yourdestination); msg.setClientId(clientID); msg.setMessageId(UUIDUtils.createUUID()); msg.setTimestamp(System.currentTimeMillis()); msg.setBody("dummy"); msgBroker.routeMessageToService(msg, null);
如果要在运行时将URL设置为流，请执行以下操作：
//assumes _consumer is an instance variable mx.messaging.Consumer var channelSet:ChannelSet = new ChannelSet(); //change {server.name}:{server.port} to the end point you wanna hit var ep:String = "http://{server.name}:{server.port}/messagebroker/streamingamf"; var channel:StreamingAMFChannel = new StreamingAMFChannel("my-streaming-amf", ep); channelSet.addChannel(channel); _consumer = new Consumer(); _consumer.channelSet = channelSet; _consumer.destination = "TestServiceAdapterDestination"; _consumer.subscribe(); _consumer.addEventListener(MessageEvent.MESSAGE, onMsg); _consumer.addEventListener(MessageFaultEvent.FAULT, faultHandler);
只是一个抬头。 这需要一些头脑才能开始。 我希望它对某人有帮助。