Spring WebSocketMessageBrokerConfigurer with Artemis 2.6.3 M

Question

Artemis mutilcast地址和队列没有预期的行为。 我的想法是创建组或特定的消息传递给可以有多个websocket会话(web，android等(的用户。服务器将向Artemis多播地址发布通知，所有订阅者都应收到通知。在当前场景中，我只是强制用户"luislaves00"并创建多个会话。在 artemis 中，我可以看到 2 个消费者(不确定 Spring 的消息代理中继如何完成它的工作(，但消费者的行为就像一个循环，而不是发布者-订阅者。使用Spring的内存代理，它可以正常工作，但它不耐用，因此当没有连接订阅者时，消息将被丢弃。 这是我正在使用的代码：

客户端部分：

function connect() {
var socket = new SockJS('/notification-websocket');
stompClient = Stomp.over(socket);
var headers = {
// todo: server will handle this logic
'client-id': 'luisalves00',
'durable-subscription-name': 'luisalves00',
'id' : 'luisalves00'
};
stompClient.connect(headers, function(frame) {
setConnected(true);
console.log('Connected: ' + frame);
// todo: server will handle this logic
stompClient.subscribe('/topic/notification/username' + 'luisalves00', function(notification) {
showNotification(JSON.parse(notification.body).content);
}, headers);
});
}

代理中继配置：

public void configureMessageBroker(MessageBrokerRegistry config) {
// Artemis ->
// tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true
config.enableStompBrokerRelay("/topic").setRelayHost("127.0.0.1").setRelayPort(61613);
config.setApplicationDestinationPrefixes("/app");
//config.enableSimpleBroker("/topic");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
logger.info("Registering the stomp endpoints.");
registry.addEndpoint("/notification-websocket").setAllowedOrigins("*").withSockJS();
}

服务器虚拟通知生产者：

@Scheduled(fixedDelay = 20000)
public void scheduleTaskWithFixedDelay() {
final Notification message = new Notification(UUID.randomUUID().toString() + " -> "  + dateTimeFormatter.format(LocalDateTime.now()));
try {
final String user = "luisalves00";
logger.info("Creating msg={}", message);
final Map<String, Object> headers = new HashMap<>();
headers.put("subscription-id", user);
template.convertAndSend("/topic/notification/username/" + user, message, headers);
} catch (Exception e) {
logger.error("", e);
}
}

当客户端订阅时，artemis 使用以下参数创建地址和持久队列：

Addesses: 
id=2147496008 name=/topic/notification/group1/ routingType=[MULTICAST] queueCount=1
Queue
id=2147496011 
name=group1.group1 
address=/topic/notification/group1/ 
routingType=MULTICAST
durable=true
maxConsumers-1
purgeOnNoConsumers=false 
consumerCount=0

Answer 1

要使持久工作，您必须使用：

'client-id': '<some unique identifier for each client>'
'durable-subscription-name': 'tech-news'

对于我的实现，我停止使用持久，因为通知的想法是在创建时传递(低延迟(。如果使用者未连接，它可以连接到历史数据库，以获取他在连接时未收到的旧消息。 如果你真的想让它持久，我建议在服务器端处理连接用户的"客户端 id"和持久订阅名称。如果用户没有正在进行的会话，则创建一个持久队列。他创建的下一个会话应该是非持久的，因为它们将收到与持久会话相同的消息。如果第一个会话死亡，他仍然会在其他会话上收到消息。当所有人都死了并且他重新连接时，这将是第一次再次会话，他将收到所有未在持久队列中传递的消息(可能是他在非持久队列中已经收到的一些消息(，但他将拥有所有消息的历史记录(如前所述，我认为应该以其他方式处理(。