用户目标

应用程序可以发送针对特定用户的消息，Spring的STOMP支持识别以/user/为前缀的目标以实现此目的。例如，客户端可能订阅/user/queue/position-updates目标。UserDestinationMessageHandler处理此目标并将其转换为与用户会话唯一相关的目标（例如/queue/position-updates-user123）。这提供了订阅通用命名目标的便利性，同时确保不会与订阅相同目标的其他用户发生冲突，以便每个用户可以接收到唯一的股票位置更新。

在处理用户目标时，重要的是配置经纪人和应用程序目标前缀，如在启用STOMP中所示，否则经纪人将处理应该由UserDestinationMessageHandler处理的以"/user"为前缀的消息。

在发送方面，消息可以发送到目标，例如/user/{username}/queue/position-updates，然后由UserDestinationMessageHandler转换为一个或多个目标，每个与用户关联的会话一个目标。这使得应用程序中的任何组件都可以发送针对特定用户的消息，而无需了解更多信息，只需知道他们的名称和通用目标。这也通过注释和消息模板支持。

消息处理方法可以通过@SendToUser注释（也支持在类级别上共享一个公共目标）向处理的消息关联的用户发送消息，如下例所示：

@Controller
public class PortfolioController {

	@MessageMapping("/trade")
	@SendToUser("/queue/position-updates")
	public TradeResult executeTrade(Trade trade, Principal principal) {
		// ...
		return tradeResult;
	}
}

如果用户有多个会话，默认情况下，所有订阅给定目标的会话都会被定位。但是，有时可能需要仅定位发送处理的消息的会话。您可以通过将broadcast属性设置为false来实现，如下例所示：

@Controller
public class MyController {

	@MessageMapping("/action")
	public void handleAction() throws Exception{
		// raise MyBusinessException here
	}

	@MessageExceptionHandler
	@SendToUser(destinations="/queue/errors", broadcast=false)
	public ApplicationError handleException(MyBusinessException exception) {
		// ...
		return appError;
	}
}

虽然用户目标通常意味着经过身份验证的用户，但并非严格要求。未与经过身份验证用户关联的WebSocket会话可以订阅用户目标。在这种情况下，@SendToUser注释的行为与broadcast=false完全相同（即仅定位发送处理的消息的会话）。

您可以通过例如注入由Java配置或XML命名空间创建的SimpMessagingTemplate来从任何应用程序组件发送消息到用户目标。（如果需要与@Qualifier限定符一起使用，bean名称为brokerMessagingTemplate。）以下示例显示了如何实现：

@Service
public class TradeServiceImpl implements TradeService {

	private final SimpMessagingTemplate messagingTemplate;

	@Autowired
	public TradeServiceImpl(SimpMessagingTemplate messagingTemplate) {
		this.messagingTemplate = messagingTemplate;
	}

	// ...

	public void afterTradeExecuted(Trade trade) {
		this.messagingTemplate.convertAndSendToUser(
				trade.getUserName(), "/queue/position-updates", trade.getResult());
	}
}

当您在外部消息代理中使用用户目标时，应查看经纪人文档以了解如何管理非活动队列，以便在用户会话结束时移除所有唯一用户队列。例如，RabbitMQ在使用/exchange/amq.direct/position-updates等目标时会创建自动删除队列。因此，在这种情况下，客户端可以订阅/user/exchange/amq.direct/position-updates。类似地，ActiveMQ有用于清除非活动目标的配置选项。

在多应用服务器场景中，用户目标可能无法解析，因为用户连接到不同的服务器。在这种情况下，您可以配置一个目标来广播未解析的消息，以便其他服务器有机会尝试。这可以通过Java配置中的MessageBrokerRegistry的userDestinationBroadcast属性或XML中message-broker元素的user-destination-broadcast属性来实现。