package WebSocketTest;

import java.net.URI;
import javax.websocket.ClientEndpoint;
import javax.websocket.ContainerProvider;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;

@ClientEndpoint
public class SampleClient {

    public SampleClient() {
        super();
    }

    @OnOpen
    public void onOpen(Session session) {
        /* セッション確立時の処理 */
        System.out.println("WebSocketセッション確立");
    }

    @OnMessage
    public void onMessage(String message) {
        /* メッセージ受信時の処理 */
        System.out.println("WebSocket受信：");
    }

    @OnError
    public void onError(Throwable th) {
        /* エラー発生時の処理 */
        System.out.println("WebSocketエラー：" + th.getMessage());
    }

    @OnClose
    public void onClose(Session session) {
        /* セッション解放時の処理 */
        System.out.println("WebSocketセッション確立");
    }


    public static void main(String[] args) throws Exception {
        // 初期化のためWebSocketコンテナのオブジェクトを取得する
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        // サーバー・エンドポイントのURI
        URI uri = URI.create("ws://localhost:8080/websocket");
        // サーバー・エンドポイントとのセッションを確立する
        Session session = container.connectToServer(new SampleClient(),uri);
        // メッセージをサーバへ送る
        session.getBasicRemote().sendText("Hello World!!");
    }
}