激动人心的 Angular HttpClient的源码解析

angular 版本已经发布????。在这个版本中，我们等到了一个令人兴奋的新功能 - httpclient api 的改进版本，以后妈妈再也不用担心我处理 http 请求了????。

httpclient 是已有 angular http api 的演进，它在一个单独的 @angular/common/http 包中。这是为了确保现有的代码库可以缓慢迁移到新的 api。

接下来让我们开启 angular 新版http client 之旅。

安装

首先，我们需要更新所有的包到 4.3.0-rc.0 版本。然后，我们需要在 appmodule 中导入 httpclientmodule 模块。具体如下：

import { httpclientmodule } from '@angular/common/http';
@ngmodule({
 declarations: [
  appcomponent
 ],
 imports: [
  browsermodule,
  httpclientmodule
 ],
 bootstrap: [appcomponent]
})
export class appmodule { }

现在一切准备就绪。让我们来体验一下我们一直期待的三个新特性。

特性一 默认 json 解析

现在 json 是默认的数据格式，我们不需要再进行显式的解析。即我们不需要再使用以下代码：

http.get(url).map(res => res.json()).subscribe(...)

现在我们可以这样写：

http.get(url).subscribe(...)

特性二 支持拦截器 (interceptors)

拦截器允许我们将中间件逻辑插入管线中。

请求拦截器 (request interceptor)

import {
 httprequest,
 httphandler,
 httpevent
} from '@angular/common/http';

@injectable()
class jwtinterceptor implements httpinterceptor {
 
 constructor(private userservice: userservice) {}
 
 intercept(req: httprequest<any>, next: httphandler): observable<httpevent<any>> {

  const jwt = `bearer ${this.userservice.gettoken()}`;
  req = req.clone({
   setheaders: {
    authorization: jwt
   }
  });
  return next.handle(req);
 }
}

如果我们想要注册新的拦截器 (interceptor)，我们需要实现 httpinterceptor 接口，然后实现该接口中的 intercept 方法。

export interface httpinterceptor {
 intercept(req: httprequest<any>, next: httphandler): observable<httpevent<any>>;
}

需要注意的是，请求对象和响应对象必须是不可修改的 (immutable)。因此，我们在返回请求对象前，我们需要克隆原始的请求对象。

next.handle(req) 方法使用新的请求对象，调用底层的 xhr 对象，并返回响应事件流。

响应拦截器 (response interceptor)

@injectable()
class jwtinterceptor implements httpinterceptor {

 constructor(private router: router) {}
 
 intercept(req: httprequest < any > ,
  next: httphandler): observable < httpevent < any >> {

  return next.handle(req).map(event => {
    if (event instanceof httpresponse) {
     if (event.status === 401) {
      // jwt expired, go to login
     }
    }
    return event;
   }
  }
}

响应拦截器可以通过在 next.handle(req) 返回的流对象 (即 observable 对象) 上应用附加的 rx 操作符来转换响应事件流对象。

接下来要应用 jwtinterceptor 响应拦截器的最后一件事是注册该拦截器，即使用 http_interceptors 作为 token，注册 multi provider：

[{ provide: http_interceptors, useclass: jwtinterceptor, multi: true }]

特性三 进度事件 (progress events)

进度事件可以用于跟踪文件上传和下载。

import {
 httpeventtype,
 httpclient,
 httprequest
} from '@angular/common/http';

http.request(new httprequest(
 'post',
  url,
  body, 
 {
  reportprogress: true
 })).subscribe(event => {

 if (event.type === httpeventtype.downloadprogress) {
  // {
  // loaded:11, // number of bytes uploaded or downloaded.
  // total :11 // total number of bytes to upload or download
  // }
 }

 if (event.type === httpeventtype.uploadprogress) {
  // {
  // loaded:11, // number of bytes uploaded or downloaded.
  // total :11 // total number of bytes to upload or download
  // }
 }

 if (event.type === httpeventtype.response) {
  console.log(event.body);
 }
})

如果我们想要跟踪文件上传或下载的进度，在创建请求对象时，我们需要配置 {reportprogress: true} 参数。

此外在回调函数中，我们通过 event.type 来判断不同的事件类型，从进行相应的事件处理。

httpeventtype 枚举定义如下：

export enum httpeventtype {
 /**
  * 表示请求已经被发送
  */
 sent,

 /**
  * 已接收到上传进度事件
  */
 uploadprogress,

 /**
  * 已接收到响应状态码和响应头
  */
 responseheader,

 /**
  * 已接收到下载进度事件
  */
 downloadprogress,

 /**
  * 已接收全部响应，包含响应体 
  */
 response,

 /**
  * 用户自定义事件，来自拦截器或后端
  */
 user,
}

其实除了上面介绍三个新的功能之外，还有以下两个新的功能：

1. 基于 angular 内部测试框架的 post-request verification 和 flush 功能
2. 类型化，同步响应体访问，包括对 json 响应体类型的支持。

最后我们来通过 client_spec.ts 文件中的测试用例，来进一步感受一下上述的新特性。

其它特性

发送 get 请求

describe('httpclient', () => {
  let client: httpclient = null !;
  let backend: httpclienttestingbackend = null !;
  beforeeach(() => {
   backend = new httpclienttestingbackend();
   client = new httpclient(backend);
  });
  aftereach(() => { backend.verify(); }); // 请求验证
 
  describe('makes a basic request', () => {
   it('for json data', (done: donefn) => {
    client.get('/test').subscribe(res => {
     expect((res as any)['data']).toequal('hello world');
     done();
    });
    backend.expectone('/test').flush({'data': 'hello world'});
   });
   
   it('for an arraybuffer', (done: donefn) => {
    const body = new arraybuffer(4);
    // 还支持 {responsetype: 'text'}、{responsetype: 'blob'}
    client.get('/test', {responsetype: 'arraybuffer'}).subscribe(res => {
     expect(res).tobe(body);
     done();
    });
    backend.expectone('/test').flush(body);
   });
   
   it('that returns a response', (done: donefn) => {
    const body = {'data': 'hello world'};
    client.get('/test', {observe: 'response'}).subscribe(res => {
     expect(res instanceof httpresponse).tobe(true);
     expect(res.body).tobe(body);
     done();
    });
    backend.expectone('/test').flush(body);
   });
  });
});

发送 post 请求

describe('makes a post request', () => {
   it('with text data', (done: donefn) => {
    client.post('/test', 'text body', {observe: 'response', responsetype: 'text'})
      .subscribe(res => {
       expect(res.ok).tobetruthy();
       expect(res.status).tobe(200);
       done();
      });
    backend.expectone('/test').flush('hello world');
   });
 
   it('with json data', (done: donefn) => {
    const body = {data: 'json body'};
    client.post('/test', body, {observe: 'response', 
     responsetype: 'text'}).subscribe(res => {
     expect(res.ok).tobetruthy();
     expect(res.status).tobe(200);
     done();
    });
    const testreq = backend.expectone('/test');
    expect(testreq.request.body).tobe(body);
    testreq.flush('hello world');
   });
});

发送 jsonp 请求

describe('makes a jsonp request', () => {
   it('with properly set method and callback', (done: donefn) => {
    client.jsonp('/test', 'mycallback').subscribe(() => done());
    backend.expectone({method: 'jsonp', url: '/test?mycallback=jsonp_callback'})
      .flush('hello world');
   });
});

参考资源

a taste from the new angular http client

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。