3

我想将二进制数据从我的 stompClient 发送到 spring 控制器。这是我的 JS

var socket = new SockJS('/test/binary');
        var stompClient = Stomp.over(socket);

        socket.binaryType = "arraybuffer";
        var appModel = new ApplicationModel(stompClient);
        ko.applyBindings(appModel);

        appModel.connect();
        appModel.pushNotification("Notifications.");


 var ctx =   canvas.get()[0].getContext('2d');
 ctx.drawImage(img, 0, 0, 320, 240);
 var data  = canvas.get()[0].toDataURL('image/jpeg', 1.0);
 newblob = dataURItoBlob(data);


 stompClient.send("/app/vid", {},  newblob);

function dataURItoBlob(dataURI) {
    // convert base64/URLEncoded data component to raw binary data held in a string
    var byteString;
    if (dataURI.split(',')[0].indexOf('base64') >= 0)
        byteString = atob(dataURI.split(',')[1]);
        else
        byteString = unescape(dataURI.split(',')[1]);

    // separate out the mime component
    var mimeString = dataURI.split(',')[0].split(':')[1].split(';')[0];

    // write the bytes of the string to a typed array
    var ia = new Uint8Array(byteString.length);
    for (var i = 0; i < byteString.length; i++) {
        ia[i] = byteString.charCodeAt(i);
    }

   return new Blob([ia], {type:mimeString});

我尝试发送 Blob、Uint8Array 消息已发送，但在服务器端我无法使用它。我在控制器中的方法是：

@MessageMapping("/vid")
public void getVid(Message<byte[]> message, Principal principal) throws IOException {
ByteArrayOutputStream bOut = new ByteArrayOutputStream();
bOut.write(message.getPayload());
bOut.flush();
byte[]  imageInByte = bOut.toByteArray();
bOut.close();

InputStream in = new ByteArrayInputStream(imageInByte);
BufferedImage bImageFromConvert = ImageIO.read(in);

ImageIO.write(bImageFromConvert, "jpeg", new File(
        "E:/new-darksouls.jpg"));

template.convertAndSend("/topic/binarydemo2",   message);

我使用了 ByteArrayMessageConverter、StringMessageConverter、MappingJackson2MessageConverter 和我写的 Base64JavaObjectMessageConverter：

public class Base64JavaObjectMessageConverter extends AbstractMessageConverter {

public Base64JavaObjectMessageConverter() {
    super(MimeTypeUtils.APPLICATION_OCTET_STREAM);
}

@Override
protected boolean supports(Class<?> clazz) {
    return true;
}


@Override
public Object convertFromInternal(Message<?> message, Class<?> targetClass) {
    byte[] messageBytes =Base64Utils.decode( (byte[])message.getPayload() );
    return SerializationUtils.deserialize( messageBytes  );
}

@Override
public Object convertToInternal(Object payload, MessageHeaders headers) {
    byte[] messageBytes = SerializationUtils.serialize( payload );
    return Base64Utils.encode( messageBytes);
}

}

我只能将 byte[] 作为字符串发送，从中删除 'base64' 等：

stompClient.send("/app/vid", {},   data.split(',')[1]);

在控制器中：

@MessageMapping("/vid")
public void getVid(String message, Principal principal) throws IOException {


    byte[] bytearray = Base64.decode(message);
    BufferedImage imag=ImageIO.read(new ByteArrayInputStream(bytearray));

    ImageIO.write(imag, "jpg", new File("E:/new-darksouls.jpg"));

但这不是我想要达到的。我想这将需要很高的性能。

我正在使用 Spring 4.2.0.RC1 WebSockets,StompJS 我在不同的帖子上读到可以从后端发送到客户端和客户端到后端，但我无法重现它。如果我能得到一个具体的例子，如何在客户端构造和发送 Uint8Array 或 blob 以及如何在服务器端处理它，我将非常感激。

感谢您的时间和帮助

4

1 回答 1

0

SockJS 不支持发送二进制数据。您可以使用 STOMP 在普通 WebSocket 上发送二进制消息。

在服务器端，请参阅 StompSubProtocolHandler，它检查传入消息是二进制还是文本，因此可以处理任何一个。从那里它并不重要，即从STOMP的角度来看，主体是一个字节数组，内容类型/内容长度标头确定主体包含什么以及应该如何解释它。在发送端，StompSubProtocolHandler 也可以发送二进制或文本，如果内容类型是 application/octet-stream 并且只要不使用 SockJS，它就使用二进制。

所以简而言之，通过 WebSocket 它应该可以工作，但在使用 SockJS 作为传输时不能。

于 2015-06-17T16:29:10.013 回答