Java线程监听,意外退出线程后自动重启的实现方法

Java线程监听，意外退出线程后自动重启

前一天写了一个微博爬行程序，主要工作原理就是每隔2分钟爬行一次微博，获取某N个关注朋友微博数量，然后将其保存起来，2分钟之后再次爬行，再取 其微博数量，与2分钟前保存的微博数量比较，如果数量增加，说明该好友在此2分钟之内发布微博，如果数量减少，则是删除微博。最后将爬行结果发送到指定手机上，作为通知！

今天看微博时发现自己关注的朋友发布了微博，然而自己手机却没有收到报警消息，查看爬行日志发现，在凌晨6点钟时，公司网络曾经断网，导致网络堵 塞，程序在爬行的时候抛出网络异常UnknownHostException，此时线程就已经死掉，猝死。为解决此问题，现有如下需求：线程死掉之后会自动重启。

常规解决办法有2种：

1，开启另外一个线程，监听爬行线程，使用线程之间的通信，一般是消费者模式，如果爬行线程死掉之后，监听线程会收到通知，但是如果监听线程先死掉，那么系统也就挂了！

2，使用心跳机制，爬行线程每隔一段时间往另一服务器进程发送数据包，如果服务器进程长时间没有收到心跳包，则说明爬行线程已经死机！

两种方法都有合适的使用范围，但是对于监听线程猝死这种情况，个人觉得是使用观察者模式比较合适！现说明一下观察者模式。

观察者模式：定义对象之间的一种一对多的依赖关系，当对象的状态发生改变时，所有依赖于它的对象都得到通知并且被自动更新。

观察者模式在JDK中有现成的实现，java.util.Obserable，如何进行监听线程，请看例子：

被监听的线程类：

package cn.std.test;

import java.util.Observable;

import cn.std.util.DateUtil;

public class RunThread extends Observableimplements Runnable{

  // 此方法一经调用，立马可以通知观察者，在本例中是监听线程

  publicvoid doBusiness(){

    if(true){

      super.setChanged();

    }

    notifyObservers();

  }

  @Override

  publicvoid run() {

    intc = 0;

    while(true){  //模拟线程运行一段时间之后退出

      System.out.println("Runing- "+c+" "+DateUtil.getStdDateTime());

      try{

        Thread.sleep(2000);

      }catch (InterruptedException e) {

        e.printStackTrace();

        doBusiness();

        break;

      }

      c++;

      //模拟抛出异常

      try{

        if(c== 4){

          Stringstr = null;

          str.length();//此处将会抛出空指针异常

        }

      }catch (Exception e) {

        e.printStackTrace();

        doBusiness();//在抛出异常时调用，通知观察者，让其重启线程

        break;//异常抛出之后，一定要跳出循环，保证将线程送进地狱

      }

    }  

  }

  publicstatic void main(String[] args) {

    RunThreadrun = new RunThread();

    Listener listen = new Listener();

    un.addObserver(listen);

    newThread(run).start();

    //run.doBusiness();

  }

}

被监听的线程需要继承Observable类，继承之后轻松变身为被观察者doBusiness方法，此处可以加上你的业务处理内容，接下来是Listener

package cn.std.test;

import java.util.Observable;

import java.util.Observer;

public class Listener implements Observer{

  @Override

  publicvoid update(Observable o, Object arg) {

    System.out.println("RunThread死机");

    RunThreadrun = new RunThread();

    run.addObserver(this);

    newThread(run).start();

    System.out.println("RunThread重启");

  }

}

很简单，只要实现Observer接口，实现其update方法，在方法内部重启线程

以上这篇Java线程监听,意外退出线程后自动重启的实现方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我们。

赞 (0)

相关推荐

  • java多线程编程之捕获子线程异常示例

    通过try catch是无法捕获子线程异常的,Thread对象提供了setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)方法用来获取线程中产生的异常. 复制代码 代码如下: package threads; import java.lang.Thread.UncaughtExceptionHandler; public class TextException{  public static void main(String

  • Java多线程之多线程异常捕捉

    Java多线程之多线程异常捕捉

    一:为什么要单独讲多线程的异常捕捉呢? 先看个例子: public class ThreadException implements Runnable{ @Override public void run() { throw new RuntimeException(); } //现象:控制台打印出异常信息,并运行一段时间后才停止 public static void main(String[] args){ //就算把线程的执行语句放到try-catch块中也无济于事 try{ Executo

  • Java线程中断的本质深入理解

    一.Java中断的现象 首先,看看Thread类里的几个方法: public static boolean interrupted 测试当前线程是否已经中断.线程的中断状态 由该方法清除.换句话说,如果连续两次调用该方法,则第二次调用将返回 false(在第一次调用已清除了其中断状态之后,且第二次调用检验完中断状态前,当前线程再次中断的情况除外). public boolean isInterrupted() 测试线程是否已经中断.线程的中断状态 不受该方法的影响. public void in

  • 详解Java多线程编程中线程的启动、中断或终止操作

    线程启动: 1.start() 和 run()的区别说明 start() : 它的作用是启动一个新线程,新线程会执行相应的run()方法.start()不能被重复调用. run() : run()就和普通的成员方法一样,可以被重复调用.单独调用run()的话,会在当前线程中执行run(),而并不会启动新线程! 下面以代码来进行说明. class MyThread extends Thread{ public void run(){ ... } }; MyThread mythread = new

  • 详解Java编程中线程的挂起、恢复和终止的方法

    有时,线程的挂起是很有用的.例如,一个独立的线程可以用来显示当日的时间.如果用户不希望用时钟,线程被挂起.在任何情形下,挂起线程是很简单的,一旦挂起,重新启动线程也是一件简单的事. 挂起,终止和恢复线程机制在Java 2和早期版本中有所不同.尽管你运用Java 2的途径编写代码,你仍需了解这些操作在早期Java环境下是如何完成的.例如,你也许需要更新或维护老的代码.你也需要了解为什么Java 2会有这样的变化.因为这些原因,下面内容描述了执行线程控制的原始方法,接着是Java 2的方法. Jav

  • Java线程监听,意外退出线程后自动重启的实现方法

    Java线程监听,意外退出线程后自动重启 前一天写了一个微博爬行程序,主要工作原理就是每隔2分钟爬行一次微博,获取某N个关注朋友微博数量,然后将其保存起来,2分钟之后再次爬行,再取 其微博数量,与2分钟前保存的微博数量比较,如果数量增加,说明该好友在此2分钟之内发布微博,如果数量减少,则是删除微博.最后将爬行结果发送到指定手机上,作为通知! 今天看微博时发现自己关注的朋友发布了微博,然而自己手机却没有收到报警消息,查看爬行日志发现,在凌晨6点钟时,公司网络曾经断网,导致网络堵 塞,程序在爬行的时

  • Java 异步线程监听与结果回调及异常捕获总结分析

    Java 异步线程监听与结果回调及异常捕获总结分析

    前言 工作中是否遇到这样的场景? 1.需要异步线程执行,而且需要获取到线程执行返回的结果. 2.如果执行过程异常,可以按照自定义方式消费异常信息. 如果只是单纯的使用Callable可以实现,本文提供更加优雅的工具类. Maven依赖 <dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.15</ver

  • Java实现监听文件变化的三种方案详解

    目录 背景 方案一:定时任务 + File#lastModified 方案二:WatchService 方案三:Apache Commons-IO 小结 背景 在研究规则引擎时,如果规则以文件的形式存储,那么就需要监听指定的目录或文件来感知规则是否变化,进而进行加载.当然,在其他业务场景下,比如想实现配置文件的动态加载.日志文件的监听.FTP文件变动监听等都会遇到类似的场景. 本文给大家提供三种解决方案,并分析其中的利弊,建议收藏,以备不时之需. 方案一:定时任务 + File#lastModi

  • Angularjs通过指令监听ng-repeat渲染完成后执行脚本的方法

    前言 在用AngularJS期间, 经常用到ng-repeat, 业务中有时需要在异步获取数据并用ng-repeat遍历渲染完页面后执行某个操作,angular本身并没有提供监听ng-repeat渲染完成的指令,所以需要自己动手写.有经验的同学都应该知道,在ng-repeat模板实例内部会暴露出一些特殊属性$index/$first/$middle/$last/$odd/$even,$index会随着每次遍历(从0开始)递增,当遍历到最后一个时,$last的值为true,so,通过判断$last

  • jQuery监听文件上传实现进度条效果的方法

    原理: 给XMLHttpRequest对象的upload属性绑定onprogress方法监听上传过程 var xhr=new XMLHttpRequest(); xhr.upload.onprogress=function(e){} 因为jQuery默认使用的XMLHttpRequest对象是内部生成的无法直接给jq的xhr绑定onprogress方法 所以只要给jQuery重新生成一个绑定了onprogress的XMLHttpRequest对象即可实现 首先封装一个方法 传入一个监听函数 返回

  • layui 监听select选择 获取当前select的ID名称方法

    监听select选择 form.on('select(filter)', function(data){ console.log(data.elem); //得到select原始DOM对象 console.log(data.value); //得到被选中的值 console.log(data.othis); //得到美化后的DOM对象 }); 获取自定义属性 data.elem.getAttribute("data-id") 例子:取得ID名称 form.on('select', fu

  • Vue监听事件实现计数点击依次增加的方法

    1.实现计数器功能,每点击一次按钮,count值增加一或增加二,鼠标在cordinates行移动时会更新当前坐标,通过自定义函数或者stop属性禁止事件传播. 效果如下: 代码如下: <!DOCTYPE html><html><head> <meta charset="utf-8"> <title>计数器自增函数</title> <script src="vue.js"></s

  • angular 实时监听input框value值的变化触发函数方法

    用angulajs + ionic 做了一个登陆页面.效果要通过监听输入框的变化来判断登陆按钮是否可点击.当至少一个输入框为空时登录按钮不可点击.一开始是用的jquery的方法做的,后来发现刷新当前页可以实现效果,但是当经过路由跳转后再回到登陆页后,方法就被执行了. 后来经过查找资料,利用angular.js的$watch方法解决了. 代码大概如下: $scope.input = {//初始化,避免ng-model绑定取不到值 Tel:'', Pwd:'' } $scope.$watch('in

  • JavaScript监听手机物理返回键的两种解决方法

    JavaScript没有监听物理返回键的API,所以只能使用 popstate 事件监听. 有两个解决办法: 1.返回到指定的页面 pushHistory(); window.addEventListener("popstate", function(e) { window.location = 'http://www.baidu.com'; }, false); function pushHistory() { var state = { title: "title&quo

  • layui监听下拉选框选中值变化的方法(包含监听普通下拉选框)

    因为本身layui是有一套自身的监听方式,form.on   当然你是先将select放入<div class="layui-form">中,不然都显示不出select 里面也有监听普通下拉选框选中值发生改变的方式,直接复制即可 <!doctype html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name=&qu

随机推荐