2

我想设置一个 WebSocket 连接以将许多非常小的文件（1kb-50mb）上传到 Web 应用程序。

我的 Web 应用程序在 Wildfly 中运行，并且基于 rest/https 的组件工作正常，但是我的 Websocket 连接每次返回 404 或当我尝试时返回 200。

这是我的端点的代码：

package com.my.package;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

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;

import java.util.logging.Level;
import java.util.logging.Logger;

@ServerEndpoint("/smallfiles/socket")
public class WebsocketApi {

  private static final long serialVersionUID = 2356475533479775725L;
  private static final Logger logger = Logger.getLogger(WebsocketApi.class.getName());
  private static Set<Session> clients = Collections.synchronizedSet(new HashSet<Session>());


  @OnOpen
  public void onOpen(Session session) {
    // Set max buffer size
    session.setMaxBinaryMessageBufferSize(1024 * 512);
    // Add session to the connected sessions set
    clients.add(session);
    logger.log(Level.INFO,"Client " + session.getId() + " connected.");
  }

  @OnClose
  public void onClose(Session session) {
    // Remove session from the connected sessions set
    clients.remove(session);
    logger.log(Level.INFO,"Client " + session.getId() + " disconnected.");
  }

  @OnError
  public void onError(Throwable error) {
    logger.log(Level.SEVERE,error.getMessage());
  }

  @OnMessage
  public void processUpload(byte[] uploadData, Session session) {
    try {
      if (session.isOpen()) {
        // Wrap a byte array into a buffer
        ByteBuffer buf = ByteBuffer.wrap(uploadData);
        logger.log(Level.INFO,"Receiving Data");
        //session.getBasicRemote().sendBinary(buf);
      }
    } catch (Exception e) {
      try {
        session.close();
      } catch (Exception e1) {
        logger.log(Level.SEVERE,"Failed to close Session. ",e1);
      }
    }
  }
}

我有这样的想法，这可能是由 Apache 引起的，因为我们的 Wildfly 在作为反向代理的 apache 后面运行，所以我在我的 https-gw.conf 中添加了 Websocket 端点：

<IfModule mod_ssl.c>
    <VirtualHost *:443>
        ServerName repName
        SSLProxyEngine On
        ProxyRequests Off
        ProxyPreserveHost On

        ProxyPass                   /                           http://127.0.0.1:8080/
        ProxyPassReverse            /                           http://127.0.0.1:8080/
        ProxyPass                   /Application/               http://127.0.0.1:8080/Application/
        ProxyPassReverse            /Application/               http://127.0.0.1:8080/Application/
        ProxyPass                   /smallfiles/socket/                 ws://127.0.0.1:8080/websocket/
        ProxyPassReverse            /smallfiles/socket/                 ws://127.0.0.1:8080/websocket/
        ProxyPass                   /Application/smallfiles/socket/      ws://127.0.0.1:8080/Application/websocket/
        ProxyPassReverse            /Application/smallfiles/socket/      ws://127.0.0.1:8080/Application/websocket/

        SetEnv proxy-sendcl 10000000
        SetEnv  proxy-sendchunked

        #   Server Certificate:
        SSLCertificateFile /etc/apache2/ssl.crt/host.net.cer

        #   Server Private Key:
        SSLCertificateKeyFile /etc/apache2/ssl.key/host.net.key

        #   Certificate Authority (CA):
        SSLCACertificateFile /etc/apache2/ssl.crt/my_ca.crt
   </VirtualHost>
</IfModule>

但是，每当我尝试通过 Javascript 访问 Websocket 时，都会遇到以下问题：

ws = new WebSocket("wss://my.server.net/")
WebSocket {url: "wss://my.server.net/", readyState: 0, bufferedAmount: 0, onopen: null, onerror: null, …}

WebSocket 连接到“wss://my.application.net/”失败：WebSocket 握手期间出错：意外响应代码：200

或者

ws = new WebSocket("wss://my.server.net/smallfiles/socket")
WebSocket {url: "wss://my.server.net/smallfiles/socket", readyState: 0, bufferedAmount: 0, onopen: null, onerror: null, …}

WebSocket 连接到“wss://my.server.net/smallfiles/socket”失败：WebSocket 握手期间出错：意外响应代码：404

我还检查了来自用户@cayz 的帖子，但遗憾的是我并没有真正看到用户解决方案的含义。

有谁知道我在哪里发黑？

编辑： 我还检查了 wildfly 日志，wildfly 注册了端点。

2020-02-04 19:33:44,647 INFO  [io.undertow.websockets.jsr] (ServerService Thread Pool -- 113) UT026003: Adding annotated server endpoint class com.my.package.WebsocketApi for path /smallfiles/socket
4

0 回答 0