java - 是否可以在 Spring-Boot Web 应用程序中使用 Java 的 Socket API？

Question

当我用谷歌搜索这个主题时，我发现的都是与 websockets 相关的东西。我想使用 Java 的 Socket API 在客户端和服务器之间发送和接收数据(服务器始终是 spring-boot Web 应用程序，客户端可能是也可能不是)。

我将服务器应用程序设计为在执行 java -jar server.war 时在端口 4444 上运行。当我执行 java -jar client.war 时，客户端在端口 3333 上运行。服务器应监听端口 5555。

到目前为止我所拥有的服务器:

Controller

@Controller
public class Home {
  ServerSocket s;

  Integer PORT = 5555;

  @RequestMapping("/")
  public String index() {
    return "index";
  }

  @RequestMapping("/open_connection")
  @ResponseBody
  public void open_connection() throws Exception {
    s = new ServerSocket(PORT);
  }

  @RequestMapping("/close_connection")
  @ResponseBody
  public void close_connection() throws Exception {
    s.close();
  }

  @RequestMapping("/listen_connection")
  @ResponseBody
  public String listen_connection() throws Exception {
    Socket socket = s.accept();
    DataInputStream dis=new DataInputStream(socket.getInputStream());
    String  str = (String) dis.readUTF();
    socket.close();
    return str;
  }
}

这些方法是通过以下 JavaScript 代码调用的:

var isOpen = false;

function open_connection(e) {
  var url = e.dataset.url;
  var oReq = new XMLHttpRequest();

  oReq.onload = function(ev) {
    var responseText = oReq.response;
    isOpen = true;
    document.querySelector('.btn-success').style.display = 'none';
    document.querySelector('.btn-danger').style.display = 'block';
  }

  oReq.open("GET", url);
  oReq.send();
}

function close_connection(e) {
  var url = e.dataset.url;
  var oReq = new XMLHttpRequest();

  oReq.onload = function(ev) {
    var responseText = oReq.response;
    isOpen = false;
    document.querySelector('.btn-danger').style.display = 'none';
    document.querySelector('.btn-success').style.display = 'block';
  }

  oReq.open("GET", url);
  oReq.send();
}

function listen_connection(e) {
  var url = document.querySelector('.container').dataset.url;

  if(isOpen) {
    while(true) {
      var oReq = new XMLHttpRequest();

      oReq.onload = function(ev) {
        var responseText = oReq.response;
        if(responseText === 'quit') {
          break;
        } else {
          var item = document.createElement('li');
          item.setAttribute('class', 'list-group-item');
          item.innerText = responseText
          document.querySelector('.list-group').addChild(item);
        }
      }

      oReq.open("GET", url);
      oReq.send();
    }
  }
}

当我从 html View 调用此方法时，打开连接和关闭连接不会给我任何错误。我不知道如何开始监听连接以从客户端接收数据(我尝试从 open_connection 调用listen_connection，但这样当我调用打开连接方法时我会崩溃浏览器)。

在客户端，我有这个:

Controller

@Controller
public class Home {
  String HOST = "localhost";

  Integer PORT = 5555;

  @RequestMapping("/")
  public String index() {
    return "index";
  }

  @RequestMapping(value="/send_data", method=RequestMethod.POST)
  @ResponseBody
  public void send_data(@RequestParam("data") String data) throws Exception {
    Socket socket = new Socket(HOST, PORT);
    DataOutputStream dout = new DataOutputStream(socket.getOutputStream());
    dout.writeUTF(data);
    dout.flush();
    dout.close();
    socket.close();
  }
}

通过以下 JavaScript 代码调用此方法:

function send(e) {
  var url = e.dataset.url;
  var oReq = new XMLHttpRequest();

  oReq.onload = function(ev) {
    var responseText = oReq.response;
    document.querySelector('.form-control').value = '';

  }

  oReq.open("POST", url);
  var formData = new FormData();
  formData.append("data", document.querySelector('.form-control').value)
  oReq.send(formData);
}

这里的问题是，当我点击调用这个方法时，收到错误403(禁止)。

谁能告诉我我在这里做错了什么？

Answer 1

转到将使用 SpringIntegration ，TCP 和 UDP 文档可以找到 here 。但总而言之，您可以使用集成流将消息/通信从一种形式转换为另一种形式，并实现一系列标准企业集成模式。