神奇的bug
前言:我写的明明是单例,可是为什么初始化了二次?
今天写的这个bug和单例设计模式有关。 所谓单例设计模式,这个不多说,详情可以自行百度。
spring中的单例
springboot的control就是单例的,关于这个可以看看这个文章
spring的controller默认是单例还是多例
场景
在我这次的项目中遇到这样一个功能需求:我需要设计一个单例的类,这个类里面有个阻塞队列。
日志的生产和消费就需要放置在队列中。
日志的生产我会监听logback的事件,如果logback打印日志,就把打印的内容发送到队列里面。
然后webscoket消费数据。
说白了,这里面的队列需要单例的,而且起到中转数据的作用。
代码
这是对队列进行一个简单的封装,如下
package cn.xiejx.jfun.config.websocket;
import cn.xiejx.jfun.vo.LogMessage;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
/**
* 创建一个阻塞队列,作为日志系统输出的日志的一个临时载体
* @author jie
* @date 2018-12-24
*/
public class LoggerQueue {
/**
* 队列大小
*/
public static final int QUEUE_MAX_SIZE = 10000;
private static LoggerQueue alarmMessageQueue = new LoggerQueue();
/**
* 阻塞队列
*/
private BlockingQueue blockingQueue = new LinkedBlockingQueue<>(QUEUE_MAX_SIZE);
private LoggerQueue() {
System.out.println("loggerquque:"+this.getClass().getClassLoader().toString());
}
public static LoggerQueue getInstance() {
return alarmMessageQueue;
}
/**
* 消息入队
* @param log
* @return
*/
public boolean push(LogMessage log) {
return this.blockingQueue.add(log);
}
/**
* 消息出队
*
* @return
*/
public LogMessage poll() {
LogMessage result = null;
try {
result = (LogMessage) this.blockingQueue.take();
System.out.println("消费一条消息"+result);
} catch (InterruptedException e) {
e.printStackTrace();
}
return result;
}
}
产生的问题
其实上面这个代码是没问题的。
我的项目是springboot,上面的单例使用的是没有用spring注解实现(springboot也有可以使用注解来使用单例)。
然后这边消费数据的时候调用take方法。
take方法没有数据是会阻塞的。
而数据已经有add进去了。
按理说可以消费到数据才是,可是数据却没有被消费。
分析
使用了java的一些分析工具,把堆dump了出来。
看到了消费数据的线程是处于等待状态。
最傻的方法用System.out.println也分析出线程一直在阻塞中(卡在take那里)
进一步分析
我确信单例的实现是没有问题的,按理说,数据add进去,应该是可以消费到的才对。
断点继续分析,不看不知道。
发现了消费和生产数据的时候,getInstance返回的对象的hashCode码不一样。
也就是说单例被破坏了,生产数据放在了a队列里面,而消费数据却要在b队列里面拿数据。
为什么呢?我的代码明明是单例啊啊啊啊!!!
解决问题
分析,如果是相同的类加载器,不可能出现这种情况。
那么我就在初始化的时候加上下面的代码
System.out.println("loggerquque:"+this.getClass().getClassLoader().toString());
发现这个类果然被初始化了2次。确实不是‘单例’了(不同的类加载器分别初始化)。
输出如下:
....
loggerquque:sun.misc.Launcher$AppClassLoader@18b4aac2
....
loggerquque:org.springframework.boot.devtools.restart.classloader.RestartClassLoader@2a5810d2
原来是这个热部署的锅!!!
拨云见日!!!
pom.xml文件果断去除热部署依赖先(暂时我只能这么解决)
<!--热部署工具-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<version>2.0.2.RELEASE</version>
<optional>true</optional>
<scope>runtime</scope>
</dependency>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<!--配置热启动-->
<fork>true</fork>
</configuration>
</plugin>
</plugins>
重启idea,问题解决。
参考链接
说明
上面的代码非原创,来自大佬的项目。
码云:https://gitee.com/elunez/eladmin-qt
github:https://github.com/elunez/eladmin-qd
这里感谢作者的开源。