@Configuration
@EnableWebSocketMessageBroker
@PropertySource("classpath:resources.properties")
public class WebSocketStompConfig extends AbstractWebSocketMessageBrokerConfigurer {@Value("${rabbitmq.host}")private String host;@Value("${rabbitmq.port}")private Integer port;@Value("${rabbitmq.userName}")private String userName;@Value("${rabbitmq.password}")private String password;/*** 将 "/stomp" 注册为一个 STOMP 端点。这个路径与之前发送和接收消息的目的地路径有所* 不同。这是一个端点，客户端在订阅或发布消息到目的地路径前，要连接到该端点。** @param registry*/@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/stomp").withSockJS();}/*** 如果不重载它的话，将会自动配置一个简单的内存消息代理，用它来处理以"/topic"为前缀的消息** @param registry*/@Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {//基于内存的STOMP消息代理registry.enableSimpleBroker("/queue", "/topic");//基于RabbitMQ 的STOMP消息代理
/*        registry.enableStompBrokerRelay("/queue", "/topic").setRelayHost(host).setRelayPort(port).setClientLogin(userName).setClientPasscode(password);*/registry.setApplicationDestinationPrefixes("/app", "/foo");registry.setUserDestinationPrefix("/user");}
}

    /*** 1、设置拦截器* 2、首次连接的时候，获取其Header信息，利用Header里面的信息进行权限认证* 3、通过认证的用户，使用 accessor.setUser(user); 方法，将登陆信息绑定在该 StompHeaderAccessor 上，在Controller方法上可以获取 StompHeaderAccessor 的相关信息* @param registration*/@Overridepublic void configureClientInboundChannel(ChannelRegistration registration) {registration.interceptors(new ChannelInterceptorAdapter() {@Overridepublic Message<?> preSend(Message<?> message, MessageChannel channel) {StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);//1、判断是否首次连接if (StompCommand.CONNECT.equals(accessor.getCommand())){//2、判断用户名和密码String username = accessor.getNativeHeader("username").get(0);String password = accessor.getNativeHeader("password").get(0);if ("admin".equals(username) && "admin".equals(password)){Principal principal = new Principal() {@Overridepublic String getName() {return userName;}};accessor.setUser(principal);return message;}else {return null;}}//不是首次连接，已经登陆成功return message;}});}

/*STOMP*/
var url = 'http://localhost:8080/stomp';
var sock = new SockJS(url);
var stomp = Stomp.over(sock);var strJson = JSON.stringify({'message': 'Marco!'});//默认的和STOMP端点连接
/*stomp.connect("guest", "guest", function (franme) {});*/var headers={username:'admin',password:'admin'
};stomp.connect(headers, function (frame) {//发送消息//第二个参数是一个头信息的Map，它会包含在STOMP的帧中//事务支持var tx = stomp.begin();stomp.send("/app/marco", {transaction: tx.id}, strJson);tx.commit();//订阅服务端消息 subscribe(destination url, callback[, headers])stomp.subscribe("/topic/marco", function (message) {var content = message.body;var obj = JSON.parse(content);console.log("订阅的服务端消息：" + obj.message);}, {});stomp.subscribe("/app/getShout", function (message) {var content = message.body;var obj = JSON.parse(content);console.log("订阅的服务端直接返回的消息：" + obj.message);}, {});/*以下是针对特定用户的订阅*/var adminJSON = JSON.stringify({'message': 'ADMIN'});/*第一种*/stomp.send("/app/singleShout", {}, adminJSON);stomp.subscribe("/user/queue/shouts",function (message) {var content = message.body;var obj = JSON.parse(content);console.log("admin用户特定的消息1：" + obj.message);});/*第二种*/stomp.send("/app/shout", {}, adminJSON);stomp.subscribe("/user/queue/notifications",function (message) {var content = message.body;var obj = JSON.parse(content);console.log("admin用户特定的消息2：" + obj.message);});/*订阅异常消息*/stomp.subscribe("/user/queue/errors", function (message) {console.log(message.body);});//若使用STOMP 1.1 版本，默认开启了心跳检测机制（默认值都是10000ms）stomp.heartbeat.outgoing = 20000;stomp.heartbeat.incoming = 0; //客户端不从服务端接收心跳包
});