哦，client side no need to known about current user，服务器会帮你做的。
在服务器端，使用以下方式向用户发送消息：

simpMessagingTemplate.convertAndSendToUser(username, "/queue/reply", message);

• • 注意：使用queue，而不是topic，Spring始终将queue与sendToUser一起使用**

在客户端

stompClient.subscribe("/user/queue/reply", handler);

• • 请解释**

当任何一个websocket连接打开时，Spring会给它分配一个session id（不是HttpSession，每个连接分配一个）。当你的客户端订阅一个频道时，以/user/开始，例如：/user/queue/reply，则服务器示例将订阅名为queue/reply-user[session id]的队列
使用时向用户发送消息，例如：用户名为admin您将写入simpMessagingTemplate.convertAndSendToUser("admin", "/queue/reply", message);
Spring将确定哪个session idMap到用户admin。例如：它发现了两个会话wsxedc123和thnujm456，Spring会将其转换为两个目的地queue/reply-userwsxedc123和queue/reply-userthnujm456，并将带有两个目的地的消息发送到消息代理。
消息代理接收消息并将其提供回您的服务器示例，该示例持有与每个会话对应的会话（WebSocket会话可以由一个或多个服务器持有）. Spring会将消息转换为destination（例如：user/queue/reply）和session id（例如：wsxedc123），然后将消息发送到对应的Websocket session

啊，我发现我的问题是什么了，首先我没有在简单代理上注册/user前缀

<websocket:simple-broker prefix="/topic,/user" />

那么发送时就不需要额外的/user前缀了：

convertAndSendToUser(principal.getName(), "/reply", reply);

Spring会自动将"/user/" + principal.getName()添加到目的地，因此它解析为“/user/bob/reply”。
这也意味着在javascript中我必须为每个用户订阅不同的地址

stompClient.subscribe('/user/' + userName + '/reply,...)

我也使用STOMP创建了一个示例WebSocket项目。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
    config.enableSimpleBroker("/topic", "/queue");// including /user also works
    config.setApplicationDestinationPrefixes("/app");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/getfeeds").withSockJS();
}

无论“/user”是否包含在config中，它都有效。

我的解决方案基于Thanh Nguyen货车的最佳解释，但除此之外，我还配置了MessageBrokerRegistry：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/queue/", "/topic/");
        ...
    }
    ...
}

完全一样，我做了同样的，它是工作，而不使用用户

@Configuration
@EnableWebSocketMessageBroker  
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
       registry.addEndpoint("/gs-guide-websocket").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic" , "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }
}

在下面的解决方案中，我为客户端和后端编写了代码片段。我们需要将/user放在客户端代码套接字主题的开头。否则，客户端无法侦听套接字。依赖性

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

网络套接字配置.java

package com.oktaykcr.notificationservice.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/socket").setAllowedOriginPatterns("*");
        registry.addEndpoint("/socket").setAllowedOriginPatterns("*").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/file");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

网络套接字控制器.java

package com.oktaykcr.notificationservice.controller;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;

@Controller
public class WebSocketController {

    Logger logger = LoggerFactory.getLogger(WebSocketController.class);

    @MessageMapping("/socket")
    @SendTo("/file/status")
    public String fileStatus(@Payload String message) {
        logger.info(message);
        return message;
    }
}

你可以从任何地方向socket发送消息，在我的例子中，我的principal.getName（）等于userId。

simpMessagingTemplate.convertAndSendToUser(userId, "/file/status", socketMessage);

**客户端（带有react-stomp的Reactjs）**应用js

import './App.css';
import SockJsClient from 'react-stomp'
import { useRef } from 'react';

function App() {

  const clientRef = useRef();

  const sendMessage = (msg) => {
    clientRef.current.sendMessage('/app/socket', msg);
  }

  return (
    <div className="App">
      <div>
        <button onClick={() => sendMessage("Hola")}>Send</button>
      </div>
      <SockJsClient url='http://localhost:9090/notification-service/socket' topics={['/user/file/status']}
        onMessage={(msg) => { console.log(msg); }}
        ref={(client) => { clientRef.current = client }} />
    </div>
  );
}

export default App;

SockJsClient元素的url属性是http://localhost:9090/notification-service/socket。http://localhost:9090是API网关IP地址，notification-service是微服务的名称，/socket在WebSocketConfig.java中定义。