Vert.x 웹서버 구성

1. Vert.x Examples 주소
-> https://github.com/vert-x3/vertx-examples

2. Intllij로 open 한다.

3. chat 프로젝트
#server.java

package io.vertx.example.web.chat;
 
import io.vertx.core.AbstractVerticle;
import io.vertx.core.eventbus.EventBus;
import io.vertx.example.util.Runner;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.handler.StaticHandler;
import io.vertx.ext.web.handler.sockjs.BridgeOptions;
import io.vertx.ext.web.handler.sockjs.PermittedOptions;
import io.vertx.ext.web.handler.sockjs.SockJSHandler;
 
import java.sql.*;
import java.text.DateFormat;
import java.time.Instant;
import java.util.Date;
 
/**
 * A {@link io.vertx.core.Verticle} which implements a simple, realtime,
 * multiuser chat. Anyone can connect to the chat application on port
 * 8000 and type messages. The messages will be rebroadcast to all
 * connected users via the @{link EventBus} Websocket bridge.
 *
 * @author <a href="https://github.com/InfoSec812">Deven Phillips</a>
 */
public class Server extends AbstractVerticle {
 
  // Convenience method so you can run it in your IDE
  public static void main(String[] args) {
    Runner.runExample(Server.class);
  }
 
  @Override
  public void start() throws Exception {
 
    Router router = Router.router(vertx);
    String aaa = getDB();
    // Allow events for the designated addresses in/out of the event bus bridge
    BridgeOptions opts = new BridgeOptions()
      .addInboundPermitted(new PermittedOptions().setAddress("chat.to.server"))
      .addOutboundPermitted(new PermittedOptions().setAddress("chat.to.client"));
 
    // Create the event bus bridge and add it to the router.
    SockJSHandler ebHandler = SockJSHandler.create(vertx).bridge(opts);
    router.route("/eventbus/*").handler(ebHandler);
//    router.route("/").handler(routingContext -> {
//      routingContext.response().putHeader("content-type", "text/html").end(aaa);
//    });
    // Create a router endpoint for the static contentd
    router.route().handler(StaticHandler.create());
 
 
    // Start the web server and tell it to use the router to handle requests.
    vertx.createHttpServer().requestHandler(router).listen(8080);
 
    EventBus eb = vertx.eventBus();
 
    // Register to listen for messages coming IN to the server
    eb.consumer("chat.to.server").handler(message -> {
      // Create a timestamp string
      String timestamp = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM).format(Date.from(Instant.now()));
      // Send the message back out to all clients with the timestamp prepended.
      eb.publish("chat.to.client", timestamp + ": " + message.body());
    });
 
  }
 
  public static String getDB() {
//        Connection conn = null;
//        Statement stmt = null;
    String dbdata = "";
//        try {
//            Class.forName("com.mysql.jdbc.Driver").newInstance();
//        } catch (ClassNotFoundException e) {
//            System.out.println("드라이버 연결 에러.");
//        } catch (Exception etc) {
//            System.out.println(etc.getMessage());
//        }
//        try {
//            String url = "jdbc:mysql://localhost/nettydb";
//            String userId = "goo";
//            String userPass = "1234";
//
//            conn = DriverManager.getConnection(url, userId, userPass);
//            stmt = conn.createStatement();
//            ResultSet rs = null;
//            rs = stmt.executeQuery("select * from test");
//            if (stmt.execute("select * from test")) {
//                rs = stmt.getResultSet();
//            }
//
//            while (rs.next()) {
//                int num = rs.getInt("num");
//                System.out.println(num + "//");
//                dbdata = "num = "+num+"  ";
//            }
//            stmt.close();
//            conn.close();
//        } catch (SQLException e) {
//            System.out.println("SQLException : " + e.getMessage());
//        }
 
    Connection con = null;
    Statement stmt = null;
 
    String server = "localhost"; // MySQL 서버 주소
    String database = "vertxdb"; // MySQL DATABASE 이름
    String user_name = "goo"; //  MySQL 서버 아이디
    String password = "1234"; // MySQL 서버 비밀번호
 
    // 1.드라이버 로딩
    try {
      Class.forName("com.mysql.jdbc.Driver");
    } catch (ClassNotFoundException e) {
      System.err.println(" !! <JDBC 오류> Driver load 오류: " + e.getMessage());
      e.printStackTrace();
    }
 
    // 2.연결
    try {
      con = DriverManager.getConnection("jdbc:mysql://" + server + "/" + database + "?useSSL=false", user_name, password);
      System.out.println("정상적으로 연결었습니다.");
      stmt = con.createStatement();
      ResultSet rs = null;
      rs = stmt.executeQuery("select * from test");
      if(stmt.execute("select * from test")){
        rs = stmt.getResultSet();
      }
      while (rs.next()){
        int num = rs.getInt("num");
        String name = rs.getString("name");
        dbdata = dbdata+"num = "+num+", name = "+name+"  ";
      }
      stmt.close();
      con.close();
    } catch(SQLException e) {
      System.err.println("con 오류:" + e.getMessage());
      e.printStackTrace();
    }
 
    // 3.해제
    try {
      if(con != null)
        con.close();
    } catch (SQLException e) {}
 
    return dbdata;
  }
}

4. 해당 디렉토리 /webroot 에 이미지를 집어넣는다.
5. 프로젝트 Run 한번 때려준다.
6. helloworld 프로젝트

#Server.java

package io.vertx.example.web.helloworld;
 
import io.vertx.core.AbstractVerticle;
import io.vertx.example.util.Runner;
import io.vertx.ext.web.Router;
 
import java.sql.*;
 
/*
 * @author <a href="http://tfox.org">Tim Fox</a>
 */
public class Server extends AbstractVerticle {
 
  // Convenience method so you can run it in your IDE
  public static void main(String[] args) {
    Runner.runExample(Server.class);
  }
 
  @Override
  public void start() throws Exception {
 
    Router router = Router.router(vertx);
 
    router.route("/big").handler(routingContext -> {
      routingContext.response().putHeader("content-type", "text/html").end(
        "<html>" +
          "<body>" +
          "<img src='big.jpg' width=200>" +
          "</body>" +
          "</html>");
    });
 
router.route("/small1").handler(routingContext -> {
      routingContext.response().putHeader("content-type", "text/html").end(
        "<html>" +
          "<body>" +
          "<img src='small1.jpg' width=200>" +
          "</body>" +
          "</html>");
    });
 
router.route("/small2").handler(routingContext -> {
      routingContext.response().putHeader("content-type", "text/html").end(
        "<html>" +
          "<body>" +
          "<img src='small2.jpg' width=200>" +
          "</body>" +
          "</html>");
    });
 
router.route("/text").handler(routingContext -> {
    String dbdata = getDB();
      routingContext.response().putHeader("content-type", "text/html").end(
        "<html>" +
          "<body>" +
           dbdata +
          "</body>" +
          "</html>");
    });
 
    vertx.createHttpServer().requestHandler(router).listen(8080);
  }
 
  public static String getDB() {
 
    String dbdata = "";
 
 
    Connection con = null;
    Statement stmt = null;
 
    String server = "localhost"; // MySQL 서버 주소
    String database = "tn"; // MySQL DATABASE 이름
    String user_name = "root"; //  MySQL 서버 아이디
    String password = "1234"; // MySQL 서버 비밀번호
 
 
    // 1.드라이버 로딩
    try {
      Class.forName("com.mysql.jdbc.Driver");
    } catch (ClassNotFoundException e) {
      System.err.println(" !! <JDBC 오류> Driver load 오류: " + e.getMessage());
      e.printStackTrace();
    }
 
 
    // 2.연결
    try {
      con = DriverManager.getConnection("jdbc:mysql://" + server + "/" + database + "?useSSL=false", user_name, password);
      System.out.println("정상적으로 연결었습니다.");
      stmt = con.createStatement();
      ResultSet rs = null;
      //rs = stmt.executeQuery("select * from tn");
      if(stmt.execute("select * from tn")){
        rs = stmt.getResultSet();
      }
      while (rs.next()){
        String name = rs.getString("name");
        dbdata = dbdata + name;
      }
      stmt.close();
      con.close();
    } catch(SQLException e) {
      System.err.println("con 오류:" + e.getMessage());
      e.printStackTrace();
    }
 
 
    // 3.해제
    try {
      if(con != null)
        con.close();
    } catch (SQLException e) {}
 
    return dbdata;
  }
}

7. 그리고 Run 해주면 된다
필자는 4개의 파라미터로 구분해 놨다.
1. /big
2. /small1
3. /small2
4. /text