Переменные пути в Spring WebSockets @SendTo mapping

Question

У меня есть, что я думаю, очень простое приложение Spring WebSocket. Тем не менее, я пытаюсь использовать переменные пути для подписки, а также отображение сообщений.

Я разместил приведенный ниже пример. Я бы ожидал, что аннотация @SendTo вернется к подписчикам на основе их fleetId. то есть POST - /fleet/MyFleet/driver/MyDriver должен уведомить об этом подписчиков /fleet/MyFleet, но я не вижу такого поведения.

Стоит отметить, что подписка на литерал /fleet/{fleetId} работает. Это предназначено? Не хватает ли какой-то части конфигурации? Или это не так, как это работает?

Я еще не знаком с WebSockets или этим проектом Spring, поэтому заранее заблаговременно.

Controller.java

... 
@MessageMapping("/fleet/{fleetId}/driver/{driverId}") 
@SendTo("/topic/fleet/{fleetId}") 
public Simple simple(@DestinationVariable String fleetId, @DestinationVariable String driverId) { 
    return new Simple(fleetId, driverId); 
} 
... 

WebSocketConfig.java

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 
    @Override 
    public void configureMessageBroker(MessageBrokerRegistry config) { 
     config.enableSimpleBroker("/topic"); 
     config.setApplicationDestinationPrefixes("/live"); 
    } 

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

index.html

var socket = new SockJS('/fleet'); 
var stompClient = Stomp.over(socket); 
stompClient.connect({}, function(frame) { 
    // Doesn't Work 
    stompClient.subscribe('/topic/fleet/MyFleet', function(greeting) { 
    // Works 
    stompClient.subscribe('/topic/fleet/{fleetId}', function(greeting) { 
     // Do some stuff 
    }); 
}); 

Отправить Sample

stompClient.send("/live/fleet/MyFleet/driver/MyDriver", {}, JSON.stringify({ 
     // Some simple content 
    })); 

Answer 1

Даже если @MessageMapping поддерживает заполнители, они не подвергаются/разрешаются в @SendTo адресатам. В настоящее время невозможно определить динамические адресаты с аннотацией @SendTo (см. Вопрос SPR-12170). На данный момент вы можете использовать SimpMessagingTemplate (так или иначе это работает внутри). Вот как вы могли бы сделать это:

@MessageMapping("/fleet/{fleetId}/driver/{driverId}") 
public void simple(@DestinationVariable String fleetId, @DestinationVariable String driverId) { 
    simpMessagingTemplate.convertAndSend("/topic/fleet/" + fleetId, new Simple(fleetId, driverId)); 
} 

В коде назначения «/тема/флот/{fleetId}» трактуется как буквальное, что причина, почему подписавшись на это работает, просто потому, что вы отправляются в тот же пункт назначения.

Если вы просто хотите отправить некоторые конкретные данные первоначального пользователя, вы можете вернуть его непосредственно в подписке:

@SubscribeMapping("/fleet/{fleetId}/driver/{driverId}") 
public Simple simple(@DestinationVariable String fleetId, @DestinationVariable String driverId) { 
    return new Simple(fleetId, driverId); 
} 

Обновление: Весной 4.2, назначение переменные заполнители поддерживаются это теперь возможно что-то вроде:

@MessageMapping("/fleet/{fleetId}/driver/{driverId}") 
@SendTo("/topic/fleet/{fleetId}") 
public Simple simple(@DestinationVariable String fleetId, @DestinationVariable String driverId) { 
    return new Simple(fleetId, driverId); 
}