3

我正在尝试在我的项目中使用 RabbitMQ 作为代理，并且我想在客户端打开套接字时分配目标队列。像这样的东西：http: //i.imgur.com/ldB2M0m.png

我设法做到了SimpleBroker，但是当我尝试做到这一点时，StompBrokerRelay我无法在 RabbitMQ 上分配队列，并且我停止在客户端（http://i.imgur.com/gNaRHCQ.png）上接收消息。

这就是我的做法：

控制器：

@RestController
public class FeedController {

@Autowired
private SimpMessageSendingOperations template;

    @RequestMapping(value = "/feed",  method = RequestMethod.POST, consumes = "application/json")
    public Reference getLeankrReference(@RequestBody Reference ref)
    {       
        this.template.convertAndSendToUser(ref.getChannelId(), "/topic/feed", ref);
        return ref;
    }
}

网络套接字配置：

@Configuration
@EnableWebSocketMessageBroker
@EnableScheduling
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config)
    {
        config.enableStompBrokerRelay("/topic/")
            .setAutoStartup(true);

        //config.enableSimpleBroker("/user/");
        config.setApplicationDestinationPrefixes("/app");
    }

    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/vision").withSockJS();
    }
}

客户：

        function connect() {
        var socket = new SockJS('/ws/vision');
        var channel = document.getElementById('name').value;
        stompClient = Stomp.over(socket);

        stompClient.connect({}, function(frame) {
            setConnected(true);
            console.log('Connected: ' + frame);
            stompClient.subscribe('/user/' + channel + '/feed', function(message) {
                showContent(JSON.parse(message.body));
            });
        });
    }

我知道我错过了一些东西。也许一些经纪人配置？

先感谢您！

4

1 回答 1

1

终于，我发现我错过了什么！

网络套接字配置：

我只是分配主题队列。在这种情况下，我还需要队列队列，一旦我想将它分配给特定的用户/频道。

config.enableStompBrokerRelay("/queue/", "/topic/");

客户：

我指的不是我想使用的队列类型。

stompClient.subscribe('/user/queue/feed', function(content) {

但这还不够。它缺少正确的安全配置。

像这样的东西，

安全配置：

@Override
protected void configure(HttpSecurity http) throws Exception {
    http
        .csrf().disable()
        .headers().addHeaderWriter(
            new XFrameOptionsHeaderWriter(
                    XFrameOptionsHeaderWriter.XFrameOptionsMode.SAMEORIGIN)).and()
        .formLogin()
            .defaultSuccessUrl("/index.html")
            .loginPage("/login.html")
            .failureUrl("/login.html?error")
            .permitAll()
            .and()
        .logout()
            .logoutSuccessUrl("/login.html?logout")
            .logoutUrl("/logout.html")
            .permitAll()
            .and()
        .authorizeRequests()
            .antMatchers("/**").permitAll()
            .anyRequest().authenticated()
            .and();
}

@Override
protected void configure(AuthenticationManagerBuilder auth) throws Exception {
    auth
        .inMemoryAuthentication()
            .withUser("channel1").password("password").roles("USER");
}

有了这个，我添加了一个登录页面。这是没有必要的。您只需要确保密码参数用于身份验证。

现在 Rabbit 知道用户/频道，它可以将队列发送到特定目的地。

于 2015-08-04T18:40:18.720 回答