线程不安全会发生什么问题?

线程不安全会发生什么问题?
线程不安全会发生什么问题?
线程不安全会发生什么问题?

8个回答

举例:
两个线程共享一个堆上的公共变量a
线程1和线程2都有如下代码
int c = a;
c = c + 1;
a = c; //实际上可能写的是a++,但是a++看上去是原子的,为了演示,写成如上的形式。
假设a=100,按照预期,两个线程各执行一次,结果应该是102,但是可能出现101:
线程1:c = a; c = c +1;,此时c = 101,线程2执行c = a,此时a还是100,c = c + 1,c= 101。然后线程1写回101,线程2也写回101。

程序运行结果出错,死锁,等等

关于死锁,举例:
线程1锁住a,等待b
在此过程中,如果线程2占用的是b,并且等待a,那么两个线程会无限等待下去,这就是姜昆小品中说的“工厂不给幼儿园开介绍信,幼儿园没有义务给工厂开介绍信;没有幼儿园的介绍信,工厂没有义务先给幼儿园开介绍信”

有的时候会发生更糟糕的事情,比如说第一个程序,C++中一个线程释放了指针,另一个线程还在使用这个指针,那么有可能会破坏内存,导致不可预知的问题。

多线程带来的风险有三种,安全性问题,活跃性问题,性能问题。
首先,安全性问题,《Java并发编程》一书中对类的线程安全的定义是:当多个线程访问某个类时,不管运行环境采用何种调度方式或者这些线程将如何交替执行,并且在主调用代码中不需要任何额外的同步或者协同,这个类都能表现正确的行为,那么这个类就是线程安全的。
相反这段描述的另一面就是线程不安全的,即可能出现某个类的行为与其规范的不一致。例如:数值序列生成器,简单的共享变量++操作。

 public class UnsafeSequence{
     private int value;
         public int getNext(){
             return value++;
        }
 }

这段代码的getNext如果执行时机不对,那么两个线程在调用getNext时会得到相同的值,因为value++操作本身包含三种独立的操作,读value,value+1,写入value,这三个动作如果在多个线程之间交替执行,就可能导致最终的数据不合常理。也就是说这段代码存在安全性问题。
其次,活跃性问题是指当某个操作无法继续执行下去时就会发生活跃性问题,如锁机制下线程死锁的问题。
最后,性能问题,多线程程序中,线程的调度,频繁的上下文切换等操作会带来极大的开销,也是编写多线程应用需要权衡的问题。

caozhy
每个人都有一个梦才不会孤单的说话就有天堂 性能问题不是线程不安全调用的风险,而是采用多线程的问题。
大约 4 年之前 回复

不能按照你写的逻辑得到正确的结果!例如你要计数,如果你不是线程安全的,可能你获得计数结果就是错误的!

最好自己写个测试,最常见的就是数据出错,

有可能出现多个线程先后更改数据,从而造成所得到的数据是脏数据。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
javaGC回收时,sleep状态并不在安全区域的线程怎么办?还是说线程中断时肯定在安全区域?
深入理解java虚拟机中74,75页讲到安全区域,说到了线程在安全区域的情况,发生GC时,不用管在安全区域的线程,那不在安全区域的线程是什么情况?还是线程中断时,都会停留在安全区域?能提供一下参考资料么 安全区域描述如下 这里忽略了一个问题,当发生GC时,运行中的线程可以跑到Safe Point后进行挂起,而那些处于Sleep或Blocked状态的线程在此时无法响应JVM的中断请求,无法到Safe Point处进行挂起,针对这种情况,可以使用安全区域(Safe Region)进行解决。 Safe Region是指在一段代码片段中,对象的引用关系不会发生变化,在这个区域中的任何位置开始GC都是安全的。 1、当线程运行到Safe Region的代码时,首先标识已经进入了Safe Region,如果这段时间内发生GC,JVM会忽略标识为Safe Region状态的线程; 2、当线程即将离开Safe Region时,会检查JVM是否已经完成GC,如果完成了,则继续运行,否则线程必须等待直到收到可以安全离开Safe Region的信号为止;
为什么发生GC的时候要让所有的线程都运行到安全点(Safepoint)处呢?
为什么发生GC的时候要让所有的线程都运行到安全点(Safepoint)处呢?不能在当前执行的地方停下来就好吗? 换句话说,就是为什么要有安全点的存在? 设置安全点的目的是什么? 安全点一般是设置在指令序列复用的地方,例如方法调用、循环跳转、异常跳转 我的理解是因为JVM不会在执行每条指令的时候都更新OopMap,这样开销太大,而是选择在执行到安全点处就更新一下OopMap。 以便在OopMap的协助下快速完成GC
关于C++ stl string的线程安全性问题
http://bbs.csdn.net/topics/50362435 . 这篇文章的作者在不同线程中访问stl string的不同实例,遭遇了线程冲突。根据文中说法,是否可以这样理解:一旦多线程中某个操作会导致string实例发生空间分配,即使这些线程不是访问的同一个实例,也必须在操作时加上线程锁? . 另,这篇文章的回复中,有人提到"vc6的stl不支持多线程"。那如果使用较新编译平台实现的stl,例如vs2013,是否还需要考虑这个问题? . 之前写的多线程程序中使用过stl string,如果全部修改,代价会比较高。由于我找到的描述这个问题的文章日期基本都很老,所以希望知道,是否可以不修改。
单例饿汉为什么是线程安全的
我不明白为什么饿汉式是线程安全的,在我想来,饿汉的对象属于类成员,而非方法成员,那么就有可能发生争夺成员资源的现象呀。 ``` //饿汉式单例类.在类初始化时,已经自行实例化 public class Singleton1 { private Singleton1() {} private static final Singleton1 single = new Singleton1(); //静态工厂方法 public static Singleton1 getInstance() { return single; } } ```
线程不安全方法,取同一个内存区数据,取到同一个数据是为什么
今天通过视频学习线程并发,测试的时候发现线程不安全的方法,取数据时,会取到大量相同的数据。我知道线程不安全可能会取到错误的数据,但是为什么会发生上述情况呢,是因为cpu么。求大神简单解释原理 ``` /*模拟网络12306抢票概念流程*/ public class SleepDemo02 { public static void main(String[] args) { //真实角色 web12306 web=new web12306(); //代理角色 Thread t1=new Thread(web,"大黄牛"); Thread t2=new Thread(web,"小黄牛"); Thread t3=new Thread(web,"老黄牛"); t1.start(); t2.start(); t3.start(); } } class web12306 implements Runnable{ private int num=50; @Override public void run() { while(true){ if(num<=0){ break; } try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+"抢到了"+num--); } } } ``` 关键运行结果: 老黄牛抢到了50 小黄牛抢到了49 大黄牛抢到了50 小黄牛抢到了48 老黄牛抢到了48 大黄牛抢到了47 小黄牛抢到了46 老黄牛抢到了46 大黄牛抢到了45 老黄牛抢到了44 小黄牛抢到了43 大黄牛抢到了42 老黄牛抢到了41 小黄牛抢到了40 大黄牛抢到了39 小黄牛抢到了38 老黄牛抢到了37 大黄牛抢到了36 小黄牛抢到了35 老黄牛抢到了35 大黄牛抢到了34 小黄牛抢到了33 老黄牛抢到了33 ......
libssh2在多线程中如何确保线程安全?
如题,我在csdn下载了一个别人编译好的libssh2库,但在多线程中使用的时候,总是运行一会儿就报异常说写入位置发生冲突,目前我只知道libssh2_session_init();这个函数是不安全的,多线程中需要加锁。我想请问下还有其他哪些函数是需要加锁的?只需要告诉我下面这些函数哪些需要加锁就可以了。 1.libssh2_session_set_timeout 2.libssh2_session_startup 3.libssh2_session_free 4.libssh2_userauth_password 5.libssh2_session_disconnect 谢谢各位了。还有人说需要在编译libssh2的时候给openssl设置加锁回调,请知道的教教菜鸟我吧。
JAVA中多线程stop() 和 suspend()方法为何不推荐使用?
有一道JAVA面试题如题目所写,网上答案是这么写的, 反对使用 stop(),是因为它不安全。它会解除由线程获取的所有锁定,而且如果对象处于一 种不连贯状态,那么其他线程能在那种状态下检查和修改它们。结果很难检查出真正的问题 所在。suspend()方法容易发生死锁。调用 suspend()的时候,目标线程会停下来,但却仍 然持有在这之前获得的锁定。此时,其他任何线程都不能访问锁定的资源,除非被"挂起"的 线程恢复运行。对任何线程来说,如果它们想恢复目标线程,同时又试图使用任何一个锁定 的资源,就会造成死锁。所以不应该使用 suspend(),而应在自己的 Thread 类中置入一个 标志,指出线程应该活动还是挂起。若标志指出线程应该挂起,便用 wait()命其进入等待状 态。若标志指出线程应当恢复,则用一个 notify()重新启动线程。 上面那句“对任何线程来说,如果它们想恢复目标线程,同时又试图使用任何一个锁定 的资源,就会造成死锁。”是什么意思,能解释清楚吗?那个suspend的线程恢复运行了不就可以继续运行了吗,怎么会死锁呢
一个懒汉模式单例crash的问题
先贴最后崩溃的地方的代码: InterfaceManage* InterfaceManage::Instance() { static InterfaceManage ins; return &ins; } 程序运行中会出现小概率的崩溃,昨天终于通过dmp文件拿到调用栈信息,但是百思不得其解,在C++11里面这个懒汉模式的单利应该是线程安全的啊,为什么会崩溃呢?异常信息如下: 0xC0000005: 读取位置 0x0000023F0D0D0D11 时发生访问冲突。
concurrentHashMap是线程安全且强一致性的吗?
看了文档,但是不是很明白,这个类可以在不阻塞线程的情况下提供线程安全的并发写,但是他没有对读进行同步,那么,假如读和写发生在同一个元素的时候,怎么办?这时候不做同步,那么数据肯定是脏的啊?还是我理解有错,大家都怎么使用这个类咧
在多线程情况下,不使用同步,对同一个MAP的并发读写问题
假设有以下场景: 某一个业务要求,定时的从数据库中取出一批数据放入一个hashmap中。 有多个线程对这个MAP进行读操作。 每过一段时间(如3分钟),都会对这个MAP进行修改(put or remove) 该场景对数据的一致性没有非常严格的要求。 如何能够在不使用同步的情况下,对这个MAP进行安全的操作呢?(例如不用concurrentHashMap,或Collections.synchronizedMap) 我的想法是,每次在需要修改MAP的时候,可以创建一个旧MAP的副本,对副本进行修改后,再替换原先的MAP 例如: Map newMap = oldMap.clone(); //或者用new HashMap().putall(oldMap)来创造副本 newMap.put / remove ..... //修改map oldMap = newMap; //替换上去 这样就不会因为对同一个map的并发读写而导致快速迭代失败。有没有大神看看这样有什么潜在的问题,比如GC。。请不吝赐教>_< ( jdk 1.6 api hashMap 在迭代器创建之后,如果从结构上对映射进行修改,除非通过迭代器本身的 remove 方法,其他任何时间任何方式的修改,迭代器都将抛出 ConcurrentModificationException。因此,面对并发的修改,迭代器很快就会完全失败,而不冒在将来不确定的时间发生任意不确定行为的风险。 )
Spring中通过ApplicationContextAware的实现类获得的ApplicationContext是线程安全的吗?
项目中我需要根据登陆用户动态修改Spring的数据源配置,即通过实现ApplicationContextAware接口来获取ApplicationContext,并将用户对应的数据源bean覆盖这个ApplicationContext的数据源bean。在多线程的情况下,是否会发生同步问题?Spring是否做到了每个线程持有独立的一份ApplicationContext,或者说我通过实现ApplicationContextAware而获得的ApplicationContext是否经过了ThreadLocal的封装优化?
java并发多线程 关于final和Volatile 的问题
@Immutable class OneValueCache { private final BigInteger lastNumber; private final BigInteger[] lastFactors; /** * 如果在构造函数中没有使用 Arrays.copyOf()方法,那么域内不可变对象 lastFactors却能被域外代码改变 * 那么 OneValueCache 就不是不可变的。 */ public OneValueCache(BigInteger i, BigInteger[] factors) { lastNumber = i; lastFactors = Arrays.copyOf(factors, factors.length); } public BigInteger[] getFactors(BigInteger i) { if (lastNumber == null || !lastNumber.equals(i)) return null; else return Arrays.copyOf(lastFactors, lastFactors.length); } } @ThreadSafe public class VolatileCachedFactorizer implements Servlet { private volatile OneValueCache cache = new OneValueCache(null, null); public void service(ServletRequest req, ServletResponse resp) { BigInteger i = extractFromRequest(req); BigInteger[] factors = cache.getFactors(i); if (factors == null) { factors = factor(i); cache = new OneValueCache(i, factors);//声明为 volatile ,防止指令重排序,保证可见性 } encodeIntoResponse(resp, factors); } } 上面两段程序是在java并发编程中看到的。没有看明白为什么必须使用final和Volatile 这两个关键字才可以保证不使用锁他也是安全的。 能不能有大神能够说一下,假如不使用final,只使用Volatile 他会发生的不安全情况,与都使用了这两个关键字的对比。 谢谢了。万分感谢,看了一晚上。 下面就是我对两个关键字的理解: Volatile 就是本地内存不存这个变量,直接在主内存中就行读写 final修饰变量就是这个变量是不可改变的,如果是引用类型就表示一直会引用初始化那个地址的数据,如果是基本类型,就是不能修改这个类型的值 如果不正确请指证一下
12306火车票的大并发的选票,怎样处理线程安全的呀??
大侠们!javaWeb项目负载均衡部署后,在多线程下怎样防止 数据库 中的某一数据 发生‘’丢失更新‘’ 就是 某一线程的数据,覆盖了前面已更新的数据的。 就是说,在12306火车票的大并发的选票过程中,怎样防止,前面的用户,选中的车票数据,不被后面的覆盖呀??
一个关于单例和线程的问题
Spring的bean 默认是单例的 也就是说每次请求获取的bean都是同一个, 验证hashCode也确实是相等的. ``` @Autowired private TestBean testBean; @RequestMapping("test1.html") public @ResponseBody String test1() throws InterruptedException { testBean.test(); return "123"; } ``` ``` public class TestBean { public void test() throws InterruptedException { System.out.println("begin sleep..............................."); System.out.println(this.hashCode()); Thread.sleep(5000); System.out.println("end sleep..............................."); } } ``` 进行一个简单的验证. 用浏览器打开两个标签前后访问. begin sleep............................... 1445493050 end sleep............................... begin sleep............................... 1445493050 end sleep............................... 结果是这样的, 后访问的会等待第一个请求执行完成, 睡眠结束才进入. 但是如果就开一个标签, 一个劲儿的点刷新, 结果又成了这样. begin sleep............................... 1445493050 begin sleep............................... 1445493050 begin sleep............................... 1445493050 begin sleep............................... 1445493050 end sleep............................... end sleep............................... end sleep............................... end sleep............................... 一直点刷新, 之后的请求居然没有等到之前的请求睡眠结束, 就进入了. 这是何解? 为啥两种方式测试结果不同? 且第二种结果给人的感觉是同一个对象可以被多个线程同时使用? 如果是可以, 那单例就并不是线程安全的了? 单例对象里的值如果在访问过程中会发生改变, 在访问结束后会还原. 那么A/B两条线程同时访问, 不就会出现异常了么? 因为不是独占的? -------------------------------------------------------- 测试有误, 分两个浏览器来访问的时候, 就是和连续刷新效果一样了. 也就是说确认多线程可以同时访问同一个对象了.
学习Java多线程和集合,关于集合的同步问题,请教版上高手!
学习Java其实好久了,需要的时候也能写出个可以跑得程序,但是对其中很多机制没有仔细研究过。最近觉得该深入学习一下,于是抱着Java Core I 开始看了。 前段时间看了Java集合,目前学的是多线程。发现多线程里确实有很多东西值得好好研究。首先同步就是一个不小的问题。今天主要对集合的同步问题进行了一下小小的测试,出现了几个我自己没弄明白的问题,希望版上高手给予解答。 多线程的同步主要是对多个线程共享一个资源时的访问控制,避免出现“乱套”现象。Java提供多种机制进行同步控制,比如锁和条件对象,synchronized关键字等。而集合经常作为这种资源被多个线程共享,而且集合框架中本身也对多线程同步进行过考虑,比如有Vector,HashTable等类。于是自己写了个简单的程序,进行下测试,到底哪种方法能有效控制集合在多线程并发中的同步。 设置非常简单的一个场景,有一个Student集合,对该集合采用迭代器进行遍历之后,又对其添加了一个元素。由于添加元素是改变集合结构的操作,所以集合如果在迭代器构造之后发生改变,就会抛出ConcurrentModificationException异常。 Student类代码,很简单: [code=Java] class Student{ public Student(String name, int age){ this.name = name; this.age = age; } String name; int age; public String toString(){ return "I am "+name+" , "+age+" years old."; } } [/code] 1. 创建一个修改Collection的线程,实现Runnable接口。不采取任何同步措施。 [code=Java] class ModifyCollectionTask implements Runnable{ public ModifyCollectionTask(Collection<Student> slist){ this.slist = slist; } public void run(){ // 遍历学生列表, for(Student s : slist){ System.out.println(Thread.currentThread().getName()); System.out.println(s); } // 向学生列表添加元素 slist.add(new Student("Katie", 30)); } Collection<Student> slist; } [/code] 在Main函数里启动100个线程, [code=Java] public class SyncCollection { public static void main(String[] args) { Collection<Student> slist = new ArrayList<Student>(); slist.add(new Student("AAA",10)); slist.add(new Student("BBB",12)); slist.add(new Student("CCC",14)); slist.add(new Student("DDD",16)); slist.add(new Student("EEE",18)); for(int i=0;i<100;i++){ new Thread(new ModifyCollectionTask(slist)).start(); } } [/code] 很明显,没有同步控制,那么很快就抛出了ConcurrentModificationException异常 2. 由于Vector类是线程安全的动态数组,所以,将集合实现改为Vector,在线程run方法中没做任何修改 [code=Java] // 使用Vector List<Student> sVector = new Vector<Student>(); sVector.add(new Student("AAA",10)); sVector.add(new Student("BBB",12)); sVector.add(new Student("CCC",14)); sVector.add(new Student("DDD",16)); sVector.add(new Student("EEE",18)); for(int i=0;i<100;i++){ new Thread(new ModifyCollectionTask(sVector)).start(); } [/code] 结果还是发生了ConcurrentModificationException异常。这让我有点怀疑Vector的同步机制。 3. 使用Collections工具类中的同步包装方法,将线程不安全ArrayList进行包装,而线程实现方法没有改动 [code=Java] // 使用Collections工具类中的同步包装器 List<Student> slist2 = Collections.synchronizedList(new ArrayList<Student>()); slist2.add(new Student("AAA",10)); slist2.add(new Student("BBB",12)); slist2.add(new Student("CCC",14)); slist2.add(new Student("DDD",16)); slist2.add(new Student("EEE",18)); for(int i=0;i<100;i++){ new Thread(new ModifyCollectionTask(slist2)).start(); } [/code] 结果还是发生了异常,不明白。。。 4. 下面使用synchronized关键字进行同步控制,对线程实现代码进行了修改 [code=Java] class syncModifyListTask implements Runnable{ public syncModifyListTask(Collection<Student> slist){ this.slist = slist; } public void run(){ synchronized(slist){ // 遍历学生列表 for(Student s : slist){ System.out.println(Thread.currentThread().getName()); System.out.println(s); } // 向学生列表添加元素 slist.add(new Student("Katie", 30)); } } Collection<Student> slist; } [/code] 由于有了synchronized关键字对代码片段进行了保护,所以没有出现异常 5. 使用java.util.concurrent包中的高效的同步集合, ConcurrentLinkedQueue,线程实现代码还是用ModifyCollectionTask [code=Java] Collection<Student> concurrentCollection = new ConcurrentLinkedQueue<Student>(); concurrentCollection.add(new Student("AAA",10)); concurrentCollection.add(new Student("BBB",12)); concurrentCollection.add(new Student("CCC",14)); concurrentCollection.add(new Student("DDD",16)); concurrentCollection.add(new Student("EEE",18)); for(int i=0;i<100;i++){ new Thread(new ModifyCollectionTask(concurrentCollection)).start(); } [/code] 结果也没有出现异常,证明高效的同步集合还是很给力的! 将上述的各种集合同步方法进行一遍测试之后,发现Vector和Collections中的同步包装方法都不能保证同步,我就很纳闷儿,是我的使用方法出现了问题,还是这两种集合同步本身就做的不好? 希望版上的高手给予解答,谢谢!!!
GetLastError的使用安全么
我不是很清楚错误码是线程私有的还是整个操作系统共享的,所以提出此问题,经常看到很多人用GetLastError来获取前一个语句可能出现错误时的错误码来决定后续的操作步骤,但我想知道,如果在发生错误和调用GetLastError中间被其它线程或者进程给改变了错误码,那岂不是得不到真正的错误原因?
函数多线安全性问题,大家帮我看看
#include <stdio.h> #include <windows.h> DWORD WINAPI ThreadProc( LPVOID lpParameter); int main (void) { for (BYTE i=0;i<5;i++) { DWORD IDThread=0; HANDLE hThread=CreateThread(NULL,NULL,ThreadProc,(LPVOID)i,NULL,&IDThread); if (hThread) CloseHandle(hThread); } getchar(); return 0; } DWORD WINAPI ThreadProc( LPVOID lpParameter) { for (BYTE i=0;i<10;i++) { printf("%d---%d---%d---%d\n",lpParameter,lpParameter,lpParameter,lpParameter); Sleep(1); } return true; } /* CPU一次执行一行代码,在main函数中创建了4个线程,调用同一个函数。 在4个线程同时执行的时候,发生CPU时间片切换,在ThreadProc函数中执行的代码可能不一样 我的意思是线程1中的局部变量被改写,不会影响线程2中的局部变量。 那4个线程同时执行一个函数,那这个函数被拷贝到每个线程的内部去执行了?咋感觉理解起来很抽象 */
vue前端websocket连接不上springboot,报错Connection closed before receiving a handshake response
搞定了,我的代码写的基本没有问题,毕竟都是按着教程一步一步来的,主要问题在于,我的开发环境和教程不一致,我是前后端分离,请求8080即请求的前端项目,当然会超时然后建立连接失败。我查看了一下前后端各自的端口:前端8080,后端63000,然后把 ``` this.sock = new WebSocket("ws:localhost:8080/websocket");//建立连接 ``` 改成 ``` this.sock = new WebSocket("ws:localhost:63000/websocket");//建立连接 ``` 就可以了,换成后端的端口号。 --- 以下是原问题 --- 照着网上的教程写的例子,整合到自己的项目中。前端用vue写的,js里几乎和教程一模一样,主要问题在于 ``` this.sock = new WebSocket("ws:localhost:8080/websocket");//建立连接 ``` --- **创建的websocket内的方法都是null,如图:** ![图片说明](https://img-ask.csdn.net/upload/201909/24/1569293600_266157.png) --- **然后观察控制台内过了一段时间报错,提示:** ``` WebSocket connection to 'ws://localhost:8080/websocket' failed: Connection closed before receiving a handshake response ``` --- **控制台错误详情见图:** ![图片说明](https://img-ask.csdn.net/upload/201909/24/1569294057_247788.png) --- **前端代码:** ``` webSocket() { debugger; // 建立socket连接 if ('WebSocket' in window) {//判断当前浏览器是否支持webSocket // this.sock = new WebSocket("ws:localhost:8080/bootTest/websocket");//建立连接(带后端项目名) this.sock = new WebSocket("ws:localhost:8080/websocket");//建立连接(不带后端项目名) } else { alert('你的浏览器暂不支持websocket :('); } var sock = this.sock; console.log(sock); sock.onopen = function (e) {//成功建立连接 console.log(e); }; sock.onmessage = function (e) {//接收到消息 console.log(e) $(".message").append("<p><font color='red'>"+e.data+"</font>") }; sock.onerror = function (e) {//连接发生错误 console.log(e); }; sock.onclose = function (e) {//连接关闭 console.log(e); }; ////监听窗口关闭事件,当窗口关闭时,主动去关闭websocket连接,防止连接还没断开就关闭窗口,server端会抛异常。 window.onbeforeunload = function(){ websocket.close(); }; } ``` --- --- --- --- 后端代码: ``` import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import javax.websocket.*; import lombok.extern.slf4j.Slf4j; @Slf4j @ServerEndpoint("/websocket") public class WebSocketServer { //静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。 private static int onlineCount = 0; //concurrent包的线程安全Set,用来存放每个客户端对应的MyWebSocket对象。 private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>(); //与某个客户端的连接会话,需要通过它来给客户端发送数据 private Session session; /** * 连接建立成功调用的方法*/ @OnOpen public void onOpen(Session session) { this.session = session; webSocketSet.add(this); //加入set中 addOnlineCount(); //在线数加1 log.info("有新连接加入!当前在线人数为" + getOnlineCount()); try { sendMessage("连接成功"); } catch (IOException e) { log.error("websocket IO异常"); } } // //连接打开时执行 // @OnOpen // public void onOpen(@PathParam("user") String user, Session session) { // currentUser = user; // System.out.println("Connected ... " + session.getId()); // } /** * 连接关闭调用的方法 */ @OnClose public void onClose() { webSocketSet.remove(this); //从set中删除 subOnlineCount(); //在线数减1 log.info("有一连接关闭!当前在线人数为" + getOnlineCount()); } /** * 收到客户端消息后调用的方法 * @param message 客户端发送过来的消息 */ @OnMessage public void onMessage(String message, Session session) { log.info("来自客户端的消息:" + message); //群发消息 for (WebSocketServer item : webSocketSet) { try { item.sendMessage(message); } catch (IOException e) { e.printStackTrace(); } } } /** * 发生错误 * @param session * @param error */ @OnError public void onError(Session session, Throwable error) { log.error("发生错误"); error.printStackTrace(); } public void sendMessage(String message) throws IOException { this.session.getBasicRemote().sendText(message); } /** * 群发自定义消息 * */ public static void sendInfo(String message) throws IOException { log.info(message); for (WebSocketServer item : webSocketSet) { try { item.sendMessage(message); } catch (IOException e) { continue; } } } public static synchronized int getOnlineCount() { return onlineCount; } public static synchronized void addOnlineCount() { WebSocketServer.onlineCount++; } public static synchronized void subOnlineCount() { WebSocketServer.onlineCount--; } } ```
websocket频繁发送大数据。
springboot项目,使用websocket持续给前端(vue)发送数据。但是会经常中断,不发数据了,记录在线人数的功能正常,如果有新的登录或者登出,后台正常显示。就是不发数据了,需要重启项目才会发数据。 ``` package com.smart.common.utils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import javax.websocket.*; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet; /** * @Description: websocket工具类, * flag表示身份标识: * bigScreen:大屏 * backSys:后台系统 */ @ServerEndpoint("/websocket/{flag}") @Component public class WebSocketUtils { private Logger logger = LoggerFactory.getLogger(getClass()); public static final String BIGSCREEN = "bigScreen"; //大屏 public static final String BACKSYS = "backSys"; //后台 //静态变量,用来记录当前在线连接数 private static int onlineCount = 0; //concurrent包的线程安全Set,用来存放每个客户端对应的MyWebSocket对象。 private static CopyOnWriteArraySet<WebSocketUtils> webSocketSet = new CopyOnWriteArraySet<>(); //与某个客户端的连接会话,需要通过它来给客户端发送数据 private Session session; /** * 身份标识 */ private String flag; /** * 连接建立成功调用的方法 * @param session 可选的参数。session为与某个客户端的连接会话,需要通过它来给客户端发送数据 */ @OnOpen public void onOpen(@PathParam("flag") String flag, Session session){ this.session = session; this.flag = flag; webSocketSet.add(this); addOnlineCount(); //在线数加1 logger.info("有新连接加入!当前在线人数为" + getOnlineCount()+",上线用户为:"+this.flag); } /** * 连接关闭调用的方法 */ @OnClose public void onClose(){ webSocketSet.remove(this); subOnlineCount(); //在线数减1 logger.info("有一连接关闭!当前在线人数为" + getOnlineCount()+",下线用户为:"+this.flag); } /** * 收到客户端消息后调用的方法 * @param message 客户端发送过来的消息 * @param session 可选的参数 */ @OnMessage public void onMessage(String message, Session session) { //解析message if(message==null){ session.getAsyncRemote().sendText("发送的消息不能为空"); }else{ } } /** * 发生错误时调用 * @param session * @param error */ @OnError public void onError(Session session, Throwable error){ logger.info("发生错误:"+error.getMessage()); error.printStackTrace(); } /** * 群发消息 * @param message * @throws IOException */ public void sendMessageToFlag(String message){ for (WebSocketUtils ws : webSocketSet){ try{ ws.sendMessage(message); }catch (Exception e){ logger.error("sendMessageToFlag: "+e.toString()); } } } /** * 给指定身份发送消息 * @param message * @param flag * @throws IOException */ public void sendMessageToFlag(String message,String flag){ try{ boolean online = true; for (WebSocketUtils ws : webSocketSet){ if (flag.equals(ws.flag)){ ws.sendMessage(message); online = false; } } if (online){ logger.info(flag+"不在线"); } }catch (Exception e){ logger.error("sendMessageToFlag: "+e.toString()); } } public boolean isonline(){ boolean online = false; for (WebSocketUtils ws : webSocketSet){ if (BIGSCREEN.equals(ws.flag)){ online = true; } } return online; } public void sendMessageToBigScreen(String message){ sendMessageToFlag(message,BIGSCREEN); } public void snedMessage2BackSys(String message){ sendMessageToFlag(message,BACKSYS); } /** * 服务器主动推送消息到客户端 * @param message * @throws IOException */ private void sendMessage(String message) throws IOException { synchronized(this.session){ this.session.getBasicRemote().sendText(message); } System.out.println("发送数据给:"+this.flag+":"+message); } private static synchronized int getOnlineCount() { return onlineCount; } private static synchronized void addOnlineCount() { WebSocketUtils.onlineCount++; } private static synchronized void subOnlineCount() { WebSocketUtils.onlineCount--; } } ```
大学四年自学走来,这些私藏的实用工具/学习网站我贡献出来了
大学四年,看课本是不可能一直看课本的了,对于学习,特别是自学,善于搜索网上的一些资源来辅助,还是非常有必要的,下面我就把这几年私藏的各种资源,网站贡献出来给你们。主要有:电子书搜索、实用工具、在线视频学习网站、非视频学习网站、软件下载、面试/求职必备网站。 注意:文中提到的所有资源,文末我都给你整理好了,你们只管拿去,如果觉得不错,转发、分享就是最大的支持了。 一、电子书搜索 对于大部分程序员...
在中国程序员是青春饭吗?
今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...
《MySQL 性能优化》之理解 MySQL 体系结构
本文介绍 MySQL 的体系结构,包括物理结构、逻辑结构以及插件式存储引擎。
python自动下载图片
近日闲来无事,总有一种无形的力量萦绕在朕身边,让朕精神涣散,昏昏欲睡。 可是,像朕这么有职业操守的社畜怎么能在上班期间睡瞌睡呢,我不禁陷入了沉思。。。。 突然旁边的IOS同事问:‘嘿,兄弟,我发现一个网站的图片很有意思啊,能不能帮我保存下来提升我的开发灵感?’ 作为一个坚强的社畜怎么能说自己不行呢,当时朕就不假思索的答应:‘oh, It’s simple. Wait for me for a ...
一名大专同学的四个问题
【前言】   收到一封来信,赶上各种事情拖了几日,利用今天要放下工作的时机,做个回复。   2020年到了,就以这一封信,作为开年标志吧。 【正文】   您好,我是一名现在有很多困惑的大二学生。有一些问题想要向您请教。   先说一下我的基本情况,高考失利,不想复读,来到广州一所大专读计算机应用技术专业。学校是偏艺术类的,计算机专业没有实验室更不用说工作室了。而且学校的学风也不好。但我很想在计算机领...
复习一周,京东+百度一面,不小心都拿了Offer
京东和百度一面都问了啥,面试官百般刁难,可惜我全会。
达摩院十大科技趋势发布:2020 非同小可!
【CSDN编者按】1月2日,阿里巴巴发布《达摩院2020十大科技趋势》,十大科技趋势分别是:人工智能从感知智能向认知智能演进;计算存储一体化突破AI算力瓶颈;工业互联网的超融合;机器间大规模协作成为可能;模块化降低芯片设计门槛;规模化生产级区块链应用将走入大众;量子计算进入攻坚期;新材料推动半导体器件革新;保护数据隐私的AI技术将加速落地;云成为IT技术创新的中心 。 新的画卷,正在徐徐展开。...
轻松搭建基于 SpringBoot + Vue 的 Web 商城应用
首先介绍下在本文出现的几个比较重要的概念: 函数计算(Function Compute): 函数计算是一个事件驱动的服务,通过函数计算,用户无需管理服务器等运行情况,只需编写代码并上传。函数计算准备计算资源,并以弹性伸缩的方式运行用户代码,而用户只需根据实际代码运行所消耗的资源进行付费。Fun: Fun 是一个用于支持 Serverless 应用部署的工具,能帮助您便捷地管理函数计算、API ...
Python+OpenCV实时图像处理
目录 1、导入库文件 2、设计GUI 3、调用摄像头 4、实时图像处理 4.1、阈值二值化 4.2、边缘检测 4.3、轮廓检测 4.4、高斯滤波 4.5、色彩转换 4.6、调节对比度 5、退出系统 初学OpenCV图像处理的小伙伴肯定对什么高斯函数、滤波处理、阈值二值化等特性非常头疼,这里给各位分享一个小项目,可通过摄像头实时动态查看各类图像处理的特点,也可对各位调参、测试...
2020年一线城市程序员工资大调查
人才需求 一线城市共发布岗位38115个,招聘120827人。 其中 beijing 22805 guangzhou 25081 shanghai 39614 shenzhen 33327 工资分布 2020年中国一线城市程序员的平均工资为16285元,工资中位数为14583元,其中95%的人的工资位于5000到20000元之间。 和往年数据比较: yea...
为什么猝死的都是程序员,基本上不见产品经理猝死呢?
相信大家时不时听到程序员猝死的消息,但是基本上听不到产品经理猝死的消息,这是为什么呢? 我们先百度搜一下:程序员猝死,出现将近700多万条搜索结果: 搜索一下:产品经理猝死,只有400万条的搜索结果,从搜索结果数量上来看,程序员猝死的搜索结果就比产品经理猝死的搜索结果高了一倍,而且从下图可以看到,首页里面的五条搜索结果,其实只有两条才是符合条件。 所以程序员猝死的概率真的比产品经理大,并不是错...
害怕面试被问HashMap?这一篇就搞定了!
声明:本文以jdk1.8为主! 搞定HashMap 作为一个Java从业者,面试的时候肯定会被问到过HashMap,因为对于HashMap来说,可以说是Java集合中的精髓了,如果你觉得自己对它掌握的还不够好,我想今天这篇文章会非常适合你,至少,看了今天这篇文章,以后不怕面试被问HashMap了 其实在我学习HashMap的过程中,我个人觉得HashMap还是挺复杂的,如果真的想把它搞得明明白...
毕业5年,我问遍了身边的大佬,总结了他们的学习方法
我问了身边10个大佬,总结了他们的学习方法,原来成功都是有迹可循的。
python爬取百部电影数据,我分析出了一个残酷的真相
2019年就这么匆匆过去了,就在前几天国家电影局发布了2019年中国电影市场数据,数据显示去年总票房为642.66亿元,同比增长5.4%;国产电影总票房411.75亿元,同比增长8.65%,市场占比 64.07%;城市院线观影人次17.27亿,同比增长0.64%。 看上去似乎是一片大好对不对?不过作为一名严谨求实的数据分析师,我从官方数据中看出了一点端倪:国产票房增幅都已经高达8.65%了,为什...
推荐10个堪称神器的学习网站
每天都会收到很多读者的私信,问我:“二哥,有什么推荐的学习网站吗?最近很浮躁,手头的一些网站都看烦了,想看看二哥这里有什么新鲜货。” 今天一早做了个恶梦,梦到被老板辞退了。虽然说在我们公司,只有我辞退老板的份,没有老板辞退我这一说,但是还是被吓得 4 点多都起来了。(主要是因为我掌握着公司所有的核心源码,哈哈哈) 既然 4 点多起来,就得好好利用起来。于是我就挑选了 10 个堪称神器的学习网站,推...
这些软件太强了,Windows必装!尤其程序员!
Windows可谓是大多数人的生产力工具,集娱乐办公于一体,虽然在程序员这个群体中都说苹果是信仰,但是大部分不都是从Windows过来的,而且现在依然有很多的程序员用Windows。 所以,今天我就把我私藏的Windows必装的软件分享给大家,如果有一个你没有用过甚至没有听过,那你就赚了????,这可都是提升你幸福感的高效率生产力工具哦! 走起!???? NO、1 ScreenToGif 屏幕,摄像头和白板...
阿里面试,面试官没想到一个ArrayList,我都能跟他扯半小时
我是真的没想到,面试官会这样问我ArrayList。
曾经优秀的人,怎么就突然不优秀了。
职场上有很多辛酸事,很多合伙人出局的故事,很多技术骨干被裁员的故事。说来模板都类似,曾经是名校毕业,曾经是优秀员工,曾经被领导表扬,曾经业绩突出,然而突然有一天,因为种种原因,被裁员了,...
大学四年因为知道了这32个网站,我成了别人眼中的大神!
依稀记得,毕业那天,我们导员发给我毕业证的时候对我说“你可是咱们系的风云人物啊”,哎呀,别提当时多开心啦????,嗯,我们导员是所有导员中最帅的一个,真的???? 不过,导员说的是实话,很多人都叫我大神的,为啥,因为我知道这32个网站啊,你说强不强????,这次是绝对的干货,看好啦,走起来! PS:每个网站都是学计算机混互联网必须知道的,真的牛杯,我就不过多介绍了,大家自行探索,觉得没用的,尽管留言吐槽吧???? 社...
良心推荐,我珍藏的一些Chrome插件
上次搬家的时候,发了一个朋友圈,附带的照片中不小心暴露了自己的 Chrome 浏览器插件之多,于是就有小伙伴评论说分享一下我觉得还不错的浏览器插件。 我下面就把我日常工作和学习中经常用到的一些 Chrome 浏览器插件分享给大家,随便一个都能提高你的“生活品质”和工作效率。 Markdown Here Markdown Here 可以让你更愉快的写邮件,由于支持 Markdown 直接转电子邮...
看完这篇HTTP,跟面试官扯皮就没问题了
我是一名程序员,我的主要编程语言是 Java,我更是一名 Web 开发人员,所以我必须要了解 HTTP,所以本篇文章就来带你从 HTTP 入门到进阶,看完让你有一种恍然大悟、醍醐灌顶的感觉。 最初在有网络之前,我们的电脑都是单机的,单机系统是孤立的,我还记得 05 年前那会儿家里有个电脑,想打电脑游戏还得两个人在一个电脑上玩儿,及其不方便。我就想为什么家里人不让上网,我的同学 xxx 家里有网,每...
史上最全的IDEA快捷键总结
现在Idea成了主流开发工具,这篇博客对其使用的快捷键做了总结,希望对大家的开发工作有所帮助。
C++(数据结构与算法):62---搜索树(二叉搜索树、索引二叉搜索树)
一、搜索树的复杂度分析 本文考察二叉搜索树和索引二叉搜索树 二叉搜索树的渐进性能可以和跳表媲美: 查找、插入、删除操作所需的平均时间为Θ(logn) 查找、插入、删除操作的最坏情况的时间为Θ(n) 元素按升序输出时所需时间为Θ(n) 虽然在最坏情况下的查找、插入、删除操作,散列表和二叉搜索树的时间性能相同,但是散列表在最好的情况下具有超级性能Θ(1) 不过,对于一个指定的关键...
阿里程序员写了一个新手都写不出的低级bug,被骂惨了。
这种新手都不会范的错,居然被一个工作好几年的小伙子写出来,差点被当场开除了。
谁是华为扫地僧?
是的,华为也有扫地僧!2020年2月11-12日,“养在深闺人不知”的华为2012实验室扫地僧们,将在华为开发者大会2020(Cloud)上,和大家见面。到时,你可以和扫地僧们,吃一个洋...
AI 没让人类失业,搞 AI 的人先失业了
最近和几个 AI 领域的大佬闲聊 根据他们讲的消息和段子 改编出下面这个故事 如有雷同 都是巧合 1. 老王创业失败,被限制高消费 “这里写我跑路的消息实在太夸张了。” 王葱葱哼笑一下,把消息分享给群里。 阿杰也看了消息,笑了笑。在座几位也都笑了。 王葱葱是个有名的人物,21岁那年以全额奖学金进入 KMU 攻读人工智能博士,累计发表论文 40 余篇,个人技术博客更是成为深度学习领域内风向标。 ...
2020年,冯唐49岁:我给20、30岁IT职场年轻人的建议
点击“技术领导力”关注∆每天早上8:30推送 作者|Mr.K 编辑| Emma 来源|技术领导力(ID:jishulingdaoli) 前天的推文《冯唐:职场人35岁以后,方法论比经验重要》,收到了不少读者的反馈,觉得挺受启发。其实,冯唐写了不少关于职场方面的文章,都挺不错的。可惜大家只记住了“春风十里不如你”、“如何避免成为油腻腻的中年人”等不那么正经的文章。 本文整理了冯...
最全最强!世界大学计算机专业排名总结!
我正在参与CSDN200进20,希望得到您的支持,扫码续投票5次。感谢您! (为表示感谢,您投票后私信我,我把我总结的人工智能手推笔记和思维导图发送给您,感谢!) 目录 泰晤士高等教育世界大学排名 QS 世界大学排名 US News 世界大学排名 世界大学学术排名(Academic Ranking of World Universities) 泰晤士高等教育世界大学排名 中国共...
作为一名大学生,如何在B站上快乐的学习?
B站是个宝,谁用谁知道???? 作为一名大学生,你必须掌握的一项能力就是自学能力,很多看起来很牛X的人,你可以了解下,人家私底下一定是花大量的时间自学的,你可能会说,我也想学习啊,可是嘞,该学习啥嘞,不怕告诉你,互联网时代,最不缺的就是学习资源,最宝贵的是啥? 你可能会说是时间,不,不是时间,而是你的注意力,懂了吧! 那么,你说学习资源多,我咋不知道,那今天我就告诉你一个你必须知道的学习的地方,人称...
那些年,我们信了课本里的那些鬼话
教材永远都是有错误的,从小学到大学,我们不断的学习了很多错误知识。 斑羚飞渡 在我们学习的很多小学课文里,有很多是错误文章,或者说是假课文。像《斑羚飞渡》: 随着镰刀头羊的那声吼叫,整个斑羚群迅速分成两拨,老年斑羚为一拨,年轻斑羚为一拨。 就在这时,我看见,从那拨老斑羚里走出一只公斑羚来。公斑羚朝那拨年轻斑羚示意性地咩了一声,一只半大的斑羚应声走了出来。一老一少走到伤心崖,后退了几步,突...
立即提问