初めに
タイトル通り。JavaSEでJettyを使ってWebSocket(JSR-356使用)サーバーを立てたので最小構成のメモ。
方法
必要なものはたった二つ。
- エンドポイント用のクラス(JSR-356準拠)
- サーバーを起動するMainメソッド
pom.xml
標準のjavax.websocket-apiとJettyのjavax-websocket-server-implに依存する。
・・・
<dependency>
<groupId>javax.websocket</groupId>
<artifactId>javax.websocket-api</artifactId>
<version>1.1</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty.websocket</groupId>
<artifactId>javax-websocket-server-impl</artifactId>
<version>9.3.8.v20160314</version>
</dependency>
・・・
EndPoint
JSR-356に準拠して書くだけ。標準仕様なのでJettyは関係ない。
EchoServer
package com.tatesuke.lab.jetty_standalone_websocket_server;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
/**
* 言われたことを返すだけの単純なWebScoketServerEndPoint
*/
@ServerEndpoint("/echo")
public class EchoServer {
@OnOpen
public void onOpen(Session session) {
/* セッション確立時の処理 */
System.out.println("onOpen");
}
@OnMessage
public String onMessage(String message) {
System.out.println("onMessage " + message);
return "You said \"" + message + "\".";
}
@OnError
public void onError(Throwable t) {
t.printStackTrace();
}
@OnClose
public void onClose(Session session) {
System.out.println("onClose");
}
}
Main関数
サーバーを起動するロジックをかいてやる。
Main.java
package com.tatesuke.lab.jetty_standalone_websocket_server;
import javax.websocket.server.ServerContainer;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.ServerConnector;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.websocket.jsr356.server.deploy.WebSocketServerContainerInitializer;
/**
* JettyによるStandalone Websocket Serverのmainメソッド
*/
public class Main {
public static void main(String[] args) throws Exception {
Server server = null;
try {
// Serverを生成
server = new Server();
ServerConnector connector = new ServerConnector(server);
connector.setPort(8080);
connector.setHost("127.0.0.1");
server.addConnector(connector);
// ServletContextHandlerを生成
ServletContextHandler context = new ServletContextHandler(
ServletContextHandler.SESSIONS);
context.setContextPath("/lab");
server.setHandler(context);
// ServerContainerを生成
ServerContainer wscontainer = WebSocketServerContainerInitializer
.configureContext(context);
wscontainer.addEndpoint(EchoServer.class);
// Server起動
server.start();
server.join();
} finally {
// Server終了
if (server != null) {
server.stop();
}
}
}
}
動作確認
上記のプログラムを実行したら、下記のHTMLを保存してブラウザで実行する。
<!doctype html>
<html>
<head>
<meta charset="UTF-8">
<title>echo-websocket-client-sample</title>
</head>
<body>
<div>
<input placeholder="Type text and click button" type="text">
<button>send</button>
</div>
<div id="echoArea"></div>
<script>
var button = document.querySelector("button");
button.addEventListener("click", function() {
var elem = document.querySelector("input[type=text]");
var text = elem.value;
elem.value = "";
var ws = new WebSocket('ws://localhost:8080/lab/echo');
ws.onopen = function() {
ws.send(text);
}
ws.onmessage = function(event) {
var echoArea = document.querySelector("#echoArea");
var msg = event.data;
echoArea.insertAdjacentHTML("afterbegin", msg + "<br>");
ws.close();
}
});
</script>
</body>
</html>
テキストエリアに文字を入力してボタンを押すと、サーバーから返された文字を表示する。
さすが標準仕様。あっけなく動く。
今回は以上。