JAVA WebSocket 独自Headerを設定したい

前提・実現したいこと

JAVAでWebSocketClientのコードを書いています。
独自ヘッダーを付加したいのですが、書き方がわかりません。

該当のソースコード

Java
1package Main.java;
2
3import java.net.URI;
4import java.util.Arrays;
5import java.util.Map;
6import java.util.List;
7
8import javax.websocket.ClientEndpoint;
9import javax.websocket.ClientEndpointConfig;
10import javax.websocket.ContainerProvider;
11import javax.websocket.OnClose;
12import javax.websocket.OnError;
13import javax.websocket.OnMessage;
14import javax.websocket.OnOpen;
15import javax.websocket.Session;
16import javax.websocket.WebSocketContainer;
17import javax.websocket.DeploymentException;
18import java.io.IOException;
19import javax.websocket.ClientEndpointConfig.Configurator;
20
21@ClientEndpoint
22public class WebSocketClient {
23
24	public WebSocketClient() {
25        super();
26    }
27
28    @OnOpen
29    public void onOpen(Session session) {
30        /* セッション確立時の処理 */
31        System.out.println("WebSocketセッション確立");
32    }
33
34    @OnMessage
35    public void onMessage(String message) {
36        /* メッセージ受信時の処理 */
37        System.out.println("WebSocket受信：");
38    }
39
40    @OnError
41    public void onError(Throwable th) {
42        /* エラー発生時の処理 */
43        System.out.println("WebSocketエラー：" + th.getMessage());
44    }
45
46   @OnClose
47   public void onClose(Session session) {
48        /* セッション解放時の処理 */
49       System.out.println("WebSocketセッション確立");
50   }
51
52   //@Override
53   public void beforeRequest(Map<String,List<String>> headers)
54   {
55          headers.put("X-My-Custom-Header", Arrays.asList("1"));
56   }   
57   
58   
59    public static void main(String[] args) throws Exception {
60        // 初期化のためWebSocketコンテナのオブジェクトを取得する
61        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
62
63      
64        // サーバー・エンドポイントのURI
65        URI uri = URI.create("ws://127.0.0.1:5001");
66
67        // サーバー・エンドポイントとのセッションを確立する
68        Session session = container.connectToServer(new WebSocketClient(),uri);
69        // メッセージをサーバへ送る
70        session.getBasicRemote().sendText("Hello World!!");
71    }
72}

xebme

2020/04/12 02:06

参考：https://stackoverflow.com/questions/31115205/how-to-add-headers-in-java-websocket-client やってみて結果を追記してください。

m.ts10806

2020/04/12 02:31

コードはマークダウンのcode機能を利用してご提示ください。

行動規範の内容に同意します

回答1件

自己解決

教えていただいたサイトを参考にコードを見直し、独自ヘッダーの設定ができました。
ありがとうございました。

Java
1package Main.java;
2
3import java.net.URI;
4import javax.websocket.ClientEndpoint;
5import javax.websocket.ContainerProvider;
6import javax.websocket.OnClose;
7import javax.websocket.OnError;
8import javax.websocket.OnMessage;
9import javax.websocket.OnOpen;
10import javax.websocket.Session;
11import javax.websocket.WebSocketContainer;
12
13@ClientEndpoint(configurator = PrClientConfiguratore.class)
14
15public class WebSocketClient {
16
17    public WebSocketClient() {
18        super();
19    }
20
21    @OnOpen
22    public void onOpen(Session session) {
23        /* セッション確立時の処理 */
24        System.out.println("WebSocketセッション確立");
25    }
26
27    @OnMessage
28    public void onMessage(String message) {
29        /* メッセージ受信時の処理 */
30        System.out.println("WebSocket受信：");
31    }
32
33    @OnError
34    public void onError(Throwable th) {
35        /* エラー発生時の処理 */
36        System.out.println("WebSocketエラー：" + th.getMessage());
37    }
38
39   @OnClose
40   public void onClose(Session session) {
41        /* セッション解放時の処理 */
42       System.out.println("WebSocketセッション確立");
43   }
44
45  
46    public static void main(String[] args) throws Exception {
47        // 初期化のためWebSocketコンテナのオブジェクトを取得する
48        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
49
50
51        // サーバー・エンドポイントのURI
52        URI uri = URI.create("ws://127.0.0.1:5001");
53
54        // サーバー・エンドポイントとのセッションを確立する
55        Session session = container.connectToServer(new WebSocketClient(),uri);
56        // メッセージをサーバへ送る
57        session.getBasicRemote().sendText("Hello World!!");
58    }
59}

Java
1package Main.java;
2
3import java.util.Arrays;
4import java.util.Map;
5import java.util.List;
6import javax.websocket.ClientEndpointConfig;
7import javax.websocket.HandshakeResponse;
8
9
10public class PrClientConfiguratore extends ClientEndpointConfig.Configurator {
11
12    @Override
13    public void beforeRequest(Map<String, List<String>> headers) {
14        headers.put("X-My-Custom-Header", Arrays.asList("1"));
15    }
16
17    @Override
18    public void afterResponse(HandshakeResponse handshakeResponse) {
19        // none
20    }
21}
22