如何在angular2中创建计时器

Question

我需要一个 Angular 2 中的计时器，它会在一段时间后滴答作响并执行一些任务（可能会调用一些函数）。

如何用 Angular 2 做到这一点？

Answer 1

除了之前所有的答案，我会使用 RxJS Observables 来做

请查看Observable.timer

这是一个示例代码，将在 2 秒后启动，然后每秒滴答一次：

import {Component} from 'angular2/core';
import {Observable} from 'rxjs/Rx';

@Component({
    selector: 'my-app',
    template: 'Ticks (every second) : {{ticks}}'
})
export class AppComponent {
  ticks =0;
  ngOnInit(){
    let timer = Observable.timer(2000,1000);
    timer.subscribe(t=>this.ticks = t);
  }
}

这是一个有效的plunker

更新 如果要调用在 AppComponent 类上声明的函数，可以执行以下操作之一：

** 假设你要调用的函数名为func，

ngOnInit(){
    let timer = Observable.timer(2000,1000);
    timer.subscribe(this.func);
}

上述方法的问题在于，如果你在 func 中调用 'this'，它将引用订阅者对象而不是 AppComponent 对象，这可能不是你想要的。

但是，在下面的方法中，您创建一个 lambda 表达式并在其中调用函数 func。这样，对 func 的调用仍然在 AppComponent 的范围内。在我看来，这是最好的方法。

ngOnInit(){
    let timer = Observable.timer(2000,1000);
    timer.subscribe(t=> {
        this.func(t);
    });
}

检查this plunker 的工作代码。

Answer 2

另一种解决方案是使用 TimerObservable

TimerObservable 是 Observable 的子类。

import {Component, OnInit, OnDestroy} from '@angular/core';
import {Subscription} from "rxjs";
import {TimerObservable} from "rxjs/observable/TimerObservable";

@Component({
  selector: 'app-component',
  template: '{{tick}}',
})
export class Component implements OnInit, OnDestroy {

  private tick: string;
  private subscription: Subscription;

  constructor() {
  }

  ngOnInit() {
    let timer = TimerObservable.create(2000, 1000);
    this.subscription = timer.subscribe(t => {
      this.tick = t;
    });
  }

  ngOnDestroy() {
    this.subscription.unsubscribe();
  }
}

P.S.：别忘了取消订阅。

Answer 3

import {Component, View, OnInit, OnDestroy} from "angular2/core";

import { Observable, Subscription } from 'rxjs/Rx';

@Component({

})
export class NewContactComponent implements OnInit, OnDestroy {

    ticks = 0;
    private timer;
    // Subscription object
    private sub: Subscription;


    ngOnInit() {
        this.timer = Observable.timer(2000,5000);
        // subscribing to a observable returns a subscription object
        this.sub = this.timer.subscribe(t => this.tickerFunc(t));
    }
    tickerFunc(tick){
        console.log(this);
        this.ticks = tick
    }

    ngOnDestroy(){
        console.log("Destroy timer");
        // unsubscribe here
        this.sub.unsubscribe();

    }


}

Answer 4

使用 rxjs 6.2.2 和 Angular 6.1.7，我得到了：

Observable.timer is not a function

错误。通过将Observable.timer 替换为timer 解决了这个问题：

import { timer, Subscription } from 'rxjs';

private myTimerSub: Subscription;    

ngOnInit(){    
    const ti = timer(2000,1000);    
    this.myTimerSub = ti.subscribe(t => {    
        console.log("Tick");    
    });    
}    

ngOnDestroy() {    
    this.myTimerSub.unsubscribe();    
}

Answer 5

您可以简单地使用 setInterval 实用程序并使用箭头函数作为回调，以便this 将指向组件实例。

例如：

this.interval = setInterval( () => { 
    // call your functions like 
    this.getList();
    this.updateInfo();
});

在您的 ngOnDestroy 生命周期挂钩中，清除间隔。

ngOnDestroy(){
    clearInterval(this.interval);
}

Answer 6

我遇到了一个问题，我必须使用计时器，但我必须在 2 个组件中同时显示它们，相同的屏幕。我在服务中创建了 timerObservable。我在两个组件中都订阅了计时器，发生了什么？它不会被同步，因为新订阅总是会创建自己的流。

我想说的是，如果您打算在多个地方使用一个计时器，请始终输入.publishReplay(1).refCount() 在 Observer 的末尾，因为它每次都会从中发布相同的流。

例子：

this.startDateTimer = Observable.combineLatest(this.timer, this.startDate$, (localTimer, startDate) => {
  return this.calculateTime(startDate);
}).publishReplay(1).refCount();

Answer 7

找到了一个 npm 包，它通过 RxJS 即服务轻松实现。

https://www.npmjs.com/package/ng2-simple-timer

您可以“订阅”现有的计时器，这样如果您在同一个组件中多次使用它，就不会创建大量计时器。

Answer 8

如果你想在 ngOnInit 上运行一个方法，你可以这样做：

从 RXJS 导入这 2 个库：

import {Observable} from 'rxjs/Rx';
import {Subscription} from "rxjs";

然后声明定时器和私有订阅，例子：

timer= Observable.timer(1000,1000); // 1 second for 2 seconds (2000,1000) etc
private subscription: Subscription;

计时器停止时最后但并非最不重要的运行方法

ngOnInit() {
  this.subscription = this.timer.subscribe(ticks=> {
    this.populatecombobox();  //example calling a method that populates a combobox
    this.subscription.unsubscribe();  //you need to unsubscribe or it will run infinite times
  });
}

就是这样，Angular 5

Answer 9

设置定时器并在一定时间后自动呼叫服务

 // Initialize from ngInit
    ngOnInit(): void {this.getNotifications();}
    
    getNotifications() {
        setInterval(() => {this.getNewNotifications();
        }, 60000);  // 60000 milliseconds interval 
    }
    getNewNotifications() {
        this.notifyService.getNewNotifications().subscribe(
            data => { // call back },
            error => { },
        );
    }

Answer 10

在最新版本的 Angular 上（我在 12.2.* 上工作）不支持 Observable.timer。您可以在 @Abdulrahman Alsoghayer 示例中稍作改动来使用它。

import {Component} from '@angular/core';
import {timer} from 'rxjs';

@Component({
    selector: 'my-app',
    template: 'Ticks (every second) : {{ticks}}'
})
export class AppComponent {
  ticks =0;
  ngOnInit(){
    let timer$ = timer(2000,1000);
    timer$.subscribe(t=>this.ticks = t);
  }
}