通过 BlazeDS 从 Java 到 Flex 的自定义编组

Question

我的团队正在使用 BlazeDS 将概念验证 Flex 应用程序放在基于 Spring 的服务器之上。

我们进行了大量的日期计算，因此我们在整个代码和域模型中广泛使用 Joda Time。

我们现在正在尝试弄清楚如何继续在 DTO 中使用 Joda Time，这些 DTO 通过 BlazeDS 与 Flex 前端来回发送。

我们的目标是在 Flex 端使用 Actionscript 3 数据类型 Date 并将其映射到我们对 Joda 时间的 DateTime、LocalDate 和Java 端的 LocalTime 类型。

我们可以解决在使用插入 BlazeDS 的自定义类型编组器调用 Java 时转换 Actionscript 3 的 Date 类型的问题，但这似乎仅针对 Flex->Java/BlazeDS 方向调用，而不是针对 Flex->Java/BlazeDS 方向调用。 Java/BlazeDS->Flex 方向。

我现在正在研究 BlazeDS 的自定义 PropertyProxy 实现，但这看起来也不是正确的事情。

另一个想法是在我们的 Java DTO 上实现外部化，但这似乎工作量太大，尤其是当我查看 BlazeDS 的竞争对手 GraniteDS 时，它在其文档中显示了通过简单的操作插入 Joda Time 支持。类型转换器！

任何想法表示赞赏。

Answer 1

好的 - 我自己找到了答案。这涉及编写我自己的 AMF 端点类 + 相关的序列化类。我不得不说 http://flexblog.faratasystems.com 的人们是破解 BlazeDS 的灵感的重要来源。

该代码确实应该合并到 BlazeDS 本身或某些开源扩展项目中 - 它非常基础。

通道定义

    <channel-definition id="my-amf" class="mx.messaging.channels.AMFChannel">
        <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amf" class="ch.hedgesphere.core.blazeds.endpoint.AMFEndpoint"/>

         <properties>
            <serialization>
                <type-marshaller>ch.hedgesphere.core.blazeds.translator.HedgesphereASTranslator</type-marshaller>
            </serialization>
        </properties>

    </channel-definition>

自定义 AMF 端点

package ch.hedgesphere.core.blazeds.endpoint;

import ch.hedgesphere.core.blazeds.serialization.Serializer;

    public class AMFEndpoint extends flex.messaging.endpoints.AMFEndpoint {

    @Override
    protected String getSerializerClassName() {
        return Serializer.class.getName();
        }

    }

自定义序列化器

package ch.hedgesphere.core.blazeds.serialization;

import java.io.OutputStream;

import flex.messaging.io.MessageIOConstants;
import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.AmfMessageSerializer;
import flex.messaging.io.amf.AmfTrace;

public class Serializer extends AmfMessageSerializer {

    @Override
    public void initialize(SerializationContext context, OutputStream out, AmfTrace trace)
    {
        amfOut = new AMF0Output(context);
        amfOut.setOutputStream(out);
        amfOut.setAvmPlus(version >= MessageIOConstants.AMF3);

        debugTrace = trace;
        isDebug = trace != null;
        amfOut.setDebugTrace(debugTrace);
    }
}

自定义 AMF 0 处理

package ch.hedgesphere.core.blazeds.serialization;

import flex.messaging.io.SerializationContext;

public class AMF0Output extends flex.messaging.io.amf.Amf0Output {

public AMF0Output(SerializationContext context) {
    super(context);
}

@Override
    protected void createAMF3Output()
    {
        avmPlusOutput = new AMF3Output(context);
        avmPlusOutput.setOutputStream(out);
        avmPlusOutput.setDebugTrace(trace);
    }
}

自定义 AMF 3 处理

package ch.hedgesphere.core.blazeds.serialization;

import java.io.IOException;

import org.joda.time.DateTime;
import org.joda.time.LocalDate;
import org.joda.time.LocalTime;

import flex.messaging.io.SerializationContext;

public class AMF3Output extends flex.messaging.io.amf.Amf3Output {

public AMF3Output(SerializationContext context) {
    super(context);
}

@Override
public void writeObject(Object value) throws IOException {
    if(value instanceof DateTime) {
        value = convertToDate((DateTime)value);
    }
    if(value instanceof LocalDate) {
        value = convertToDate((LocalDate)value);
    }
    if(value instanceof LocalTime) {
    value = convertToDate((LocalTime)value);
    }
    super.writeObject(value);
}

private Object convertToDate(LocalTime time) {
    return time.toDateTimeToday().toDate();
}

private Object convertToDate(LocalDate date) {
    return date.toDateMidnight().toDate();
}

private Object convertToDate(DateTime dateTime) {
    return dateTime.toDate();
}   
}

用于 Flex->Java 调用的自定义编组器

package ch.hedgesphere.core.blazeds.translator;

import org.joda.time.DateTime;
import org.joda.time.LocalDate;
import org.joda.time.LocalTime;

import flex.messaging.io.amf.translator.ASTranslator;


public class HedgesphereASTranslator extends ASTranslator {

@SuppressWarnings({"rawtypes"})
@Override
public Object convert(Object originalValue, Class type) {
    if( type.equals(DateTime.class)) {
        return convertToDateTime(originalValue);
    }
    if( type.equals(LocalDate.class)) {
    return convertToLocalDate(originalValue); 
    }
    if( type.equals(LocalTime.class)) {
        return convertToLocalTime(originalValue);
    }

    return super.convert(originalValue, type);
}

private Object convertToLocalTime(Object originalValue) {
    return originalValue == null ? null : new LocalTime(originalValue);
}

private Object convertToLocalDate(Object originalValue) {
    return originalValue == null ? null : new LocalDate(originalValue); 
}

private Object convertToDateTime(Object originalValue) {
    return originalValue == null ? null : new DateTime(originalValue);
}

@SuppressWarnings({"rawtypes"})
@Override
public Object createInstance(Object source, Class type) {
    return super.createInstance(source, type);
}
}

Answer 2

对于使用 SpringSource 中的 Spring-BlazeDS 集成项目的 Java 应用程序，有一种更简单的处理方法：

• 编写 GenericConverter 的实现，用于处理 ReadableDateTime 与 java.util.Date 之间的映射。

• 创建 AbstractAmfConversionServiceConfigProcessor 的子类并重写 configureConverters，将转换器实现添加到注册表。

• 通过创建 ConfigProcessor 实例并连接它来更新 Spring 配置：

XML：

<flex:message-broker>
    <flex:config-processor ref="customConfigProcessor"/>
</flex:message-broker>

更多信息请参见：

http://static.springsource.org/ spring-flex/docs/1.5.x/reference/html/index.html#amf-custom-converters

Answer 3

您是否尝试过此博客中概述的自定义编组器方法：

http:// /flexblog.faratasystems.com/index.php/custom-type-masrhaller-in-blazeds