spring boot集成WebSocket日志实时输出到web页面的方法

本篇内容介绍了"spring boot集成WebSocket日志实时输出到web页面的方法"的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

前言

本文使用到的其实就是使用spring boot自带的webSocket模块提供stomp的服务端，前端使用stomp.min.js做stomp的客户端，使用sockjs来链接，前端订阅后端日志端点的消息，后端实时推送，达到日志实时输出到web页面的目的，效果如下图

首先了解下stomp

STOMP即Simple (or Streaming) Text Orientated Messaging Protocol，简单(流)文本定向消息协议，它提供了一个可互操作的连接格式，允许STOMP客户端与任意STOMP消息代理（Broker）进行交互。STOMP协议由于设计简单，易于开发客户端，因此在多种语言和多种平台上得到广泛地应用。

STOMP协议的前身是TTMP协议（一个简单的基于文本的协议），专为消息中间件设计。
STOMP是一个非常简单和容易实现的协议，其设计灵感源自于HTTP的简单性。尽管STOMP协议在服务器端的实现可能有一定的难度，但客户端的实现却很容易。例如，可以使用Telnet登录到任何的STOMP代理，并与STOMP代理进行交互。

下面是具体的步骤，主要是日志信息的获取和日志信息的推送，不多说，上代码

一.引入spring boot websocket依赖

                        org.springframework.boot                        spring-boot-starter-websocket

二.新增日志消息实体

/** * Created by kl on 2017/10/9. * Content :日志消息实体，注意，这里为了减少篇幅，省略了get,set代码 */public class LoggerMessage{    private String body;    private String timestamp;    private String threadName;    private String className;    private String level;    public LoggerMessage(String body, String timestamp, String threadName, String className, String level) {        this.body = body;        this.timestamp = timestamp;        this.threadName = threadName;        this.className = className;        this.level = level;    }    public LoggerMessage() {    }}

三. 创建一个阻塞队列

作为日志系统输出的日志的一个临时载体

public class LoggerQueue {    //队列大小    public static final int QUEUE_MAX_SIZE = 10000;    private static LoggerQueue alarmMessageQueue = new LoggerQueue();    //阻塞队列    private BlockingQueueblockingQueue = new LinkedBlockingQueue<>(QUEUE_MAX_SIZE);    private LoggerQueue() {    }    public static LoggerQueue getInstance() {        return alarmMessageQueue;    }    /**     * 消息入队     * @param log     * @return     */    public boolean push(LoggerMessage log) {        return this.blockingQueue.add(log);//队列满了就抛出异常，不阻塞    }    /**     * 消息出队     * @return     */    public LoggerMessage poll() {        LoggerMessage result = null;        try {            result = this.blockingQueue.take();        } catch (InterruptedException e) {            e.printStackTrace();        }        return result;    }}

四.获取logback的日志，塞入日志队列中

1.定义Logfilter拦截输出日志

public class LogFilter extends Filter{    @Override    public FilterReply decide(ILoggingEvent event) {        LoggerMessage loggerMessage = new LoggerMessage(                event.getMessage()                , DateFormat.getDateTimeInstance().format(new Date(event.getTimeStamp())),                event.getThreadName(),                event.getLoggerName(),                event.getLevel().levelStr        );        LoggerQueue.getInstance().push(loggerMessage);        return FilterReply.ACCEPT;    }}

2.配置logback.xml,添加我们自定义的filter

                                    ${CONSOLE_LOG_PATTERN}            utf8                                            

五.配置WebSocket消息代理端点，即stomp服务端

@Configurationpublic class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer{    @Override    public void registerStompEndpoints(StompEndpointRegistry registry) {        registry.addEndpoint("/websocket")                .setAllowedOrigins("http://localhost:8976")                .withSockJS();    }}

注意：为了连接安全，setAllowedOrigins设置的允许连接的源地址，如果在非这个配置的地址下发起连接会报403，进一步还可以使用addInterceptors设置拦截器，来做相关的鉴权操作

六.启动类，开启webSocket消息代理功能，并推送日志信息

@SpringBootApplication@EnableScheduling@EnableWebSocketMessageBrokerpublic class WebsocketApplication {        private Logger logger = LoggerFactory.getLogger(WebsocketApplication.class);        public static void main(String[] args) {                SpringApplication.run(WebsocketApplication.class, args);        }        @Autowired        private SimpMessagingTemplate messagingTemplate;    int info=1;        @Scheduled(fixedRate = 1000)        public void outputLogger(){      logger.info("测试日志输出"+info++);        }        /**         * 推送日志到/topic/pullLogger         */        @PostConstruct        public void pushLogger(){                ExecutorService executorService=Executors.newFixedThreadPool(2);                Runnable runnable=new Runnable() {                        @Override                        public void run() {                                while (true) {                                        try {                                                LoggerMessage log = LoggerQueue.getInstance().poll();                                                if(log!=null){                                                        if(messagingTemplate!=null)                                                        messagingTemplate.convertAndSend("/topic/pullLogger",log);                                                }                                        } catch (Exception e) {                                                e.printStackTrace();                                        }                                }                        }                };                executorService.submit(runnable);                executorService.submit(runnable);        }}

七.html页面，连接stomp服务端，订阅/topic/pullLogger的消息，展示日志信息

                    开启日志关闭日志
    

"spring boot集成WebSocket日志实时输出到web页面的方法"的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站，小编将为大家输出更多高质量的实用文章！