кэширование результатов с помощью службы http angular2 [дубликат]
этот вопрос уже есть ответ здесь:
Я предоставляю запрос HTTP GET через службу, и несколько компонентов используют эти данные (сведения о профиле пользователя). Я хотел бы, чтобы первый запрос компонента фактически выполните запрос HTTP GET на сервер и кэшируйте результаты, чтобы последующие запросы использовали кэшированные данные вместо повторного вызова сервера.
вот пример для службы, как бы вы рекомендовали реализовать этот слой кэша с Angular2 и typescript.
import {Inject, Injectable} from 'angular2/core';
import {Http, Headers} from "angular2/http";
import {JsonHeaders} from "./BaseHeaders";
import {ProfileDetails} from "../models/profileDetails";
@Injectable()
export class ProfileService{
myProfileDetails: ProfileDetails = null;
constructor(private http:Http) {
}
getUserProfile(userId:number) {
return this.http.get('/users/' + userId + '/profile/', {
headers: headers
})
.map(response => {
if(response.status==400) {
return "FAILURE";
} else if(response.status == 200) {
this.myProfileDetails = new ProfileDetails(response.json());
return this.myProfileDetails;
}
});
}
}
3 ответа:
Что касается вашего последнего комментария, это самый простой способ я могу думать : создать службу, которая будет иметь одно свойство, и это свойство будет содержать запрос.
class Service { _data; get data() { return this._data; } set data(value) { this._data = value; } }
вот так просто. Все остальное в plnkr бы нетронутой. Я удалил запрос из службы, потому что он будет создан автоматически (мы не делаем
new Service...
и я не знаю простой способ передать параметр в конструктор).Итак, теперь у нас есть сервис, то, что мы делаем сейчас, это сделать заявку на нашем компонента и присвоить его переменной обслуживание
data
class App { constructor(http: Http, svc: Service) { // Some dynamic id let someDynamicId = 2; // Use the dynamic id in the request svc.data = http.get('http://someUrl/someId/'+someDynamicId).share(); // Subscribe to the result svc.data.subscribe((result) => { /* Do something with the result */ }); } }
помните, что наш экземпляр службы является одним и тем же для каждого компонента, поэтому, когда мы присваиваем значение
data
это будет отражено в каждом элементе.здесь plnkr С рабочим примером.
ссылка
The share () оператор работает только по первому запросу, когда все подписки обслуживаются и вы создаете еще один, то он не будет работать, он сделает еще один запрос. (этот случай довольно распространен, так как для Angular2 SPA вы всегда создаете/уничтожаете компоненты)
я использовал ReplaySubject сохранить значение из тега http наблюдаема. Элемент ReplaySubject observable может служить Предыдущее значение к своему подписчик.
сервис:@Injectable() export class DataService { private dataObs$ = new ReplaySubject(1); constructor(private http: HttpClient) { } getData(forceRefresh?: boolean) { // If the Subject was NOT subscribed before OR if forceRefresh is requested if (!this.dataObs$.observers.length || forceRefresh) { this.http.get('http://jsonplaceholder.typicode.com/posts/2').subscribe( data => this.dataObs$.next(data), error => { this.dataObs$.error(error); // Recreate the Observable as after Error we cannot emit data anymore this.dataObs$ = new ReplaySubject(1); } ); } return this.dataObs$; } }
компонент:
@Component({ selector: 'my-app', template: `<div (click)="getData()">getData from AppComponent</div>` }) export class AppComponent { constructor(private dataService: DataService) {} getData() { this.dataService.getData().subscribe( requestData => { console.log('ChildComponent', requestData); }, // handle the error, otherwise will break the Observable error => console.log(error) ); } } }
полностью рабочая PLUNKER
(обратите внимание на консоль и вкладку Сеть)
Я опустил
userId
работа. Для этого потребуется управлять массивомdata
и массивobservable
(по одному для каждого запрошенного ).import {Injectable} from '@angular/core'; import {Http, Headers} from '@angular/http'; import {Observable} from 'rxjs/Observable'; import 'rxjs/observable/of'; import 'rxjs/add/operator/share'; import 'rxjs/add/operator/map'; import {Data} from './data'; @Injectable() export class DataService { private url:string = 'https://cors-test.appspot.com/test'; private data: Data; private observable: Observable<any>; constructor(private http:Http) {} getData() { if(this.data) { // if `data` is available just return it as `Observable` return Observable.of(this.data); } else if(this.observable) { // if `this.observable` is set then the request is in progress // return the `Observable` for the ongoing request return this.observable; } else { // example header (not necessary) let headers = new Headers(); headers.append('Content-Type', 'application/json'); // create the request, store the `Observable` for subsequent subscribers this.observable = this.http.get(this.url, { headers: headers }) .map(response => { // when the cached data is available we don't need the `Observable` reference anymore this.observable = null; if(response.status == 400) { return "FAILURE"; } else if(response.status == 200) { this.data = new Data(response.json()); return this.data; } // make it shared so more than one subscriber can get the result }) .share(); return this.observable; } } }
вы можете найти другое интересное решение на https://stackoverflow.com/a/36296015/217408