node.js - Nestjs 中的 Observables - 异步读取文件
问题描述
我正在尝试异步读取 json 文件并将其作为响应(作为 rxjs 可观察数据)发送出去的用例。这是我使用的服务
import { logger } from './../../shared/utils/logger';
import { Injectable } from '@nestjs/common';
import * as fs from 'fs';
import * as path from 'path';
import { BehaviorSubject, Observable, pipe, of, from, throwError, merge} from 'rxjs';
import { map, filter, scan, take, debounce, switchMap, retry, catchError, mergeMap, delay, zip, tap, mapTo } from 'rxjs/operators';
import { HttpResponseModel } from '../model/config.model';
import { isNullOrUndefined } from 'util';
@Injectable()
export class NewProviderService {
serviceSubject: BehaviorSubject<HttpResponseModel[]>;
filePath: string;
httpResponseObjectArray: HttpResponseModel[];
constructor() {
this.serviceSubject = new BehaviorSubject<HttpResponseModel[]>([]);
this.filePath = path.resolve(__dirname, './../../shared/assets/httpTest.json');
this.setSubject();
}
readFileFromJSON() {
this.readFileFromJsonSync();
fs.exists(this.filePath.toString(), exists => {
if (exists) {
fs.readFile(this.filePath.toString(), 'utf-8', (err, data) => {
logger.info('file read without parsin', data);
this.httpResponseObjectArray = JSON.parse(data).HttpTestResponse;
logger.info('array obj is:', this.httpResponseObjectArray);
logger.info('file read after parsing', JSON.parse(data));
return this.httpResponseObjectArray;
});
} else {
return null;
}
});
}
getObservable(): Observable<HttpResponseModel[]> {
// create an observable
// return Observable.create(observer => {
// observer.next(this.readFileFromJSON());
// });
return of(this.readFileFromJsonSync()).pipe(map(data => {
logger.info('inside obs methid', data);
return data;
}));
}
setSubject() {
this.getObservable().subscribe(data => {
logger.info('data before setting in sub', data);
this.serviceSubject.next(data);
});
}
}
所以我想在控制器中订阅这个发出的 observable,但是在我订阅并阅读了主题(BehaviorSubject
)之后,这些值会被读取。我知道我在订阅和发送数据方面做错了,但不明白我在哪里做错了。每次控制器打印'data subscribed undefined'然后继续读取文件并发出 observable
这是控制器数据
@Get('/getJsonData')
public async getJsonData(@Req() requestAnimationFrame, @Res() res) {
this.newService.serviceSubject.subscribe(data => {
logger.info('data subscribed', data);
res.status(HttpStatus.OK).send(data);
});
}
如果我同步读取文件效果很好
替换readFileFromJSON()
为以下方法,效果很好
readFileFromJsonSync(): HttpResponseModel[] {
const objRead = JSON.parse(fs.readFileSync(this.filePath.toString(), {encoding: 'utf-8'}));
logger.info('object read is', objRead.HttpTestResponse);
return objRead.HttpTestResponse;
}
所以我在异步读取文件时遗漏了一些东西。我不确定我做错了什么。有人可以帮忙吗?
解决方案
问题是您实际上并没有在readFileFromJSON
. 它将异步运行fs.exists
和fs.readFile
相应的回调,但回调的结果被忽略。
你应该Promises
改用。您可以Promise
自己创建一个库,也可以使用 bluebird 之类的库,fs
从基于回调的 API 转换为Promise
基于 API 的 API。有关详细信息,请参阅此线程。
return new Promise(function(resolve, reject) {
fs.readFile(this.filePath.toString(), 'utf-8', (err, data) => {
if (err) {
reject(err);
} else {
const httpResponseObjectArray = JSON.parse(data).HttpTestResponse;
resolve(httpResponseObjectArray);
}
});
});
推荐阅读
- angular - 同时测试 Angular 库,包括库组件和示例应用程序
- apache - 如何在支持 SSL 的 Amazon EC2 单实例上托管多个网站?
- react-native - 在标签离开时对本机标签重置做出反应
- c# - 我已经使用了参数,但我很难用多用户登录
- asp.net-mvc - 如果我的基本控制器具有处理 dbcontext 的覆盖 void Dispose(),我是否需要在子控制器中处理它?
- c# - 如果 admob 广告未加载统一如何加载自定义横幅广告
- android - 我可以使用普通视图作为小部件吗?
- ios - 来自json的tableview部分
- polymer - 准备就绪时聚合物 3 中的淡入过渡
- c++ - 将应用程序与包含另一个库的库链接