Web服务处理协议

Question

我正试图使Web服务与protobuf和json一起工作。问题在于，为了构建我的proto，我需要能够读取inputStream（至少我没有看到其他方法）。

我为protobuf创建了一个转换器：

public class ProtobufMessageConverter extends AbstractHttpMessageConverter<MyProto>{

    @Override
    protected boolean supports(Class<?> aClass) {
        return MyProto.class.equals(aClass);
    }

    @Override
    protected MyProto readInternal(Class<? extends MyProto> aClass, HttpInputMessage httpInputMessage)
            throws IOException, HttpMessageNotReadableException {
        return MyProto.parseFrom(httpInputMessage.getBody());
    }

    @Override
    protected void writeInternal(MyProto proto, HttpOutputMessage httpOutputMessage)
            throws IOException, HttpMessageNotWritableException {
        OutputStream wr = httpOutputMessage.getBody();
        wr.write(proto.toByteArray());
        wr.close();
    }
}

在我的Spring配置中使用：

@Configuration
@EnableWebMvc
@ComponentScan(basePackages = "com.test")
public class SpringMvcConfiguration extends WebMvcConfigurationSupport {

    @Override
    public void configureMessageConverters(List<HttpMessageConverter<?>> httpMessageConverters) {
        httpMessageConverters.add(new ProtobufMessageConverter(new MediaType("application","octet-stream")));

        addDefaultHttpMessageConverters(httpMessageConverters);
    }
}

我的控制器：

@RequestMapping(value = "/proto", method = {POST}, consumes = {MediaType.APPLICATION_OCTET_STREAM_VALUE})
@ResponseBody
public MyProto openProto(@RequestHeader(value = "Host") String host, @RequestBody
   MyProto strBody, HttpServletRequest httpRequest
) throws InterruptedException {
    return null;
}

问题是，如果我让控制器这样做，我会得到一个错误，因为我的webservice不支持application/octet流。

[main]信息组织。日食码头。服务器ServerConnector-已启动ServerConnector@73b05494{HTTP/1.1}{0.0.0.0:8180}org。springframework。网状物HttpMediaTypeNotSupportedException:组织不支持内容类型“应用程序/八位字节流”。springframework。网状物servlet。mvc。方法注释。AbstractMessageConverterMethodArgumentResolver。readWithMessageConverters（AbstractMessageConverterMethodArgumentResolver.java:155）。。。

如果我把String放在@askestBody中，那么我就进入了我的方法，但它似乎没有使用转换器，并且字符串不能通过parsefrom函数转换到MyProto中。

你知道吗？

Answer 1

事实上，我找到了答案。我们需要将原始BUFF视为字节[]。此类型已经有一个HttpMessageConverter。因此，ResponseBody应该是

public byte[] openProto(@RequestHeader(value = "Host") String host, @RequestBody
   byte[] strBody, HttpServletRequest httpRequest
) throws InterruptedException {
    return null;
}