Last active
December 7, 2019 17:25
-
-
Save TheBrokenRail/7f5c1df6bfca0662253713e4fc27565b to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.net.URI; | |
import java.net.URISyntaxException; | |
import java.nio.ByteBuffer; | |
import org.java_websocket.client.WebSocketClient; | |
import org.java_websocket.drafts.Draft; | |
import org.java_websocket.drafts.Draft_6455; | |
import org.java_websocket.handshake.ServerHandshake; | |
public class Client extends WebSocketClient { | |
public Client(URI serverUri, Draft draft) { | |
super(serverUri, draft); | |
} | |
public Client(URI serverURI) { | |
super(serverURI); | |
} | |
@Override | |
public void onOpen(ServerHandshake handshakedata) { | |
send("Hello, World!"); | |
System.out.println("new connection opened"); | |
} | |
@Override | |
public void onClose(int code, String reason, boolean remote) { | |
System.out.println("closed with exit code " + code + " additional info: " + reason); | |
} | |
@Override | |
public void onMessage(String message) { | |
System.out.println("received message: " + message); | |
} | |
@Override | |
public void onMessage(ByteBuffer message) { | |
System.out.println("received ByteBuffer"); | |
} | |
@Override | |
public void onError(Exception ex) { | |
System.err.println("an error occurred:" + ex); | |
} | |
public static void main(String[] args) throws URISyntaxException { | |
WebSocketClient client = new Client(new URI("ws://localhost:8887")); | |
client.connect(); | |
} | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.net.InetSocketAddress; | |
import java.nio.ByteBuffer; | |
import org.java_websocket.WebSocket; | |
import org.java_websocket.handshake.ClientHandshake; | |
import org.java_websocket.server.WebSocketServer; | |
public class Server extends WebSocketServer { | |
public Server(InetSocketAddress address) { | |
super(address); | |
} | |
@Override | |
public void onOpen(WebSocket conn, ClientHandshake handshake) { | |
conn.send("Welcome to the server!"); | |
conn.close(); | |
System.out.println("new connection to " + conn.getRemoteSocketAddress()); | |
} | |
@Override | |
public void onClose(WebSocket conn, int code, String reason, boolean remote) { | |
System.out.println("closed " + conn.getRemoteSocketAddress() + " with exit code " + code + " additional info: " + reason); | |
} | |
@Override | |
public void onMessage(WebSocket conn, String message) { | |
System.out.println("received message from " + conn.getRemoteSocketAddress() + ": " + message); | |
} | |
@Override | |
public void onMessage(WebSocket conn, ByteBuffer message) { | |
System.out.println("received ByteBuffer from " + conn.getRemoteSocketAddress()); | |
} | |
@Override | |
public void onError(WebSocket conn, Exception ex) { | |
System.err.println("an error occurred on connection " + conn.getRemoteSocketAddress() + ":" + ex); | |
} | |
@Override | |
public void onStart() { | |
System.out.println("server started successfully"); | |
} | |
public static void main(String[] args) { | |
String host = "localhost"; | |
int port = 8887; | |
WebSocketServer server = new Server(new InetSocketAddress(host, port)); | |
server.run(); | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment