FilesExpand file tree

 master

/

FragmentedFramesExample.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

81 lines (73 loc) · 3.47 KB

 master

/

FragmentedFramesExample.java

Copy path

Top

File metadata and controls

• Code
• Blame

81 lines (73 loc) · 3.47 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

/*

* Copyright (c) 2010-2018 Nathan Rajlich

*

* Permission is hereby granted, free of charge, to any person

* obtaining a copy of this software and associated documentation

* files (the "Software"), to deal in the Software without

* restriction, including without limitation the rights to use,

* copy, modify, merge, publish, distribute, sublicense, and/or sell

* copies of the Software, and to permit persons to whom the

* Software is furnished to do so, subject to the following

* conditions:

*

* The above copyright notice and this permission notice shall be

* included in all copies or substantial portions of the Software.

*

* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES

* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT

* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,

* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING

* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR

* OTHER DEALINGS IN THE SOFTWARE.

*/

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.URI;

import java.net.URISyntaxException;

import java.nio.ByteBuffer;

import org.java_websocket.WebSocket;

import org.java_websocket.client.WebSocketClient;

import org.java_websocket.enums.Opcode;

/**

* This example shows how to send fragmented frames.<br>

* For information on when to used fragmented frames see http://tools.ietf.org/html/rfc6455#section-5.4<br>

* Fragmented and normal messages can not be mixed.

* One is however allowed to mix them with control messages like ping/pong.

*

* @see WebSocket#sendFragmentedFrame(Opcode, ByteBuffer, boolean)

**/

public class FragmentedFramesExample {

public static void main( String[] args ) throws URISyntaxException , IOException , InterruptedException {

// WebSocketImpl.DEBUG = true; // will give extra output

WebSocketClient websocket = new ExampleClient( new URI( "ws://localhost:8887" ));

if( !websocket.connectBlocking() ) {

System.err.println( "Could not connect to the server." );

return;

}

System.out.println( "This example shows how to send fragmented(continuous) messages." );

BufferedReader stdin = new BufferedReader( new InputStreamReader( System.in ) );

while ( websocket.isOpen() ) {

System.out.println( "Please type in a loooooong line(which then will be send in 2 byte fragments):" );

String longline = stdin.readLine();

ByteBuffer longelinebuffer = ByteBuffer.wrap( longline.getBytes() );

longelinebuffer.rewind();

for( int position = 2 ; ; position += 2 ) {

if( position < longelinebuffer.capacity() ) {

longelinebuffer.limit( position );

websocket.sendFragmentedFrame( Opcode.TEXT, longelinebuffer, false );// when sending binary data one should use Opcode.BINARY

assert ( longelinebuffer.remaining() == 0 );

// after calling sendFragmentedFrame one may reuse the buffer given to the method immediately

} else {

longelinebuffer.limit( longelinebuffer.capacity() );

websocket.sendFragmentedFrame( Opcode.TEXT, longelinebuffer, true );// sending the last frame

break;

}

}

System.out.println( "You can not type in the next long message or press Ctr-C to exit." );

}

System.out.println( "FragmentedFramesExample terminated" );

}

}