你是否需要取消订阅 Angular 2 的 HTTP 请求以防止内存泄漏？
fetchFilm(index) {
var sub = this._http.get(`http://example.com`)
.map(result => result.json())
.map(json => {
dispatch(this.receiveFilm(json));
})
.subscribe(e=>sub.unsubscribe());
...
Ng2会自动清理它。
complete()。这意味着它实际上在完成时取消订阅。所以您不需要自己这样做。 fetchFilms() {
return (dispatch) => {
dispatch(this.requestFilms());
let observer = this._http.get(`${BASE_URL}`)
.map(result => result.json())
.map(json => {
dispatch(this.receiveFilms(json.results));
dispatch(this.receiveNumberOfFilms(json.count));
console.log("2 isUnsubscribed",observer.isUnsubscribed);
window.setTimeout(() => {
console.log("3 isUnsubscribed",observer.isUnsubscribed);
},10);
})
.subscribe();
console.log("1 isUnsubscribed",observer.isUnsubscribed);
};
}
因此，由于Ng2自动取消订阅，不会存在任何泄漏！
值得一提的是：这个Observable被归类为有限，与无限的Observable相反，后者是可以像DOM click监听器一样无限地发出数据流。
感谢@rubyboy的帮助。
好的，有两个理由可以取消订阅任何可观察对象。但很少有人谈论到非常重要的第二个原因！
- 清理资源。正如其他人所说，这对于HTTP可观察对象来说是一个微不足道的问题。它只会自己清理。
- 防止运行
subscribe处理程序。
请注意，对于HTTP可观察对象，在取消订阅时，它将为您取消浏览器中的底层请求（您将在网络面板中看到“已取消”以红色显示）。这意味着不会浪费时间下载或解析响应。但那实际上是我的下面主要观点的一件小事。
第二个原因的相关性将取决于您的subscribe处理程序的操作：
如果您的subscribe()处理程序函数具有任何不需要的副作用，那么当调用它的任何内容关闭或处置时，您必须取消订阅（或添加条件逻辑），以防止其被执行。
考虑一些情况：
一个登录表单。您输入用户名和密码，然后点击“登录”。如果服务器很慢，您决定按Esc关闭对话框怎么办？您可能会认为您没有登录，但是如果http请求在您按下Esc后返回，那么您仍将执行其中的任何逻辑。这可能导致重定向到帐户页面，设置不想要的登录cookie或令牌变量。这可能不是您的用户预期的结果。
一个“发送电子邮件”表单。
如果“sendEmail”的subscribe处理程序执行类似于触发“您的电子邮件已发送”动画、将您转移到另一页或尝试访问任何已被处理的内容，则可能会出现异常或意外行为。
此外，要小心不要假设unsubscribe()的意思是“取消”。一旦HTTP消息正在传输中，unsubscribe()将无法取消已经到达您的服务器的HTTP请求。它只会取消返回给您的响应。而邮件可能仍然会被发送。
如果您在UI组件内直接创建订阅以发送电子邮件，则可能需要在处理完毕时取消订阅，但如果电子邮件是由非UI集中式服务发送的，则可能不需要。
onDestroy()中取消订阅。后果轻重取决于你在 subscribe 处理程序中所做的事情。如果您尝试更新不再存在的内容，则可能会出现错误。
有时您可能会希望在组件被处理时执行某些操作，有些则不需要。例如，也许您为已发送电子邮件设置了“嗖”声音。即使组件已关闭，您可能仍想播放此声音，但如果您尝试在组件上运行动画，它将失败。在这种情况下，在 subscribe 中添加一些额外条件逻辑是解决方案 - 您不需要取消订阅 http 观察者。
因此，实际答案是，不需要取消订阅以避免内存泄漏。但是，您需要（经常）这样做以避免由运行可能引发异常或破坏应用程序状态的代码触发不需要的副作用。
提示：Subscription 包含一个 closed 布尔属性，在高级情况下可能会有用。对于 HTTP 来说，当它完成时，这个值将被设置。在 Angular 中，对于某些情况，将 _isDestroyed 属性设置在 ngDestroy 中可能非常有用，它可以在 subscribe 处理程序中进行检查。提示2: 如果要处理多个订阅，您可以创建一个临时的new Subscription()对象，并将任何其他订阅add(...) 到它上面-这样当您从主订阅中取消订阅时，它也会取消订阅所有添加的订阅。
必须要取消订阅，如果您希望在所有网络速度下都获得确定性的行为。
想象一下，组件A被呈现在选项卡中——您单击按钮发送一个“GET”请求。响应需要200毫秒才能返回。所以您可以随时安全地关闭选项卡，知道机器比您更快，HTTP响应已经被处理并且在选项卡关闭后组件A已经销毁了。
那么，在网络很慢的情况下怎么办呢？您单击按钮，'GET'请求花费10秒钟才能收到它的响应，但是5秒钟后你决定关闭选项卡。这将会销毁组件A并在以后被垃圾回收。等一下！我们没有取消订阅——现在 5秒钟后，响应返回，已销毁组件中的逻辑将被执行。该执行现在被认为是上下文外的，可能导致许多问题，包括非常低的性能和数据/状态损坏。
因此，最佳实践是在组件被销毁时使用takeUntil()并取消订阅HTTP呼叫订阅。
注意：
async管道会自动在销毁时取消订阅no-op调用import { Component, OnInit, OnDestroy } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Subject } from 'rxjs';
import { takeUntil } from 'rxjs/operators';
interface User {
id: string;
name: string;
age: number;
}
@Component({
selector: 'app-foobar',
templateUrl: './foobar.component.html',
styleUrls: ['./foobar.component.scss'],
})
export class FoobarComponent implements OnInit, OnDestroy {
private user: User = null;
private destroy$ = new Subject();
constructor(private http: HttpClient) {}
ngOnInit() {
this.http
.get<User>('api/user/id')
.pipe(takeUntil(this.destroy$))
.subscribe(user => {
this.user = user;
});
}
ngOnDestroy(): void {
this.destroy$.next(); // trigger the unsubscribe
this.destroy$.complete(); // finalize & clean up the subject stream
}
}
ngOnDestroy() 中，使用 BehaviorSubject() 并仅调用 complete() 是否可行？ - Saksham.ts 文件中每次看到 .subscribe()，请确保有一个明确的取消订阅。即使使用了 take(n)、first() 等方法也要如此。单个“上下文不清”的执行可能会导致专家团队困惑数周！ - Avid Coder经过一段时间的测试、阅读文档和HttpClient源代码。
HttpClient:https://github.com/angular/angular/blob/master/packages/common/http/src/client.ts
HttpXhrBackend :https://github.com/angular/angular/blob/master/packages/common/http/src/xhr.ts
HttpClientModule:https://indepth.dev/exploring-the-httpclientmodule-in-angular/
Angular University:https://blog.angular-university.io/angular-http/
这种类型的Observables是单值流：如果HTTP请求成功，这些Observables将仅发出一个值，然后完成
而整个“我需要”取消订阅的问题的答案取决于你的回调函数中的逻辑。
这要看情况。 Http调用内存泄漏不是一个问题。 问题在于回调函数中的逻辑。
例如：路由或登录。
如果您的调用是一个登录调用，则不需要“取消订阅”，但您需要确保如果用户离开页面，则在缺乏用户时正确处理响应。
this.authorisationService
.authorize(data.username, data.password)
.subscribe((res: HttpResponse<object>) => {
this.handleLoginResponse(res);
},
(error: HttpErrorResponse) => {
this.messageService.error('Authentication failed');
},
() => {
this.messageService.info('Login has completed');
})
从烦人到危险
现在想象一下，网络比平常慢，通话需要长达5秒钟，用户离开登录视图并进入“支持视图”。
组件可能没有激活，但订阅仍在进行中。如果有响应，用户将会突然重定向（取决于您的handleResponse()实现）。
这是不好的。
还要想象一下，用户离开电脑，认为他还没有登录。但是您的逻辑已经将用户登录，现在您面临安全问题。
在不取消订阅的情况下，您可以做什么？
使您的调用依赖于视图的当前状态：
public isActive = false;
public ngOnInit(): void {
this.isActive = true;
}
public ngOnDestroy(): void {
this.isActive = false;
}
使用.pipe(takeWhile(value => this.isActive))，以确保只有在视图处于活动状态时才处理响应。
this.authorisationService
.authorize(data.username, data.password).pipe(takeWhile(value => this.isActive))
.subscribe((res: HttpResponse<object>) => {
this.handleLoginResponse(res);
},
(error: HttpErrorResponse) => {
this.messageService.error('Authentication failed');
},
() => {
this.messageService.info('Login has completed');
})
但是你如何确定订阅不会导致内存泄漏？
您可以记录是否应用了“teardownLogic”。
当订阅为空或取消订阅时，将调用订阅的teardownLogic。
this.authorisationService
.authorize(data.username, data.password).pipe(takeWhile(value => this.isActive))
.subscribe((res: HttpResponse<object>) => {
this.handleLoginResponse(res);
},
(error: HttpErrorResponse) => {
this.messageService.error('Authentication failed');
},
() => {
this.messageService.info('Login has completed');
}).add(() => {
// this is the teardown function
// will be called in the end
this.messageService.info('Teardown');
});
调用unsubscribe方法相当于取消正在进行的HTTP请求，因为该方法在底层XHR对象上调用abort方法并删除负载和错误事件的侦听器：
// From the XHRConnection class
return () => {
_xhr.removeEventListener('load', onLoad);
_xhr.removeEventListener('error', onError);
_xhr.abort();
};
话虽如此，unsubscribe会移除监听器...所以这可能是个好主意，但我不认为对于单个请求是必要的 ;-)
希望能帮到你， Thierry
y = x.subscribe((x)=>data = x); 然后用户更改输入和 x.subscribe((x)=>cachlist[n] = x); y.unsubscribe() 嘿，你使用了我们的服务器资源，我不会抛弃你.....而在另一种情况下：只需调用 y.stop() 把一切都扔掉。 - Hassan Faghihi新的HttpClient模块中，与原来相同的行为依然保持不变。
您一定要阅读这篇文章，它向您展示了为什么即使是http请求也应该始终取消订阅。
如果在从后端收到答案之前创建请求但销毁了组件，那么您的订阅将保留对组件的引用，从而导致可能会引起内存泄漏的机会。
更新
上述说法似乎是正确的，但无论如何，在收到答案时，http订阅都会被销毁。
在自动完成的可观察对象（例如 Http 调用）中，您不应该取消订阅。但是对于无限可观察对象，如 Observable.timer()，则需要取消订阅。