Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import io.vertx.core.Handler;
- import io.vertx.core.Vertx;
- import io.vertx.core.buffer.Buffer;
- import io.vertx.core.http.*;
- public class serverTest {
- public static void main(String[] args) throws Exception {
- HttpServer server = Vertx.vertx().createHttpServer();
- server.websocketHandler(new Handler<ServerWebSocket>() {
- @Override
- public void handle(ServerWebSocket webs) {
- System.out.println("Client connected");
- System.out.println("Client's message: ");
- webs.handler(new Handler<Buffer>() {
- @Override
- public void handle(Buffer event) {
- System.out.println("Received data " + event.toString("ISO-8859-1"));
- }
- });
- }
- });
- server.listen(8080, "localhost", res -> {
- if (res.succeeded()) {
- System.out.println("Server is now listening!");
- } else {
- System.out.println("Failed to bind!");
- }
- });
- }
- }
- @Override
- public void handle(Buffer event) {
- System.out.println("Received data " + event.toString("ISO-8859-1"));
- }
- httpServer.requestHandler(request -> {
- //Тело
- });
- public void handle(Buffer event) {
- System.out.println("Received data: " + event.toString("ISO-8859-1"));
- webs.writeFinalTextFrame("echo:"+event.toString("ISO-8859-1"));
Add Comment
Please, Sign In to add comment