길이가 128 자 이상인 Java Websocket Text Frame 오류?

Question

나는 바퀴를 재발 명하고 내 자신의 websocket 서버를 만들려고 노력하고있다. 구글 크롬과 파이어 폭스 모두에서 잘 연결되어 있으며 최대 127 글자의 텍스트 프레임을 정확하게 수신하고 에코합니다. 그러나, 구글은 나에게 다음과 같은 오류 제공을 넘어 님의

웹 소켓 연결 'WS를 : // localhost를 : 9999 /'실패 바이트의 최소 숫자는 길이를 인코딩하는 데 사용되어야한다

파이어 폭스 받게됩니다/처음 몇 문자를 해석 한 다음 실패한 코드 : 1006.

서버가 메시지를 완전히 수신 중이고 런타임 오류없이 전체를 브로드 캐스트하려고 시도하는 것으로 나타납니다. 그것은 또한 내 System.out.println()에 표시된 것처럼 16 비트 길이 생성자로 이동합니다. 서버에서 내 자바 콘솔을 읽

웹 소켓 서버는 클라이언트가 메시지가 수신 연결을 시작 1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij12345678 방송 : 1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij1234567890abcdefghij12345678 2 데이터

나는 현재 내가 함께 보내고있다 프레임을 테스트하기 위해 프레임 테스터를 쓰고 있어요 지역 사회가 저에게 다리 작업의 일부를 구할 수 있기를 희망했습니다. 정말 이상한 점은 길이가 2 바이트 인 126과 127 페이로드 길이가 작동하고 반영한다는 것입니다.

public void broadcast(String mess) throws IOException { 
     System.out.println("broadcasting: "+mess); 
     byte[] rawData = mess.getBytes(); 

     int frameCount = 0; 
     byte[] frame = new byte[10]; 

     frame[0] = (byte) 129; 

     if (rawData.length <= 125) { 
      frame[1] = (byte) rawData.length; 
      frameCount = 2; 
     } else if (rawData.length >= 126 && rawData.length <= 65535) { 
      System.out.println("2nd data"); 
      frame[1] = (byte) 126; 
      byte len = (byte) rawData.length; 
      frame[2] = (byte) ((len >> 8) & (byte) 255); 
      frame[3] = (byte) (len & (byte) 255);     
      frameCount = 4; 
     } else { 
      System.out.println("3rd data"); 
      frame[1] = (byte) 127; 
      byte len = (byte) rawData.length; 
      frame[2] = (byte) ((len >> 56) & (byte) 255); 
      frame[3] = (byte) ((len >> 48) & (byte) 255); 
      frame[4] = (byte) ((len >> 40) & (byte) 255); 
      frame[5] = (byte) ((len >> 32) & (byte) 255); 
      frame[6] = (byte) ((len >> 24) & (byte) 255); 
      frame[7] = (byte) ((len >> 16) & (byte) 255); 
      frame[8] = (byte) ((len >> 8) & (byte) 255); 
      frame[9] = (byte) (len & (byte) 255); 
      frameCount = 10; 
     } 

     int bLength = frameCount + rawData.length; 

     byte[] reply = new byte[bLength]; 

     int bLim = 0; 
     for (int i = 0; i < frameCount; i++) { 
      reply[bLim] = frame[i]; 
      bLim++; 
     } 
     for (int i = 0; i < rawData.length; i++) { 
      reply[bLim] = rawData[i]; 
      bLim++; 
     } 
     for (OutputStream writer : writers) { 
      writer.write(reply); 
      writer.flush(); 
     }    

    } 

도움을 주신 커뮤니티.

Answer 1

몇 노트. 당신은 잘못

당신은 제대로 바이트로 문자열을 변환하지 않는 길이를 처리하는

1. 는

다음은 간단한 예제 (UTF-8을 통해 수행해야합니다).

아래 코드에 따라 사용이 허가됩니다 :

package websocket; 

import java.nio.ByteBuffer; 
import java.nio.charset.Charset; 

public class RawGenerate 
{ 
    /** 
    * The overhead (maximum) for a framing header. Assuming a maximum sized payload with masking key. 
    */ 
    public static final int OVERHEAD = 28; 

    public ByteBuffer asClientInitiatedTextFrame(String msg) 
    { 
     ByteBuffer buf = ByteBuffer.allocate(msg.length() + OVERHEAD); 
     putOpFin(buf,(byte)0x01,true); 
     byte mask[] = new byte[] { 1, 2, 3, 4 }; // Needs to be random 
     byte payload[] = msg.getBytes(Charset.forName("UTF-8")); // must be UTF-8 (per spec) 
     putLengthAndMask(buf,payload.length,mask); 
     for (int i = 0; i < payload.length; i++) 
     { 
      buf.put((byte)(payload[i] ^= mask[i % 4])); 
     } 
     buf.flip(); 
     return buf; 
    } 

    public static void putOpFin(ByteBuffer buf, byte opcode, boolean fin) 
    { 
     byte b = 0x00; 
     if (fin) 
     { 
      b |= 0x80; 
     } 
     b |= opcode & 0x0F; 
     buf.put(b); 
    } 

    public static void putLengthAndMask(ByteBuffer buf, int length, byte mask[]) 
    { 
     if (mask != null) 
     { 
      assert (mask.length == 4); 
      putLength(buf,length,(mask != null)); 
      buf.put(mask); 
     } 
     else 
     { 
      putLength(buf,length,false); 
     } 
    } 

    public static void putLength(ByteBuffer buf, int length, boolean masked) 
    { 
     if (length < 0) 
     { 
      throw new IllegalArgumentException("Length cannot be negative"); 
     } 
     byte b = (masked?(byte)0x80:0x00); 

     if (length > 0xFF_FF) 
     { 
      buf.put((byte)(b | 0x7F)); 
      buf.put((byte)0x00); 
      buf.put((byte)0x00); 
      buf.put((byte)0x00); 
      buf.put((byte)0x00); 
      buf.put((byte)((length >> 24) & 0xFF)); 
      buf.put((byte)((length >> 16) & 0xFF)); 
      buf.put((byte)((length >> 8) & 0xFF)); 
      buf.put((byte)(length & 0xFF)); 
     } 
     else if (length >= 0x7E) 
     { 
      buf.put((byte)(b | 0x7E)); 
      buf.put((byte)(length >> 8)); 
      buf.put((byte)(length & 0xFF)); 
     } 
     else 
     { 
      buf.put((byte)(b | length)); 
     } 
    } 
}