头部背景图片
zhaoyangkanshijie |
zhaoyangkanshijie |

2018-10-08

2018-10-08

pythonExample

爬虫

开发环境:python3+win8.1+pycharm

参考教程:

urllib

urllib用来获取url,抓取远程数据,进行保存。

参考教程:

  1. 直接用urllib.request模块的urlopen()获取页面,page的数据格式为bytes类型,需要decode()解码,转换成str类型。
1
2
3
4
from urllib import request
response = request.urlopen(r'http://python.org/')
page = response.read()
page = page.decode('utf-8')

urlopen返回对象提供方法:

  • read() , readline() ,readlines() , fileno() , close() :对HTTPResponse类型数据进行操作
  • info():返回HTTPMessage对象,表示远程服务器返回的头信息
  • getcode():返回Http状态码。如果是http请求,200请求成功完成;404网址未找到
  • geturl():返回请求的url
  1. 使用request()来包装请求,再通过urlopen()获取页面。
1
2
3
4
5
6
7
8
9
10
url = r'http://www.lagou.com/zhaopin/Python/?labelWords=label'
headers = {
'User-Agent': r'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
r'Chrome/45.0.2454.85 Safari/537.36 115Browser/6.0.3',
'Referer': r'http://www.lagou.com/zhaopin/Python/?labelWords=label',
'Connection': 'keep-alive'
}
req = request.Request(url, headers=headers)
page = request.urlopen(req).read()
page = page.decode('utf-8')

用来包装头部的数据:

  • User-Agent :这个头部可以携带如下几条信息:浏览器名和版本号、操作系统名和版本号、默认语言
  • Referer:可以用来防止盗链,有一些网站图片显示来源http://***.com,就是检查Referer来鉴定的
  • Connection:表示连接状态,记录Session的状态。
  1. urlopen()的data参数默认为None,当data参数不为空的时候,urlopen()提交方式为Post。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
from urllib import request, parse
url = r'http://www.lagou.com/jobs/positionAjax.json?'
headers = {
'User-Agent': r'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
r'Chrome/45.0.2454.85 Safari/537.36 115Browser/6.0.3',
'Referer': r'http://www.lagou.com/zhaopin/Python/?labelWords=label',
'Connection': 'keep-alive'
}
data = {
'first': 'true',
'pn': 1,
'kd': 'Python'
}
data = parse.urlencode(data).encode('utf-8')
req = request.Request(url, headers=headers, data=data)
page = request.urlopen(req).read()
page = page.decode('utf-8')

经过urlencode()转换后的data数据为?first=true?pn=1?kd=Python,最后提交的url为

http://www.lagou.com/jobs/positionAjax.json?first=true?pn=1?kd=Python

Post的数据必须是bytes或者iterable of bytes,不能是str,因此需要进行encode()编码

  1. 异常处理
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
def get_page(url):
headers = {
'User-Agent': r'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
r'Chrome/45.0.2454.85 Safari/537.36 115Browser/6.0.3',
'Referer': r'http://www.lagou.com/zhaopin/Python/?labelWords=label',
'Connection': 'keep-alive'
}
data = {
'first': 'true',
'pn': 1,
'kd': 'Python'
}
data = parse.urlencode(data).encode('utf-8')
req = request.Request(url, headers=headers)
try:
page = request.urlopen(req, data=data).read()
page = page.decode('utf-8')
except error.HTTPError as e:
print(e.code())
print(e.read().decode('utf-8'))
return page
  1. 使用代理

当需要抓取的网站设置了访问限制,这时就需要用到代理来抓取数据。

1
2
3
4
5
6
7
8
9
10
11
12
data = {
'first': 'true',
'pn': 1,
'kd': 'Python'
}
proxy = request.ProxyHandler({'http': '5.22.195.215:80'}) # 设置proxy
opener = request.build_opener(proxy) # 挂载opener
request.install_opener(opener) # 安装opener
data = parse.urlencode(data).encode('utf-8')
page = opener.open(url, data).read()
page = page.decode('utf-8')
return page
  1. Cookie的使用

爬取的网页涉及登录信息。访问每一个互联网页面,都是通过HTTP协议进行的,而HTTP协议是一个无状态协议,所谓的无状态协议即无法维持会话之间的状态。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
import urllib.request
import urllib.parse
import urllib.error
import http.cookiejar

url='http://bbs.chinaunix.net/member.php?mod=logging&action=login&loginsubmit=yes&loginhash=La2A2'
data={
'username':'zhanghao',
'password':'mima',
}
postdata=urllib.parse.urlencode(data).encode('utf8')
header={
'User-Agent':'Mozilla/5.0 (X11; Fedora; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36'
}

request=urllib.request.Request(url,postdata,headers=header)
#使用http.cookiejar.CookieJar()创建CookieJar对象
cjar=http.cookiejar.CookieJar()
#使用HTTPCookieProcessor创建cookie处理器,并以其为参数构建opener对象
cookie=urllib.request.HTTPCookieProcessor(cjar)
opener=urllib.request.build_opener(cookie)
#将opener安装为全局
urllib.request.install_opener(opener)

try:
reponse=urllib.request.urlopen(request)
except urllib.error.HTTPError as e:
print(e.code)
print(e.reason)

fhandle=open('./test1.html','wb')
fhandle.write(reponse.read())
fhandle.close()

url2='http://bbs.chinaunix.net/forum-327-1.html' #打开test2.html文件,会发现此时会保持我们的登录信息,为已登录状态。也就是说,对应的登录状态已经通过Cookie保存。
reponse2=urllib.request.urlopen(url)
fhandle2=open('./test2.html','wb')
fhandle2.write(reponse2.read())
fhandle2.close()

Beautiful Soup

Beautiful Soup是python的一个库,最主要的功能是从网页抓取数据。

参考教程:

  1. 安装
1
2
3
pip install beautifulsoup4
pip install lxml
pip install html5lib

Beautiful Soup支持Python标准库中的HTML解析器,还支持一些第三方的解析器,如果我们不安装它,则 Python 会使用 Python默认的解析器,lxml 解析器更加强大,速度更快,推荐安装。

解析器 使用方法 优势 劣势
Python标准库 BeautifulSoup(markup, “html.parser”) Python的内置标准库
执行速度适中
文档容错能力强
Python 2.7.3 or 3.2.2)前 的版本中文档容错能力差
lxml HTML 解析器 BeautifulSoup(markup, “lxml”) 速度快
文档容错能力强
需要安装C语言库
lxml XML 解析器 BeautifulSoup(markup, [“lxml”, “xml”])
BeautifulSoup(markup, “xml”)
速度快
唯一支持XML的解析器
需要安装C语言库
html5lib BeautifulSoup(markup, “html5lib”) 最好的容错性
以浏览器的方式解析文档
生成HTML5格式的文档
速度慢
  1. 应用实例
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
from bs4 import BeautifulSoup

# html字符串创建BeautifulSoup对象
soup = BeautifulSoup(html_doc, 'html.parser', from_encoding='utf-8')
# 或者打开本地文件
soup = BeautifulSoup(open('index.html'))
# 格式化输出
print soup.prettify()
#输出第一个 title 标签
print soup.title
#输出第一个 title 标签的标签名称
print soup.title.name
#输出第一个 title 标签的包含内容
print soup.title.string
#输出第一个 title 标签的父标签的标签名称
print soup.title.parent.name
#输出第一个 p 标签
print soup.p
#输出第一个 p 标签的 class 属性内容
print soup.p['class']
#输出第一个 a 标签的 href 属性内容
print soup.a['href']
# soup的属性可以被添加,删除或修改. 再说一次, soup的属性操作方法与字典一样
#修改第一个 a 标签的href属性为 http://www.baidu.com/
soup.a['href'] = 'http://www.baidu.com/'
#删除第一个 a 标签的 class 属性为
del soup.a['class']
##输出第一个 p 标签的所有子节点
print soup.p.contents
#输出第一个 a 标签
print soup.a
#输出所有的 a 标签,以列表形式显示
print soup.find_all('a')
#输出第一个 id 属性等于 link3 的 a 标签
print soup.find(id="link3")
#获取所有文字内容
print(soup.get_text())
#输出第一个 a 标签的所有属性信息
print soup.a.attrs
for link in soup.find_all('a'):
#获取 link 的 href 属性内容
print(link.get('href'))
#对soup.p的子节点进行循环输出
for child in soup.p.children:
print(child)
#正则匹配,名字中带有b的标签
for tag in soup.find_all(re.compile("b")):
print(tag.name)
  1. 详解
  • 四大对象种类:print type(soup.a)
  1. Tag 通过soup.标签名,获取含整个标签内容,通过soup.标签名.属性/attrs,获取属性数组
  2. NavigableString 通过soup.标签名.string,获取含标签内容文字
  3. BeautifulSoup 可以获取soup.name
  4. Comment 需要处理掉注释
    1
    2
    if type(soup.a.string)==bs4.element.Comment:
    print soup.a.string
  • 遍历文档树
  1. 直接子节点

Tag.Tag_child1:直接通过下标名称访问子节点。

Tag.contents:以列表形式返回所有子节点。

Tag.children:生成器,可用于循环访问:for child in Tag.children

  1. 所有子孙节点

    1
    2
    for child in soup.descendants:
    print child
  2. 父节点

Tag.parent:父节点

Tag.parents:父到根的所有节点

  1. 兄弟节点

Tag.next_sibling

Tag.next_siblings

Tag.previous_sibling

Tag.previous_siblings

  1. 前后节点

.next_element

.previous_element

.next_elements

.previous_elements

  1. 搜索文档树

find_all( name , attrs , recursive , text , **kwargs )

recursive=False,搜直接子孙节点,否则搜全部子孙节点

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import re # 正则搜索
for tag in soup.find_all(re.compile("^b")):
print(tag.name)
# 搜索列表
soup.find_all(["a", "b"])
# True 可以匹配任何值,下面代码查找到所有的tag,但是不会返回字符串节点
for tag in soup.find_all(True):
print(tag.name)
# 传方法
def has_class_but_no_id(tag):
return tag.has_attr('class') and not tag.has_attr('id')

soup.find_all(has_class_but_no_id)
# keyword 参数
soup.find_all(id='link2')
soup.find_all("a", class_="sister")
# text 参数
soup.find_all(text="Elsie")
soup.find_all(text=["Tillie", "Elsie", "Lacie"])
# limit 参数
soup.find_all("a", limit=2)
  1. CSS选择器搜索
    1
    2
    3
    4
    5
    # 所有css表达式,标签名、类名、id 名、组合、属性
    soup.select('表达式')
    #遍历
    for tag in soup.select('a'):
    print tag.get_text()

pyspider

一个国人编写的强大的网络爬虫系统并带有强大的WebUI。采用Python语言编写,分布式架构,支持多种数据库后端,强大的WebUI支持脚本编辑器,任务监视器,项目管理器以及结果查看器。

参考教程:

  1. 安装
    1
    2
    3
    pip install pyspider

    sudo apt-get install phantomjs

测试

1
pyspider all

然后浏览器访问 http://localhost:5000

  1. 具体使用

Python爬虫-pyspider框架的使用

Hello World

2018-10-08

Welcome to Hexo! This is your very first post. Check documentation for more info. If you get any problems when using Hexo, you can find the answer in troubleshooting or you can ask me on GitHub.

Quick Start

Create a new post

1
$ hexo new "My New Post"

More info: Writing

Run server

1
$ hexo server

More info: Server

Generate static files

1
$ hexo generate

More info: Generating

Deploy to remote sites

1
$ hexo deploy

More info: Deployment

2018-10-08

angular项目

参考教程

命令解析

  • 创建新项目:ng new {项目名}
  • 本地浏览:ng serve ,后面加上–open可自动打开浏览器
  • 生成服务器文件:ng build

    如果想看index.html,可删除里面的

    1
    <base href="/">
  • 生成组件:ng generate component {组件名} ,后面加上–inline-style,CLI 就会定义一个空的 styles 数组

  • 生成服务:ng generate service {服务名} ,后面加上–module=app让 CLI 自动把它提供给 AppModule
  • 生成模块:ng generate module {模块名}, 后面加上–flat会把这个文件放进了 src/app 中,而不是单独的目录中, 加上–module=app告诉 CLI 把它注册到 AppModule 的 imports 数组中。
  • 生成类:ng generate class {类名}
  • 生成指令:ng generate directive {名称}
  • 测试:ng test

知识点

项目架构

  • app –单页应用
    • 模块1
      • 子模块1
        • html –页面模板
        • css –样式
        • ts –数据和生命周期控制
          • @Component –声明组件
          • constructor –构造器,传入服务
          • @Input() –用于外部组件绑定
          • ngOnInit –生命周期:初始化,还有更多的生命周期事件
          • subscribe –订阅,异步获取服务observable数据,类似于jquery ajax的success
          • 其它自定义的方法和变量
      • 子模块2
      • 子模块3
    • 模块2
    • 模块3
    • 路由模块 –前端路由控制(后端不再路由)
      • forRoot(routes)和path –定义默认路由和常规路由,可使用通配符,如:/:id
    • 服务 –数据增删改与传递
      • @Injectable() –依赖注入
      • constructor –构造器,引入其它服务和模块,如$http
      • http.get(url) –get请求获取数据,也可用post,delete,put等
      • httpOptions –设置特殊头部HttpHeaders({ ‘Content-Type’: ‘application/json’ })
      • .pipe() –扩展 Observable 的结果,()内用操作符
        • catchError(function) –错误处理
        • tap() –该操作符会查看 Observable 中的值,使用那些值做一些事情,并且把它们传出来。 这种 tap 回调不会改变这些值本身
        • map() –对 Observable 的结果进行处理,相当于return
        • debounceTime(300) –在传出最终字符串之前,debounceTime(300) 将会等待,直到新增字符串的事件暂停了 300 毫秒
        • distinctUntilChanged() –确保只在过滤条件变化时才发送请求
        • switchMap() –为每个从 debounce 和 distinctUntilChanged 中通过的搜索词调用搜索服务。 它会取消并丢弃以前的搜索可观察对象,只保留最近的。
      • Observable.of(…) –返回observable对象
      • id=${id} –模板字符串字面量,生成可变字符串
      • 其它自定义的变量和方法,如错误处理函数和打印函数等

关于import

  1. import { Injectable } from ‘@angular/core’;
  2. import { HttpClient, HttpHeaders, HttpClientModule } from ‘@angular/common/http’;
  3. import { BrowserModule } from ‘@angular/platform-browser’;
  4. import { FormsModule,ReactiveFormsModule,FormControl, FormGroup, Validators } from ‘@angular/forms’;
  5. import { Observable} from ‘rxjs’;
  6. import { catchError, map, tap } from ‘rxjs/operators’;
  7. import { InMemoryDbService } from ‘angular-in-memory-web-api’;
  8. import { BrowserAnimationsModule } from ‘@angular/platform-browser/animations’;
  9. import { Directive, ElementRef } from ‘@angular/core’;
  10. import { Pipe, PipeTransform } from ‘@angular/core’;
  11. import { Component, EventEmitter, Input, Output } from ‘@angular/core’;
  12. import { AnimationEvent } from ‘@angular/animations’;
  13. import { animate, state, style, transition, trigger } from ‘@angular/animations’;
  14. import { NgModule } from ‘@angular/core’;
  15. import { Router, NavigationStart, ActivatedRoute, CanActivate, ActivatedRouteSnapshot, RouterStateSnapshot, CanActivateChild } from ‘@angular/router’;
  16. import { filter } from ‘rxjs/operators’;

语法基础

  1. 条件判断 *ngIf=”…”

    条件为真,则渲染下面内容

  2. 循环 *ngFor=”let i of/in is”

    for in遍历的是数组的索引(即键名),而for of遍历的是数组元素值。

    带索引:

    1
    <div *ngFor="let hero of heroes; let i=index">{{i + 1}} - {{hero.name}}</div>
  3. 数据双向绑定 [(ngModel)]=”…”

    需导入FormsModule,配合@Input()使用

  4. 点击事件 (click)=”…”

  5. a路由跳转 routerLink=”…”

  6. 模板引用变量 #var

    #phone 的意思就是声明一个名叫 phone 的变量来引用 \<input> 元素。

    1
    2
    <input #phone placeholder="phone number">
    <button (click)="callPhone(phone.value)">Call</button>

    优点:代替$event

    例子:获取用户输入

    $event:
    把整个 DOM 事件传到方法中,因为这样组件会知道太多模板的信息。 只有当它知道更多它本不应了解的 HTML 实现细节时,它才能提取信息。 这就违反了模板(用户看到的)和组件(应用如何处理用户数据)之间的分离关注原则。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    template: `
    <input (keyup)="onKey($event)">
    <p>{{values}}</p>
    `
    export class KeyUpComponent_v1 {
    values = '';


    onKey(event: KeyboardEvent) { // with type info
    this.values += (<HTMLInputElement>event.target).value + ' | ';
    }
    }

    #var

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    @Component({
    selector: 'app-key-up2',
    template: `
    <input #box (keyup)="onKey(box.value)">
    <p>{{values}}</p>
    `
    })
    export class KeyUpComponent_v2 {
    values = '';
    onKey(value: string) {
    this.values += value + ' | ';
    }
    }
  7. form 与 input

    (1) 事件:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    @Component({
    selector: 'app-key-up4',
    template: `
    <input #box
    (keyup.enter)="update(box.value)"
    (blur)="update(box.value)">

    <p>{{value}}</p>
    `
    })
    export class KeyUpComponent_v4 {
    value = '';
    update(value: string) { this.value = value; }
    }

    (2) 通过 ngModel 跟踪修改状态与有效性验证
    | 状态 | 为真时的 CSS 类 | 为假时的 CSS 类 |
    |————-|——————|—————–|
    |控件被访问过。 | ng-touched | ng-untouched |
    |控件的值变化了。| ng-dirty | ng-pristine |
    |控件的值有效。 | ng-valid | ng-invalid |

    查看以上类的方法:

    1
    2
    3
    4
    5
    <input type="text" class="form-control" id="name"
    required
    [(ngModel)]="model.name" name="name"
    #spy>
    <br>TODO: remove this: {{spy.className}}

    自定义css

    1
    2
    3
    4
    5
    6
    7
    .ng-valid[required], .ng-valid.required  {
    border-left: 5px solid #42A948; /* green */
    }

    .ng-invalid:not(form) {
    border-left: 5px solid #a94442; /* red */
    }

    显示和隐藏验证错误信息

    1
    2
    3
    4
    5
    6
    7
    8
    9
    <label for="name">Name</label>
    <input type="text" class="form-control" id="name"
    required
    [(ngModel)]="model.name" name="name"
    #name="ngModel">这里把 name 设置为 ngModel 是因为 ngModel 指令的 exportAs 属性设置成了 “ngModel”。
    <div [hidden]="name.valid || name.pristine"
    class="alert alert-danger">
    Name is required
    </div>

    (3) ngSubmit 提交表单

    1
    2
    <form (ngSubmit)="onSubmit()" #heroForm="ngForm">
    <button type="submit" class="btn btn-success" [disabled]="!heroForm.form.valid">Submit</button>

    (4) 表单验证

    • 模板驱动验证

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      <input id="name" name="name" class="form-control"
      required minlength="4" appForbiddenName="bob"
      [(ngModel)]="hero.name" #name="ngModel" >

      <div *ngIf="name.invalid && (name.dirty || name.touched)"
      class="alert alert-danger">对 dirty 和 touched 的检查可以避免在用户还没编辑表单就给他们显示错误提示。改变控件的值会改变控件的 dirty(脏)状态,而当控件失去焦点时,就会改变控件的 touched(碰过)状态。

      <div *ngIf="name.errors.required">
      Name is required.
      </div>
      <div *ngIf="name.errors.minlength">
      Name must be at least 4 characters long.
      </div>
      <div *ngIf="name.errors.forbiddenName">
      Name cannot be Bob.
      </div>

      </div>
    • 内置验证器

      由于这些验证器都是同步验证器,因此要把它们作为第二个参数传进去。

      可以通过把这些函数放进一个数组后传进去,可以支持多重验证器。

      这个例子添加了一些 getter 方法。在响应式表单中,你通常会通过它所属的控件组(FormGroup)的 get 方法来访问表单控件,但有时候为模板定义一些 getter 作为简短形式。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      ngOnInit(): void {
      this.heroForm = new FormGroup({
      'name': new FormControl(this.hero.name, [
      Validators.required,
      Validators.minLength(4),
      forbiddenNameValidator(/bob/i) // <-- Here's how you pass in the custom validator.
      ]),
      'alterEgo': new FormControl(this.hero.alterEgo),
      'power': new FormControl(this.hero.power, Validators.required)
      });
      }

      get name() { return this.heroForm.get('name'); }

      get power() { return this.heroForm.get('power'); }
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      <input id="name" class="form-control"
      formControlName="name" required >

      <div *ngIf="name.invalid && (name.dirty || name.touched)"
      class="alert alert-danger">

      <div *ngIf="name.errors.required">
      Name is required.
      </div>
      <div *ngIf="name.errors.minlength">
      Name must be at least 4 characters long.
      </div>
      <div *ngIf="name.errors.forbiddenName">
      Name cannot be Bob.
      </div>
      </div>
    • 自定义验证器
      这个函数是一个工厂,它接受一个用来检测指定名字是否已被禁用的正则表达式,并返回一个验证器函数。

      1
      2
      3
      4
      5
      6
      export function forbiddenNameValidator(nameRe: RegExp): ValidatorFn {
      return (control: AbstractControl): {[key: string]: any} => {
      const forbidden = nameRe.test(control.value);
      return forbidden ? {'forbiddenName': {value: control.value}} : null;
      };
      }
      1
      2
      3
      4
      5
      6
      7
      8
      9
      this.heroForm = new FormGroup({
      'name': new FormControl(this.hero.name, [
      Validators.required,
      Validators.minLength(4),
      forbiddenNameValidator(/bob/i) // <-- Here's how you pass in the custom validator.
      ]),
      'alterEgo': new FormControl(this.hero.alterEgo),
      'power': new FormControl(this.hero.power, Validators.required)
      });
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      @Directive({
      selector: '[appForbiddenName]',
      providers: [{provide: NG_VALIDATORS, useExisting: ForbiddenValidatorDirective, multi: true}]
      })
      export class ForbiddenValidatorDirective implements Validator {
      @Input('appForbiddenName') forbiddenName: string;

      validate(control: AbstractControl): {[key: string]: any} {
      return this.forbiddenName ? forbiddenNameValidator(new RegExp(this.forbiddenName, 'i'))(control)
      : null;
      }
      }
      1
      2
      3
      <input id="name" name="name" class="form-control"
      required minlength="4" appForbiddenName="bob"
      [(ngModel)]="hero.name" #name="ngModel" >

      (5) 表单类

    • AbstractControl是这三个具体表单类的抽象基类。 并为它们提供了一些共同的行为和属性。

    • FormControl 用于跟踪一个单独的表单控件的值和有效性状态。它对应于一个 HTML 表单控件,比如 \<input> 或 \<select>。

      属性

      • myControl.value:FormControl 的值。

      • myControl.status:FormControl 的有效性。可能的值有 VALID、INVALID、PENDING 或 DISABLED。

      • myControl.pristine:如果用户尚未改变过这个控件的值,则为 true。它总是与 myControl.dirty 相反。

      • myControl.untouched:如果用户尚未进入这个 HTML 控件,也没有触发过它的 blur(失去焦点)事件,则为 true。 它是 myControl.touched 的反义词。

        1
        2
        <p>Name value: {{ heroForm.get('name').value }}</p>
        <p>Street value: {{ heroForm.get('address.street').value}}</p>
    • FormGroup用于 跟踪一组AbstractControl 的实例的值和有效性状态。 该组的属性中包含了它的子控件。 组件中的顶级表单就是一个 FormGroup。

      方法

      • setValue() 方法会在赋值给任何表单控件之前先检查数据对象的值。它不会接受一个与 FormGroup 结构不同或缺少表单组中任何一个控件的数据对象。

        1
        2
        3
        4
        this.heroForm.setValue({
        name: this.hero.name,
        address: this.hero.addresses[0] || new Address()
        });
      • patchValue(),可以通过提供一个只包含要更新的控件的键值对象来把值赋给 FormGroup 中的指定控件。

        1
        2
        3
        this.heroForm.patchValue({
        name: this.hero.name
        });
1
2
3
4
5
6
7
8
import { Component }              from '@angular/core';
import { FormControl, FormGroup } from '@angular/forms';

export class HeroDetailComponent2 {
heroForm = new FormGroup ({
name: new FormControl()
});
}
1
2
3
4
5
6
7
8
9
<h2>Hero Detail</h2>
<h3><i>FormControl in a FormGroup</i></h3>
<form [formGroup]="heroForm">
<div class="form-group">
<label class="center-block">Name:
<input class="form-control" formControlName="name">
</label>
</div>
</form>
* FormArray用于跟踪 AbstractControl 实例组成的有序数组的值和有效性状态。
1
2
3
4
5
<div formArrayName="secretLairs" class="well well-lg">
<div *ngFor="let address of secretLairs.controls; let i=index" [formGroupName]="i" >
<!-- The repeated address template -->
</div>
</div>
* FormBuilder 类能通过处理控件创建的细节问题来帮你减少重复劳动。
1
2
3
4
5
6
7
8
9
10
11
12
13
export class HeroDetailComponent3 {
heroForm: FormGroup; // <--- heroForm is of type FormGroup

constructor(private fb: FormBuilder) { // <--- inject FormBuilder
this.createForm();
}

createForm() {
this.heroForm = this.fb.group({
name: '', // <--- the FormControl called "name"
});
}
}
FormBuilder.group 是一个用来创建 FormGroup 的工厂方法,它接受一个对象,对象的键和值分别是 FormControl 的名字和它的定义。 在这个例子中,name 控件的初始值是空字符串。 把一组控件定义在一个单一对象中,可以让代码更加紧凑、易读。 因为不必写一系列重复的 new FormControl(...) 语句。 (6) 在ngOnChanges设置/重置表单模型的值
1
2
3
ngOnChanges() {
this.rebuildForm();
}
  1. 管道符 |

    用于表达式结果转换,如lowercase,uppercase,json,date

    自定义

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    import { Pipe, PipeTransform } from '@angular/core';
    /*
    * Raise the value exponentially
    * Takes an exponent argument that defaults to 1.
    * Usage:
    * value | exponentialStrength:exponent
    * Example:
    * {{ 2 | exponentialStrength:10 }}
    * formats to: 1024
    */
    @Pipe({name: 'exponentialStrength'})
    export class ExponentialStrengthPipe implements PipeTransform {
    transform(value: number, exponent: string): number {
    let exp = parseFloat(exponent);
    return Math.pow(value, isNaN(exp) ? 1 : exp);
    }
    }
  2. style

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    encapsulation: ViewEncapsulation.Native 定义封装模式(具体见“概念梳理2”)
    @import './hero-details-box.css';可导入css文件
    @Component({
    selector: 'app-root',
    template: `
    <style>内联样式
    button {
    background-color: white;
    border: 1px solid #777;
    }
    </style>
    <link rel="stylesheet" href="../assets/hero-team.component.css">可使用link标签
    <h1>Tour of Heroes</h1>
    <app-hero-main [hero]="hero"></app-hero-main>
    `,
    styles: ['h1 { font-weight: normal; }']元数据样式
    styleUrls: ['./hero-app.component.css']加载外部样式
    styleUrls: ['./app.component.scss']如果使用 CLI 进行构建,可以用 sass、less 或 stylus 来编写样式
    })
  3. 分组元素(不会在DOM中)

    1
    2
    3
    4
    5
    6
    7
    <p>
    I turned the corner
    <ng-container *ngIf="hero">
    and saw {{hero.name}}. I waved
    </ng-container>
    and continued on my way.
    </p>

语法详解

  1. 属性绑定

    1
    2
    3
    4
    5
    6
    <img [src]="...">
    <button [disabled]="...">..</button>
    <div [ngClass]="...">..</div> //同时添加或移除多个 CSS 类,NgStyle同理s
    <div class="special"
    [class.special]="!isSpecial">..</div>
    <button [style.color]="isSpecial ? 'red': 'green'">Red</button>
    • 更多关于数据绑定

      |数据方向|语法|绑定类型|解析|
      |——-|—|——-|—|
      |数据源到视图|
      [target]=”expression”
      bind-target=”expression”|插值表达式
      属性
      Attribute
      CSS 类
      样式|数据改变影响视图|
      |视图到数据源|(target)=”statement”
      on-target=”statement”|事件|视图触发数据改变|
      |双向|[(target)]=”expression”
      bindon-target=”expression”|双向|视图和数据同时改变|

  2. 通信:输入输出与服务

    1
    2
    3
    4
    5
    6
    @Component({
    inputs: ['hero'],
    outputs: ['deleteRequest'],
    })
    @Input() hero: Hero;
    @Output() deleteRequest = new EventEmitter<Hero>();
    1
    <hero-detail [hero]="currentHero" (deleteRequest)="deleteHero($event)">

    HeroDetailComponent.hero 是个输入属性, 因为数据流从模板绑定表达式流入那个属性。

    HeroDetailComponent.deleteRequest 是个输出属性, 因为事件从那个属性流出,流向模板绑定语句中的处理器。

    更多组件交互:https://www.angular.cn/guide/component-interaction

  3. 安全操作

    • 安全导航操作符(?.)

      1
      The current hero's name is {{currentHero?.name}}

      若currentHero为null,不使用安全导航操作符会报错:
      TypeError: Cannot read property ‘name’ of null in [null].

    • 非空断言操作符(!)

      1
      2
      3
      <div *ngIf="hero">
      The hero's name is {{hero!.name}}
      </div>

      一般用于if后

    • 类型转换函数 $any

      1
      2
      3
      <div>
      The hero's marker is {{$any(hero).marker}}
      </div>

      防止类型报错

  4. 模板引用变量 ( #var )

    1
    2
    <input #phone placeholder="phone number">
    <button (click)="callPhone(phone.value)">Call</button>

    声明在 input 上的 phone 变量就是在模板另一侧的 button 上使用

  5. 组件样式

    (2:host用来选择组件宿主(父组件)元素中的元素

    1
    2
    3
    :host(.active) {
    order-width: 3px;
    }

    (2):host-context它在当前组件宿主元素的祖先节点中查找CSS 类, 直到文档的根节点为止。

    1
    2
    3
    :host-context(.theme-light) h2 {
    background-color: #eef;
    }

    (3)废弃:/deep/、>>> 和 ::ng-deep(将来兼容) 强制一个样式对各级子组件的视图也生效.

    1
    2
    3
    :host /deep/ h3 {
    font-style: italic;
    }
  6. 动态组件(样例:弹窗服务)

    (1) popup.component.ts 定义了一个简单的弹窗元素,用于显示一条输入消息,附带一些动画和样式。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    import { Component, EventEmitter, Input, Output } from '@angular/core';
    import { AnimationEvent } from '@angular/animations';
    import { animate, state, style, transition, trigger } from '@angular/animations';

    @Component({
    selector: 'my-popup',
    template: 'Popup: {{message}}',
    host: {
    '[@state]': 'state',
    '(@state.done)': 'onAnimationDone($event)',
    },
    animations: [
    trigger('state', [
    state('opened', style({transform: 'translateY(0%)'})),
    state('void, closed', style({transform: 'translateY(100%)', opacity: 0})),
    transition('* => *', animate('100ms ease-in')),
    ])
    ],
    styles: [`
    :host {
    position: absolute;
    bottom: 0;
    left: 0;
    right: 0;
    background: #009cff;
    height: 48px;
    padding: 16px;
    display: flex;
    align-items: center;
    border-top: 1px solid black;
    font-size: 24px;
    }
    `]
    })

    export class PopupComponent {
    private state: 'opened' | 'closed' = 'closed';

    @Input()
    set message(message: string) {
    this._message = message;
    this.state = 'opened';

    setTimeout(() => this.state = 'closed', 2000);
    }
    get message(): string { return this._message; }
    _message: string;

    @Output()
    closed = new EventEmitter();

    onAnimationDone(e: AnimationEvent) {
    if (e.toState === 'closed') {
    this.closed.next();
    }
    }
    }

    (2) popup.service.ts 创建了一个可注入的服务,它提供了两种方式来执行 PopupComponent:作为动态组件或作为自定义元素。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    import { ApplicationRef, ComponentFactoryResolver, Injectable, Injector } from '@angular/core';

    import { PopupComponent } from './popup.component';
    import { NgElementConstructor } from '../elements-dist';

    @Injectable()
    export class PopupService {
    constructor(private injector: Injector,
    private applicationRef: ApplicationRef,
    private componentFactoryResolver: ComponentFactoryResolver) {}

    // Previous dynamic-loading method required you to set up infrastructure
    // before adding the popup to the DOM.
    showAsComponent(message: string) {
    // Create element
    const popup = document.createElement('popup-component');

    // Create the component and wire it up with the element
    const factory = this.componentFactoryResolver.resolveComponentFactory(PopupComponent);
    const popupComponentRef = factory.create(this.injector, [], popup);

    // Attach to the view so that the change detector knows to run
    this.applicationRef.attachView(popupComponentRef.hostView);

    // Listen to the close event
    popupComponentRef.instance.closed.subscribe(() => {
    document.body.removeChild(popup);
    this.applicationRef.detachView(popupComponentRef.hostView);
    });

    // Set the message
    popupComponentRef.instance.message = message;

    // Add to the DOM
    document.body.appendChild(popup);
    }

    // This uses the new custom-element method to add the popup to the DOM.
    showAsElement(message: string) {
    // Create element
    const popupEl = document.createElement('popup-element');

    // Listen to the close event
    popupEl.addEventListener('closed', () => document.body.removeChild(popupEl));

    // Set the message
    popupEl.message = message;

    // Add to the DOM
    document.body.appendChild(popupEl);
    }
    }

    (3) app.module.ts 把 PopupComponent 添加到模块的 entryComponents 列表中,而从编译过程中排除它,以消除启动时的警告和错误。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    import { BrowserModule } from '@angular/platform-browser';
    import { BrowserAnimationsModule } from '@angular/platform-browser/animations';
    import { NgModule } from '@angular/core';

    import { AppComponent } from './app.component';
    import { PopupService } from './popup.service';
    import { PopupComponent } from './popup.component';

    // include the PopupService provider,
    // but exclude PopupComponent from compilation,
    // because it will be added dynamically

    @NgModule({
    declarations: [AppComponent, PopupComponent],
    imports: [BrowserModule, BrowserAnimationsModule],
    providers: [PopupService],
    bootstrap: [AppComponent],
    entryComponents: [PopupComponent],
    })

    export class AppModule {}

    (4) app.component.ts 定义了该应用的根组件,它借助 PopupService 在运行时把这个弹窗添加到 DOM 中。在应用运行期间,根组件的构造函数会把 PopupComponent 转换成自定义元素。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    import { Component, Injector } from '@angular/core';
    import { createNgElementConstructor } from '../elements-dist';
    import { PopupService } from './popup.service';
    import { PopupComponent } from './popup.component';

    @Component({
    selector: 'app-root',
    template: `
    <input #input value="Message">
    <button (click)="popup.showAsComponent(input.value)">
    Show as component </button>
    <button (click)="popup.showAsElement(input.value)">
    Show as element </button>
    `
    })

    export class AppComponent {
    constructor(private injector: Injector, public popup: PopupService) {
    // on init, convert PopupComponent to a custom element
    const PopupElement =
    createNgElementConstructor(PopupComponent, {injector: this.injector});
    // register the custom element with the browser.
    customElements.define('popup-element', PopupElement);
    }
    }
  7. 指令 directive

  • 属性型指令

    (1) 直接改变元素样式

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    import { Directive, ElementRef } from '@angular/core';

    @Directive({
    selector: '[appHighlight]'
    })
    export class HighlightDirective {
    constructor(el: ElementRef) {
    el.nativeElement.style.backgroundColor = 'yellow';
    }
    }
    1
    <p appHighlight>Highlight me!</p>

    (2)用户触发

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    import { Directive, ElementRef, HostListener } from '@angular/core';

    @Directive({
    selector: '[appHighlight]'
    })
    export class HighlightDirective {
    constructor(private el: ElementRef) { }

    @HostListener('mouseenter') onMouseEnter() {
    this.highlight('yellow');
    }

    @HostListener('mouseleave') onMouseLeave() {
    this.highlight(null);
    }

    private highlight(color: string) {
    this.el.nativeElement.style.backgroundColor = color;
    }

    (3)带输入值

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    import { Directive, ElementRef, HostListener, Input } from '@angular/core';

    @Directive({
    selector: '[appHighlight]'
    })
    export class HighlightDirective {

    constructor(private el: ElementRef) { }

    @Input('appHighlight') highlightColor: string;

    @HostListener('mouseenter') onMouseEnter() {
    this.highlight(this.highlightColor || 'red');
    }

    @HostListener('mouseleave') onMouseLeave() {
    this.highlight(null);
    }

    private highlight(color: string) {
    this.el.nativeElement.style.backgroundColor = color;
    }
    }
    1
    2
    <p appHighlight highlightColor="yellow">Highlighted in yellow</p>
    <p appHighlight [highlightColor]="'orange'">Highlighted in orange</p>
  • 结构型指令

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    import { Directive, Input, TemplateRef, ViewContainerRef } from '@angular/core';

    /**
    * Add the template content to the DOM unless the condition is true.
    */
    @Directive({ selector: '[appUnless]'})
    export class UnlessDirective {
    private hasView = false;

    constructor(
    private templateRef: TemplateRef<any>,
    private viewContainer: ViewContainerRef) { }

    @Input() set appUnless(condition: boolean) {
    if (!condition && !this.hasView) {
    this.viewContainer.createEmbeddedView(this.templateRef);
    this.hasView = true;
    } else if (condition && this.hasView) {
    this.viewContainer.clear();
    this.hasView = false;
    }
    }
    }
    1
    2
    3
    <p *appUnless="condition" class="unless a">
    (A) This paragraph is displayed because the condition is false.
    </p>
  1. 动画

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    import { BrowserModule } from '@angular/platform-browser';
    import { BrowserAnimationsModule } from '@angular/platform-browser/animations';

    import { Hero } from './hero.service';

    @Component({
    selector: 'app-hero-list-basic',
    template: `
    <ul>
    <li *ngFor="let hero of heroes"
    [@heroState]="hero.state"
    (click)="hero.toggleState()">
    {{hero.name}}
    </li>
    </ul>
    `,
    styleUrls: ['./hero-list.component.css'],
    animations: [
    动画触发器
    trigger('heroState', [
    state('inactive', style({
    backgroundColor: '#eee',
    transform: 'scale(1)'
    })),
    state('active', style({
    backgroundColor: '#cfd8dc',
    transform: 'scale(1.1)'
    })),
    transition('inactive => active', animate('100ms ease-in')),
    transition('active => inactive', animate('100ms ease-out'))
    ])
    ]
    })
    export class HeroListBasicComponent {
    @Input() heroes: Hero[];
    }

    transition(‘inactive => active, active => inactive’,animate(‘100ms ease-out’)),多个时间线

    transition(‘inactive <=> active’, animate(‘100ms ease-out’))双向
    也可使用*(通配符)匹配任何动画状态。

    有一种叫做 void 的特殊状态,它可以应用在任何动画中。它表示元素没有被附加到视图。这种情况可能是由于它尚未被添加进来或者已经被移除了。 void 状态在定义“进场”和“离场”的动画时会非常有用。

    进场:void => *

    离场:* => void

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    animations: [
    trigger('heroState', [
    state('inactive', style({transform: 'translateX(0) scale(1)'})),
    state('active', style({transform: 'translateX(0) scale(1.1)'})),
    transition('inactive => active', animate('100ms ease-in')),
    transition('active => inactive', animate('100ms ease-out')),
    transition('void => inactive', [
    style({transform: 'translateX(-100%) scale(1)'}),
    animate(100)
    ]),
    transition('inactive => void', [
    animate(100, style({transform: 'translateX(100%) scale(1)'}))
    ]),
    transition('void => active', [
    style({transform: 'translateX(0) scale(0)'}),
    animate(200)
    ]),
    transition('active => void', [
    animate(200, style({transform: 'translateX(0) scale(0)'}))
    ])
    ])
    ]

    可动的(Animatable)属性与单位:位置(position)、大小(size)、变换(transform)、颜色(color)、边框(border)等

    尺寸类属性(如位置、大小、边框等)包括一个数字值和一个用来定义长度单位的后缀:’50px’,’3em’,’100%’

    动画时间线:持续时间(duration)、延迟(delay)和缓动(easing)函数

    持续时间控制动画从开始到结束要花多长时间。可以用三种方式定义持续时间:

    • 作为一个普通数字,以毫秒为单位,如:100

    • 作为一个字符串,以毫秒为单位,如:’100ms’

    • 作为一个字符串,以秒为单位,如:’0.1s’

      延迟:等待 100 毫秒,然后运行 200 毫秒:’0.2s 100ms’。

      缓动函数

    • 等待 100 毫秒,然后运行 200 毫秒,并且带缓动:’0.2s 100ms ease-out’

    • 运行 200 毫秒,并且带缓动:’0.2s ease-in-out’

      基于关键帧(Keyframes)的多阶段动画,通过offset实现,取值[0,1],表示动画起点到终点

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      animations: [
      trigger('flyInOut', [
      state('in', style({transform: 'translateX(0)'})),
      transition('void => *', [
      animate(300, keyframes([
      style({opacity: 0, transform: 'translateX(-100%)', offset: 0}),
      style({opacity: 1, transform: 'translateX(15px)', offset: 0.3}),
      style({opacity: 1, transform: 'translateX(0)', offset: 1.0})
      ]))
      ]),
      transition('* => void', [
      animate(300, keyframes([
      style({opacity: 1, transform: 'translateX(0)', offset: 0}),
      style({opacity: 1, transform: 'translateX(-15px)', offset: 0.7}),
      style({opacity: 0, transform: 'translateX(100%)', offset: 1.0})
      ]))
      ])
      ])
      ]

      并行动画组(Group):只要把它们都放进同一个 style() 定义中

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      26
      27
      28
      animations: [
      trigger('flyInOut', [
      state('in', style({width: 120, transform: 'translateX(0)', opacity: 1})),
      transition('void => *', [
      style({width: 10, transform: 'translateX(50px)', opacity: 0}),
      group([
      animate('0.3s 0.1s ease', style({
      transform: 'translateX(0)',
      width: 120
      })),
      animate('0.3s ease', style({
      opacity: 1
      }))
      ])
      ]),
      transition('* => void', [
      group([
      animate('0.3s ease', style({
      transform: 'translateX(50px)',
      width: 10
      })),
      animate('0.3s 0.2s ease', style({
      opacity: 0
      }))
      ])
      ])
      ])
      ]

      动画回调:当动画开始和结束时,会触发一个回调。对于例子中的这个关键帧,你有一个叫做 @flyInOut 的 trigger。在那里你可以挂钩到那些回调,回调接收一个 AnimationTransitionEvent 参数,它包含一些有用的属性,例如 fromState,toState 和 totalTime。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      template: `
      <ul>
      <li *ngFor="let hero of heroes"
      (@flyInOut.start)="animationStarted($event)"
      (@flyInOut.done)="animationDone($event)"
      [@flyInOut]="'in'">
      {{hero.name}}
      </li>
      </ul>
      `,
  2. 观察者(observer)与订阅者(subscriber)

    • 代码样例:

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      26
      27
      28
      29
      30
      31
      32
      33
      34
      35
      36
      37
      38
      39
      // Create an Observable that will start listening to geolocation updates
      // when a consumer subscribes.

      const locations = new Observable((observer) => {

      // Get the next and error callbacks. These will be passed in when the consumer subscribes.

      //observer这个对象定义了一些回调函数来处理可观察对象可能会发来的三种通知:
      //next 必要。用来处理每个送达值。在开始执行后可能执行零次或多次。
      //error 可选。用来处理错误通知。错误会中断这个可观察对象实例的执行过程。
      //complete 可选。用来处理执行完毕(complete)通知。当执行完毕后,这些值就会继续传给下一个处理器。

      const {next, error} = observer;
      let watchId;

      // Simple geolocation API check provides values to publish


      if ('geolocation' in navigator) {
      watchId = navigator.geolocation.watchPosition(next, error);
      } else {
      error('Geolocation not available');
      }

      // When the consumer unsubscribes, clean up data ready for next subscription.

      return {unsubscribe() { navigator.geolocation.clearWatch(watchId); }};
      });

      // Call subscribe() to start listening for updates.
      //只有当有人订阅 Observable 的实例时,它才会开始发布值。 订阅时要先调用该实例的 subscribe() 方法,并把一个观察者对象传给它,用来接收通知。

      const locationsSubscription = locations.subscribe({
      next(position) { console.log('Current Position: ', position); },
      error(msg) { console.log('Error Getting Location: ', msg); }
      });

      // Stop listening for location after 10 seconds
      setTimeout(() => { locationsSubscription.unsubscribe(); }, 10000);
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      // Create simple observable that emits three values

      //可观察对象有一个构造函数可以用来创建新实例,也可以使用 Observable 上定义的一些静态方法来创建一些常用的简单可观察对象:
      //Observable.of(...items) —— 返回一个 Observable 实例,它用同步的方式把参数中提供的这些值发送出来。
      //Observable.from(iterable) —— 把它的参数转换成一个 Observable 实例。 该方法通常用于把一个数组转换成一个(发送多个值的)可观察对象。

      const myObservable = Observable.of(1, 2, 3);

      // Create observer object

      const myObserver = {
      next: x => console.log('Observer got a next value: ' + x),
      error: err => console.error('Observer got an error: ' + err),
      complete: () => console.log('Observer got a complete notification'),
      };

      // Execute with the observer object

      myObservable.subscribe(myObserver);

      // Logs:
      // Observer got a next value: 1
      // Observer got a next value: 2
      // Observer got a next value: 3
      // Observer got a complete notification
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      26
      27
      28
      29
      30
      31
      32
      33
      34
      // This function runs when subscribe() is called
      // 同上等价形式

      function sequenceSubscriber(observer) {

      // synchronously deliver 1, 2, and 3, then complete

      observer.next(1);
      observer.next(2);
      observer.next(3);
      observer.complete();

      // unsubscribe function doesn't need to do anything in this
      // because values are delivered synchronously

      return {unsubscribe() {}};

      }

      // Create a new Observable that will deliver the above sequence
      const sequence = new Observable(sequenceSubscriber);

      // execute the Observable and print the result of each notification

      sequence.subscribe({
      next(num) { console.log(num); },
      complete() { console.log('Finished sequence'); }
      });

      // Logs:
      // 1
      // 2
      // 3
      // Finished sequence
      1
      2
      3
      4
      5
      6
      7
      //subscribe() 方法还可以接收定义在同一行中的回调函数

      myObservable.subscribe(
      x => console.log('Observer got a next value: ' + x),
      err => console.error('Observer got an error: ' + err),
      () => console.log('Observer got a complete notification')
      );
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      //用来发布事件的可观察对象

      function fromEvent(target, eventName) {
      return new Observable((observer) => {
      const handler = (e) => observer.next(e);

      // Add the event handler to the target

      target.addEventListener(eventName, handler);

      return () => {
      // Detach the event handler from the target

      target.removeEventListener(eventName, handler);

      };
      });
      }
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      //创建可发布 keydown 事件的可观察对象

      const ESC_KEY = 27;
      const nameInput = document.getElementById('name') as HTMLInputElement;

      const subscription = fromEvent(nameInput, 'keydown')
      .subscribe((e: KeyboardEvent) => {
      if (e.keyCode === ESC_KEY) {
      nameInput.value = '';
      }
      });
    • 多播

      用来让可观察对象在一次执行中同时广播给多个订阅者。借助支持多播的可观察对象,你不必注册多个监听器,而是复用第一个(next)监听器,并且把值发送给各个订阅者。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      26
      27
      28
      29
      30
      31
      32
      33
      34
      35
      36
      37
      38
      39
      40
      41
      42
      43
      44
      45
      46
      47
      48
      49
      50
      51
      52
      53
      54
      55
      56
      57
      58
      59
      60
      61
      62
      63
      64
      65
      66
      67
      68
      69
      70
      71
      72
      73
      74
      75
      76
      77
      78
      79
      80
      81
      82
      83
      84
      85
      86
      87
      88
      89
      90
      91
      92
      93
      94
      95
      function multicastSequenceSubscriber() {
      const seq = [1, 2, 3];
      // Keep track of each observer (one for every active subscription)

      const observers = [];

      // Still a single timeoutId because there will only ever be one
      // set of values being generated, multicasted to each subscriber

      let timeoutId;

      // Return the subscriber function (runs when subscribe()
      // function is invoked)

      return (observer) => {
      observers.push(observer);

      // When this is the first subscription, start the sequence

      if (observers.length === 1) {
      timeoutId = doSequence({
      next(val) {

      // Iterate through observers and notify all subscriptions

      observers.forEach(obs => obs.next(val));
      },
      complete() {

      // Notify all complete callbacks

      observers.forEach(obs => obs.complete());
      }
      }, seq, 0);
      }

      return {
      unsubscribe() {

      // Remove from the observers array so it's no longer notified

      observers.splice(observers.indexOf(observer), 1);

      // If there's no more listeners, do cleanup

      if (observers.length === 0) {
      clearTimeout(timeoutId);
      }
      }
      };
      };
      }

      // Run through an array of numbers, emitting one value
      // per second until it gets to the end of the array.

      function doSequence(observer, arr, idx) {
      return setTimeout(() => {
      observer.next(arr[idx]);
      if (idx === arr.length - 1) {
      observer.complete();
      } else {
      doSequence(observer, arr, idx++);
      }
      }, 1000);
      }

      // Create a new Observable that will deliver the above sequence

      const multicastSequence = new Observable(multicastSequenceSubscriber);

      // Subscribe starts the clock, and begins to emit after 1 second

      multicastSequence.subscribe({
      next(num) { console.log('1st subscribe: ' + num); },
      complete() { console.log('1st sequence finished.'); }
      });

      // After 1 1/2 seconds, subscribe again (should "miss" the first value).

      setTimeout(() => {
      multicastSequence.subscribe({
      next(num) { console.log('2nd subscribe: ' + num); },
      complete() { console.log('2nd sequence finished.'); }
      });
      }, 1500);

      // Logs:
      // (at 1 second): 1st subscribe: 1
      // (at 2 seconds): 1st subscribe: 2
      // (at 2 seconds): 2nd subscribe: 2
      // (at 3 seconds): 1st subscribe: 3
      // (at 3 seconds): 1st sequence finished
      // (at 3 seconds): 2nd subscribe: 3
      // (at 3 seconds): 2nd sequence finished
    • RxJS 库

      可以简化事件、定时器、承诺等创建可观察对象的过程

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      //承诺

      import { fromPromise } from 'rxjs';

      // Create an Observable out of a promise

      const data = fromPromise(fetch('/api/endpoint'));

      // Subscribe to begin listening for async result

      data.subscribe({
      next(response) { console.log(response); },
      error(err) { console.error('Error: ' + err); },
      complete() { console.log('Completed'); }
      });
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      //定时器

      import { interval } from 'rxjs';

      // Create an Observable that will publish a value on an interval

      const secondsCounter = interval(1000);

      // Subscribe to begin publishing values

      secondsCounter.subscribe(n =>
      console.log(`It's been ${n} seconds since subscribing!`));
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      //事件

      import { fromEvent } from 'rxjs';
      const el = document.getElementById('my-element');

      // Create an Observable that will publish mouse movements

      const mouseMoves = fromEvent(el, 'mousemove');

      // Subscribe to start listening for mouse-move events

      const subscription = mouseMoves.subscribe((evt: MouseEvent) => {
      // Log coords of mouse movements

      console.log(`Coords: ${evt.clientX} X ${evt.clientY}`);

      // When the mouse is over the upper-left of the screen,
      // unsubscribe to stop listening for mouse movements

      if (evt.clientX < 40 && evt.clientY < 40) {
      subscription.unsubscribe();
      }
      });
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      //ajax

      import { ajax } from 'rxjs/ajax';

      // Create an Observable that will create an AJAX request

      const apiData = ajax('/api/data');

      // Subscribe to create the request

      apiData.subscribe(res => console.log(res.status, res.response));

      RxJS 定义了一些操作符,比如 map()、filter()、concat() 和 flatMap()。

      常用操作符

      创建 from , fromPromise , fromEvent , of

      组合 combineLatest , concat , merge , startWith , withLatestFrom , zip

      过滤 debounceTime , distinctUntilChanged , filter , take , takeUntil

      转换 bufferTime , concatMap , map , mergeMap , scan , switchMap

      工具 tap

      多播 share

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      import { map } from 'rxjs/operators';

      const nums = of(1, 2, 3);

      //map会观察来源可观察对象中发出的值,转换它们,并返回由转换后的值组成的新的可观察对象

      const squareValues = map((val: number) => val * val);
      const squaredNums = squareValues(nums);

      squaredNums.subscribe(x => console.log(x));

      // Logs
      // 1
      // 4
      // 9
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      26
      27
      import { filter, map } from 'rxjs/operators';

      const nums = of(1, 2, 3, 4, 5);

      // Create a function that accepts an Observable.
      //pipe() 函数以你要组合的这些函数作为参数,并且返回一个新的函数,当执行这个新函数时,就会顺序执行那些被组合进去的函数。

      const squareOddVals = pipe(
      filter(n => n % 2),
      map(n => n * n)
      );

      //可简写为

      const squareOdd = of(1, 2, 3, 4, 5)
      .pipe(
      filter(n => n % 2 !== 0),
      map(n => n * n)
      );

      // Create an Observable that will run the filter and map functions

      const squareOdd = squareOddVals(nums);

      // Suscribe to run the combined functions

      squareOdd.subscribe(x => console.log(x));
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      import { ajax } from 'rxjs/ajax';
      import { map, retry, catchError } from 'rxjs/operators';

      const apiData = ajax('/api/data').pipe(
      //错误重试3次

      retry(3),
      map(res => {
      if (!res.response) {
      throw new Error('Value expected!');
      }
      return res.response;
      }),
      //错误处理

      catchError(err => of([]))
      );

      apiData.subscribe({
      next(x) { console.log('data: ', x); },
      error(err) { console.log('errors already caught... will not run'); }
      });
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      import { Component } from '@angular/core';
      import { Observable } from 'rxjs';

      @Component({
      selector: 'app-stopwatch',
      templateUrl: './stopwatch.component.html'
      })
      export class StopwatchComponent {

      //命名约定:可观察对象一般以$结尾,属性储存不带$

      stopwatchValue: number;
      stopwatchValue$: Observable<number>;

      start() {
      this.stopwatchValue$.subscribe(num =>
      this.stopwatchValue = num
      );
      }
      }
    • 更多可观察对象

      事件发送器 EventEmitter 用来从组件的 @Output() 属性中发布一些值。

      HTTP http.get(‘/api’) 就会返回可观察对象。

      AsyncPipe 会订阅一个可观察对象或承诺,并返回其发出的最后一个值。

      路由器 (router) 可以使用 RxJS 中的 filter() 操作符来找到感兴趣的事件,并且订阅它们,以便根据浏览过程中产生的事件序列作出决定。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      25
      import { Router, NavigationStart } from '@angular/router';
      import { filter } from 'rxjs/operators';

      @Component({
      selector: 'app-routable',
      templateUrl: './routable.component.html',
      styleUrls: ['./routable.component.css']
      })
      export class Routable1Component implements OnInit {

      navStart: Observable<NavigationStart>;

      constructor(private router: Router) {

      // Create a new Observable the publishes only the NavigationStart event

      this.navStart = router.events.pipe(
      filter(evt => evt instanceof NavigationStart)
      ) as Observable<NavigationStart>;
      }

      ngOnInit() {
      this.navStart.subscribe(evt => console.log('Navigation Started!'));
      }
      }

      ActivatedRoute 是一个可注入的路由器服务,它使用可观察对象来获取关于路由路径和路由参数的信息。比如,ActivateRoute.url 包含一个用于汇报路由路径的可观察对象。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      import { ActivatedRoute } from '@angular/router';

      @Component({
      selector: 'app-routable',
      templateUrl: './routable.component.html',
      styleUrls: ['./routable.component.css']
      })
      export class Routable2Component implements OnInit {
      constructor(private activatedRoute: ActivatedRoute) {}

      ngOnInit() {
      this.activatedRoute.url
      .subscribe(url => console.log('The URL changed to: ' + url));
      }
      }

      响应式表单 (reactive forms) FormControl 的 valueChanges 属性和 statusChanges 属性包含了会发出变更事件的可观察对象。订阅可观察的表单控件属性是在组件类中触发应用逻辑的途径之一。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      import { FormGroup } from '@angular/forms';

      @Component({
      selector: 'my-component',
      template: 'MyComponent Template'
      })
      export class MyComponent implements OnInit {
      nameChangeLog: string[] = [];
      heroForm: FormGroup;

      ngOnInit() {
      this.logNameChange();
      }
      logNameChange() {
      const nameControl = this.heroForm.get('name');
      nameControl.valueChanges.forEach(
      (value: string) => this.nameChangeLog.push(value)
      );
      }
      }
    • 用法场景

      (1)输入提示(type-ahead)建议:

      从输入中监听数据。

      移除输入值前后的空白字符,并确认它达到了最小长度。

      防抖(这样才能防止连续按键时每次按键都发起 API 请求,而应该等到按键出现停顿时才发起)

      如果输入值没有变化,则不要发起请求(比如按某个字符,然后快速按退格)。

      如果已发出的 AJAX 请求的结果会因为后续的修改而变得无效,那就取消它。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      import { fromEvent } from 'rxjs';
      import { ajax } from 'rxjs/ajax';
      import { map, filter, debounceTime, distinctUntilChanged, switchMap } from 'rxjs/operators';

      const searchBox = document.getElementById('search-box');

      const typeahead = fromEvent(searchBox, 'input').pipe(
      map((e: KeyboardEvent) => e.target.value),
      filter(text => text.length > 2),
      debounceTime(10),
      distinctUntilChanged(),
      switchMap(() => ajax('/api/endpoint'))
      );

      typeahead.subscribe(data => {
      // Handle the data from the API
      });

      (2)指数化退避

      指数化退避是一种失败后重试 API 的技巧,它会在每次连续的失败之后让重试时间逐渐变长,超过最大重试次数之后就会彻底放弃。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      import { pipe, range, timer, zip } from 'rxjs';
      import { ajax } from 'rxjs/ajax';
      import { retryWhen, map, mergeMap } from 'rxjs/operators';

      function backoff(maxTries, ms) {
      return pipe(
      retryWhen(attempts => range(1, maxTries)
      .pipe(
      zip(attempts, (i) => i),
      map(i => i * i),
      mergeMap(i => timer(i * ms))
      )
      )
      );
      }

      ajax('/api/endpoint')
      .pipe(backoff(3, 250))
      .subscribe(data => handleData(data));

      function handleData(data) {
      // ...
      }
  3. 依赖注入

    A类需要使用B类,所以B类是A类的外部资源,不用依赖注入时,B类的改动(如构造函数多了个参数)都会导致A类的改动。依赖注入模式中,A类向注入容器拿B类实例,注入容器把B类注入A类中。

    依赖注入(Dependency Injection,DI):A类依赖容器注入外部资源B类。

    控制反转(Inversion Of Control,IOC):容器反向控制A类的外部资源B类。

    1
    2
    3
    4
    5
    6
    7
    8
    import { Injectable } from '@angular/core';

    @Injectable({
    providedIn: 'root',
    })
    export class HeroService {
    constructor() { }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    import { Component } from '@angular/core';
    import { HeroService } from './hero.service';

    @Component({
    selector: 'app-heroes',
    providers: [ HeroService ],

    //[{ provide: Logger, useClass: Logger }]上方简写:请求 Logger 时,返回 Logger
    //[{ provide: Logger, useClass: BetterLogger }]用于备选的类提供商的情况

    template: `
    <h2>Heroes</h2>
    <app-hero-list></app-hero-list>
    `
    })
    export class HeroesComponent { }

    备选的类提供商

    1
    2
    3
    4
    5
    6
    7
    8
    9
    @Injectable()
    export class EvenBetterLogger extends Logger {
    constructor(private userService: UserService) { super(); }

    log(message: string) {
    let name = this.userService.user.name;
    super.log(`Message to ${name}: ${message}`);
    }
    }

    别名类提供商:解决接口相同,功能不同的服务

    1
    2
    [ NewLogger,{ provide: OldLogger, useClass: NewLogger}]改为下面写法
    [ NewLogger,{ provide: OldLogger, useExisting: NewLogger}]

    值提供商

    1
    2
    3
    4
    5
    6
    export function SilentLoggerFn() {}

    const silentLogger = {
    logs: ['Silent logger says "Shhhhh!". Provided via "useValue"'],
    log: SilentLoggerFn
    };
    1
    [{ provide: Logger, useValue: silentLogger }]

    工厂提供商

    1
    2
    3
    4
    5
    6
    7
    8
    9
    constructor(
    private logger: Logger,
    private isAuthorized: boolean) { }

    getHeroes() {
    let auth = this.isAuthorized ? 'authorized ' : 'unauthorized';
    this.logger.log(`Getting heroes for ${auth} user.`);
    return HEROES.filter(hero => this.isAuthorized || !hero.isSecret);
    }
    1
    2
    3
    let heroServiceFactory = (logger: Logger, userService: UserService) => {
    return new HeroService(logger, userService.user.isAuthorized);
    };
    1
    2
    3
    4
    5
    export let heroServiceProvider =
    { provide: HeroService,
    useFactory: heroServiceFactory,
    deps: [Logger, UserService]
    };

    服务需要别的服务:用构造函数注入模式,来添加一个带有参数的构造函数。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    import { Injectable } from '@angular/core';
    import { HEROES } from './mock-heroes';
    import { Logger } from '../logger.service';

    @Injectable({
    providedIn: 'root',
    })
    export class HeroService {

    constructor(private logger: Logger) { }

    getHeroes() {
    this.logger.log('Getting heroes ...');
    return HEROES;
    }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    import { Injectable } from '@angular/core';

    @Injectable()
    export class Logger {
    logs: string[] = []; // capture logs for testing

    log(message: string) {
    this.logs.push(message);
    console.log(message);
    }
    }

    非类依赖:InjectionToken 值

    1
    2
    import { InjectionToken } from '@angular/core';
    export const TOKEN = new InjectionToken('desc');

    创建 InjectionToken 时直接配置一个提供商。该提供商的配置会决定由哪个注入器来提供这个令牌,以及如何创建它的值。 这和 @Injectable 的用法很像,不过你没法用 InjectionToken 来定义标准提供商(比如 useClass 或 useFactory),而要指定一个工厂函数,该函数直接返回想要提供的值。

    1
    export const TOKEN = new InjectionToken('desc', { providedIn: 'root', factory: () => new AppConfig(), })

    配置对象注入

    1
    constructor(@Inject(TOKEN));

    可选依赖

    1
    constructor(@Inject(Token, null));

    工厂函数需要访问其它的 DI 令牌

    1
    const TOKEN = new InjectionToken('tree-shakeable token', { providedIn: 'root', factory: () => new AppConfig(inject(Parameter1), inject(Paremeter2)), });

    直接使用注入器

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    @Component({
    selector: 'app-injectors',
    template: `
    <h2>Other Injections</h2>
    <div id="car">{{car.drive()}}</div>
    <div id="hero">{{hero.name}}</div>
    <div id="rodent">{{rodent}}</div>
    `,
    providers: [Car, Engine, Tires, heroServiceProvider, Logger]
    })
    export class InjectorComponent implements OnInit {
    car: Car;

    heroService: HeroService;
    hero: Hero;

    constructor(private injector: Injector) { }

    ngOnInit() {
    this.car = this.injector.get(Car);
    /*这些服务本身没有注入到组件,它们是通过调用 injector.get() 获得的。
    get() 方法如果不能解析所请求的服务,会抛出异常。 调用 get() 时,还可以使用第二个参数,一旦获取的服务没有在当前或任何祖先注入器中注册过, 就把它作为返回值。
    */
    this.heroService = this.injector.get(HeroService);
    this.hero = this.heroService.getHeroes()[0];
    }

    get rodent() {
    let rousDontExist = `R.O.U.S.'s? I don't think they exist!`;
    return this.injector.get(ROUS, rousDontExist);
    }
    }

    当 Angular 找不到依赖时,@Optional 装饰器会告诉 Angular 继续执行。Angular 把此注入参数设置为 null(而不用默认的抛出错误的行为)。

    @Host 装饰器将把往上搜索的行为截止在宿主组件

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    @Component({
    selector: 'app-hero-bios-and-contacts',
    template: `
    <app-hero-bio [heroId]="1"> <app-hero-contact></app-hero-contact> </app-hero-bio>
    <app-hero-bio [heroId]="2"> <app-hero-contact></app-hero-contact> </app-hero-bio>
    <app-hero-bio [heroId]="3"> <app-hero-contact></app-hero-contact> </app-hero-bio>`,
    providers: [HeroService]
    })
    export class HeroBiosAndContactsComponent {
    constructor(logger: LoggerService) {
    logger.logInfo('Creating HeroBiosAndContactsComponent');
    }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    @Component({
    selector: 'app-hero-contact',
    template: `
    <div>Phone #: {{phoneNumber}}
    <span *ngIf="hasLogger">!!!</span></div>`
    })
    export class HeroContactComponent {

    hasLogger = false;

    constructor(
    @Host() /* limit to the host component's instance of the HeroCacheService */
    private heroCache: HeroCacheService,

    @Host() /* limit search for logger; hides the application-wide logger*/
    @Optional() /* ok if the logger doesn't exist */
    private loggerService: LoggerService
    ) {
    if (loggerService) {
    this.hasLogger = true;
    loggerService.logInfo('HeroContactComponent can log!');
    }
    }

    get phoneNumber() { return this.heroCache.hero.phone; }

    }

    注入组件的 DOM 元素

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    import { Directive, ElementRef, HostListener, Input } from '@angular/core';

    @Directive({
    selector: '[appHighlight]'
    })
    export class HighlightDirective {

    @Input('appHighlight') highlightColor: string;

    private el: HTMLElement;

    constructor(el: ElementRef) {
    this.el = el.nativeElement;
    }

    @HostListener('mouseenter') onMouseEnter() {
    this.highlight(this.highlightColor || 'cyan');
    }

    @HostListener('mouseleave') onMouseLeave() {
    this.highlight(null);
    }

    private highlight(color: string) {
    this.el.style.backgroundColor = color;
    }
    }

    解决依赖循环 @SkipSelf

    1
    constructor( @SkipSelf() @Optional() public parent: Parent ) { }

    provideParent()助手函数:编写父组件相同的各种别名提供商很快就会变得啰嗦,在用forwardRef的时候尤其绕口。使用一个前向引用(forwardRef)来打破循环

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    providers: [{ provide: Parent, useExisting: forwardRef(() => AlexComponent) }],

    改为:

    const provideParent =(component: any) => {
    return { provide: Parent, useExisting: forwardRef(() => component) };};

    providers: [ provideParent(AliceComponent) ]

    默认接口:

    const provideParent = (component: any, parentType?: any) => {
    return { provide: parentType || Parent, useExisting: forwardRef(() => component) };};

    providers: [ provideParent(BethComponent, DifferentParent) ]
  1. HttpClient

    (1)根模块 AppModule 导入

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    import { NgModule }         from '@angular/core';
    import { BrowserModule } from '@angular/platform-browser';
    import { HttpClientModule } from '@angular/common/http';

    @NgModule({
    imports: [
    BrowserModule,
    HttpClientModule,
    ],
    declarations: [
    AppComponent,
    ],
    bootstrap: [ AppComponent ]
    })
    export class AppModule {}

    (2)注入到应用,并通过http.get获取特定资源,如这里的json文件

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    import { Injectable } from '@angular/core';
    import { HttpClient } from '@angular/common/http';

    @Injectable()
    export class ConfigService {
    constructor(private http: HttpClient) { }

    configUrl = 'assets/config.json';

    getConfig() {
    匿名对象,需要data['heroesUrl']获取数据
    return this.http.get(this.configUrl);
    带类型get,可data.heroesUrl获取数据
    return this.http.get<Config>(this.configUrl);
    }
    }

    (3)调用方法。这个服务方法返回配置数据的 Observable 对象,所以组件要订阅(subscribe) 该方法的返回值。订阅时的回调函数会把这些数据字段复制到组件的 config 对象中,它会在组件的模板中绑定,以供显示。

    1
    2
    3
    4
    5
    6
    7
    showConfig() {
    this.configService.getConfig()
    .subscribe((data: Config) => this.config = {
    heroesUrl: data['heroesUrl'],
    textfile: data['textfile']
    });
    }

    (4)读取完整的响应体,包含响应头或状态码

    1
    2
    3
    4
    getConfigResponse(): Observable<HttpResponse<Config>> {
    return this.http.get<Config>(
    this.configUrl, { observe: 'response' });
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    showConfigResponse() {
    this.configService.getConfigResponse()
    .subscribe(resp => {
    const keys = resp.headers.keys();
    this.headers = keys.map(key =>
    `${key}: ${resp.headers.get(key)}`);

    this.config = { ... resp.body };
    });
    }

    (5)错误处理

    1
    2
    3
    4
    5
    6
    7
    showConfig() {
    this.configService.getConfig()
    .subscribe(
    (data: Config) => this.config = { ...data },
    error => this.error = error
    );
    }

    (6)错误处理器

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    private handleError(error: HttpErrorResponse) {
    if (error.error instanceof ErrorEvent) {
    console.error('An error occurred:', error.error.message);
    } else {
    console.error(
    `Backend returned code ${error.status}, ` +
    `body was: ${error.error}`);
    }
    return throwError(
    'Something bad happened; please try again later.');
    };

    (7)错误通过管道传给处理器,可用retry重试

    1
    2
    3
    4
    5
    6
    7
    getConfig() {
    return this.http.get<Config>(this.configUrl)
    .pipe(
    retry(3),
    catchError(this.handleError)
    );
    }

    (8)请求非 JSON 格式的数据,如txt

    1
    2
    3
    4
    5
    6
    7
    8
    9
    getTextFile(filename: string) {
    return this.http.get(filename, {responseType: 'text'})
    .pipe(
    tap(
    data => this.log(filename, data),
    error => this.logError(filename, error)
    )
    );
    }
    1
    2
    3
    4
    download() {
    this.downloaderService.getTextFile('assets/textfile.txt')
    .subscribe(results => this.contents = results);
    }

    (9)数据发送到服务器

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    import { HttpHeaders } from '@angular/common/http';

    const httpOptions = {
    添加请求头
    headers: new HttpHeaders({
    'Content-Type': 'application/json',
    'Authorization': 'my-auth-token'
    })
    };
    配置请求头
    httpOptions.headers =
    httpOptions.headers.set('Authorization', 'my-new-auth-token');

    addHero (hero: Hero): Observable<Hero> {
    POST 请求
    return this.http.post<Hero>(this.heroesUrl, hero, httpOptions)
    .pipe(
    catchError(this.handleError('addHero', hero))
    );
    }

    对应订阅
    this.heroesService.addHero(newHero)
    .subscribe(hero => this.heroes.push(hero));

    deleteHero (id: number): Observable<{}> {
    DELETE 请求
    const url = `${this.heroesUrl}/${id}`;
    return this.http.delete(url, httpOptions)
    .pipe(
    catchError(this.handleError('deleteHero'))
    );
    }

    对应订阅
    this.heroesService.deleteHero(hero.id).subscribe();
    该组件不会等待删除操作的结果,所以它的 subscribe 中没有回调函数。不过就算你不关心结果,也仍然要订阅它。调用 subscribe() 方法会执行这个可观察对象,这时才会真的发起 DELETE 请求。

    updateHero (hero: Hero): Observable<Hero> {
    PUT 请求
    return this.http.put<Hero>(this.heroesUrl, hero, httpOptions)
    .pipe(
    catchError(this.handleError('updateHero', hero))
    );
    }

    searchHeroes(term: string): Observable<Hero[]> {
    term = term.trim();

    URL 参数:HttpParams 是不可变的,所以你也要使用 set() 方法来修改这些选项。
    const options = term ?
    { params: new HttpParams().set('name', term) } : {};

    return this.http.get<Hero[]>(this.heroesUrl, options)
    .pipe(
    catchError(this.handleError<Hero[]>('searchHeroes', []))
    );
    }

    (10)请求的防抖(debounce)(keyup) 事件绑定把每次击键都发送一次请求就太昂贵了。 最好能等到用户停止输入时才发送请求。

    1
    2
    3
    4
    5
    6
    7
    8
    <input (keyup)="search($event.target.value)" id="name" placeholder="Search"/>

    <ul>
    <li *ngFor="let package of packages$ | async">
    <b>{{package.name}} v.{{package.version}}</b> -
    <i>{{package.description}}</i>
    </li>
    </ul>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    withRefresh = false;
    packages$: Observable<NpmPackageInfo[]>;

    searchText$ 是一个序列,包含用户输入到搜索框中的所有值。 它定义成了 RxJS 的 Subject 对象,这表示它是一个多播 Observable,同时还可以自行调用 next(value) 来产生值。

    private searchText$ = new Subject<string>();

    search(packageName: string) {
    this.searchText$.next(packageName);
    }

    ngOnInit() {

    效果:只有当用户停止了输入且搜索值和以前不一样的时候,搜索值才会传给服务。

    this.packages$ = this.searchText$.pipe(

    debounceTime(500),等待500ms,直到用户停止输入

    distinctUntilChanged(),等待,直到搜索内容发生了变化

    下面switchMap()它的参数是一个返回 Observable 的函数。如果以前的搜索结果仍然是在途状态(这会出现在慢速网络中),它会取消那个请求,并发起这个新的搜索。它会按照原始的请求顺序返回这些服务的响应,而不用关心服务器实际上是以乱序返回的它们。

    switchMap(packageName =>
    this.searchService.search(packageName, this.withRefresh))
    把搜索请求发送给服务
    );
    }

    constructor(private searchService: PackageSearchService) { }

    (11)拦截请求和响应

    空白拦截器,它只会不做任何修改的传递这个请求

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    import { Injectable } from '@angular/core';
    import {
    HttpEvent, HttpInterceptor, HttpHandler, HttpRequest
    } from '@angular/common/http';

    import { Observable } from 'rxjs';

    /** Pass untouched request through to the next request handler. */
    @Injectable()
    export class NoopInterceptor implements HttpInterceptor {

    intercept(req: HttpRequest<any>, next: HttpHandler):
    Observable<HttpEvent<any>> {
    return next.handle(req);
    }
    }

    提供拦截器,并把它加到 AppModule 的 providers 数组中

    1
    2
    3
    4
    5
    6
    7
    8
    import { HTTP_INTERCEPTORS } from '@angular/common/http';

    import { NoopInterceptor } from './noop-interceptor';

    /** HTTP_INTERCEPTORS 是一个多重提供商的令牌 */
    export const httpInterceptorProviders = [
    { provide: HTTP_INTERCEPTORS, useClass: NoopInterceptor, multi: true },
    ];
    1
    2
    3
    providers: [
    httpInterceptorProviders
    ],

    拦截器的顺序:提供拦截器的顺序是A->B->C,请求阶段的执行顺序就是 A->B->C,而响应阶段的执行顺序则是 C->B->A

    拦截器有能力改变请求和响应,但 HttpRequest 和 HttpResponse 实例的属性却是只读(readonly)的。要想修改该请求,就要先克隆它,并修改这个克隆体,然后再把这个克隆体传给 next.handle()。

    1
    2
    3
    4
    const secureReq = req.clone({
    url: req.url.replace('http://', 'https://')
    });
    return next.handle(secureReq);

    readonly 这种赋值保护,无法防范深修改(修改子对象的属性),也不能防范你修改请求体对象中的属性。如果你必须修改请求体,那么就要先复制它,然后修改这个复本,clone() 这个请求,然后把这个请求体的复本作为新的请求体.

    1
    2
    3
    const newBody = { ...body, name: body.name.trim() };
    const newReq = req.clone({ body: newBody });
    return next.handle(newReq);

    清空请求体

    1
    newReq = req.clone({ body: null });

    设置默认请求头

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    import { AuthService } from '../auth.service';

    @Injectable()
    export class AuthInterceptor implements HttpInterceptor {

    constructor(private auth: AuthService) {}

    intercept(req: HttpRequest<any>, next: HttpHandler) {
    const authToken = this.auth.getAuthorizationToken();

    const authReq = req.clone({
    headers: req.headers.set('Authorization', authToken)
    });
    也可:
    const authReq = req.clone({ setHeaders: { Authorization: authToken } });

    return next.handle(authReq);
    }
    }

    记日志

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    import { finalize, tap } from 'rxjs/operators';
    import { MessageService } from '../message.service';

    @Injectable()
    export class LoggingInterceptor implements HttpInterceptor {
    constructor(private messenger: MessageService) {}

    intercept(req: HttpRequest<any>, next: HttpHandler) {
    const started = Date.now();
    let ok: string;

    return next.handle(req)
    .pipe(
    会捕获请求成功了还是失败了
    tap(
    event => ok = event instanceof HttpResponse ? 'succeeded' : '',
    error => ok = 'failed'
    ),
    无论在响应成功还是失败时都会调用
    finalize(() => {
    const elapsed = Date.now() - started;
    const msg = `${req.method} "${req.urlWithParams}"
    ${ok} in ${elapsed} ms.`;
    this.messenger.add(msg);
    })
    );
    }
    }

    缓存

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    @Injectable()
    export class CachingInterceptor implements HttpInterceptor {
    constructor(private cache: RequestCache) {}

    intercept(req: HttpRequest<any>, next: HttpHandler) {
    if (!isCachable(req)) { return next.handle(req); }

    const cachedResponse = this.cache.get(req);
    return cachedResponse ?
    of(cachedResponse) : sendRequest(req, next, this.cache);
    }

    function sendRequest(
    req: HttpRequest<any>,
    next: HttpHandler,
    cache: RequestCache): Observable<HttpEvent<any>> {

    const noHeaderReq = req.clone({ headers: new HttpHeaders() });

    return next.handle(noHeaderReq).pipe(
    tap(event => {
    if (event instanceof HttpResponse) {
    cache.put(req, event);
    }
    })
    );
    }
    )
    }

    返回多值可观察对象

    1
    2
    3
    4
    5
    6
    7
    8
    if (req.headers.get('x-refresh')) {
    const results$ = sendRequest(req, next, this.cache);
    return cachedResponse ?
    results$.pipe( startWith(cachedResponse) ) :
    results$;
    }
    return cachedResponse ?
    of(cachedResponse) : sendRequest(req, next, this.cache);

    (12)监听进度事件(文件上传)

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    private getEventMessage(event: HttpEvent<any>, file: File) {
    switch (event.type) {
    case HttpEventType.Sent:
    return `Uploading file "${file.name}" of size ${file.size}.`;

    case HttpEventType.UploadProgress:
    const percentDone = Math.round(100 * event.loaded / event.total);
    return `File "${file.name}" is ${percentDone}% uploaded.`;

    case HttpEventType.Response:
    return `File "${file.name}" was completely uploaded!`;

    default:
    return `File "${file.name}" surprising upload event: ${event.type}.`;
    }
    }

    const req = new HttpRequest('POST', '/upload/file', file, {
    reportProgress: true
    });

    return this.http.request(req).pipe(
    map(event => this.getEventMessage(event, file)),
    tap(message => this.showProgress(message)),
    last(),
    catchError(this.handleError(file))
    );
  2. 路由router

    (1)常用样例

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    app.module.ts:
    path 不能以斜杠(/)开头
    const appRoutes: Routes = [
    { path: 'crisis-center', component: CrisisListComponent },
    { path: 'hero/:id', component: HeroDetailComponent },
    {
    path: 'heroes',
    component: HeroListComponent,
    data: { title: 'Heroes List' }
    },
    空路径('')表示应用的默认路径,当 URL 为空时就会访问那里
    { path: '',
    redirectTo: '/heroes',
    pathMatch: 'full'
    },
    当所请求的 URL 不匹配前面定义的路由表中的任何路径时,路由器就会选择此路由。 这个特性可用于显示“404 - Not Found”页,或自动重定向到其它路由。
    { path: '**', component: PageNotFoundComponent }
    ];

    @NgModule({
    imports: [
    RouterModule.forRoot(
    appRoutes,
    它会把每个导航生命周期中的事件输出到浏览器的控制台
    { enableTracing: true }
    )
    ],
    ...
    })
    export class AppModule { }
    1
    2
    3
    4
    5
    6
    <h1>Angular Router</h1>
    <nav>
    <a routerLink="/crisis-center" routerLinkActive="active">Crisis Center</a>
    <a routerLink="/heroes" routerLinkActive="active">Heroes</a>
    </nav>
    <router-outlet></router-outlet>路由出口

    也可把路由设置为单独模块,在app.module.ts的import和imports引用即可

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    import { NgModule }              from '@angular/core';
    import { RouterModule, Routes } from '@angular/router';

    import { CrisisListComponent } from './crisis-list.component';
    import { HeroListComponent } from './hero-list.component';
    import { PageNotFoundComponent } from './not-found.component';

    const appRoutes: Routes = [
    { path: 'crisis-center', component: CrisisListComponent },
    { path: 'heroes', component: HeroListComponent },
    { path: '', redirectTo: '/heroes', pathMatch: 'full' },
    { path: '**', component: PageNotFoundComponent }
    ];

    @NgModule({
    imports: [
    RouterModule.forRoot(
    appRoutes,
    { enableTracing: true }
    )
    ],
    exports: [
    RouterModule
    ]
    })
    export class AppRoutingModule {}

    只在根模块 AppRoutingModule 中调用 RouterModule.forRoot(如果在 AppModule 中注册应用的顶级路由,那就在 AppModule 中调用)。 在其它模块中,你就必须调用RouterModule.forChild方法来注册附属路由。

    1
    2
    3
    4
    5
    6
    7
    8
    @NgModule({
    imports: [
    RouterModule.forChild(heroesRoutes)
    ],
    exports: [
    RouterModule
    ]
    })

    如有顺序很重要,先匹配的先跳转,通配符应放到后面。

    (2)路由属性

    • url

      路由路径的 Observable 对象,是一个由路由路径中的各个部分组成的字符串数组。

    • data

      一个 Observable,其中包含提供给路由的 data 对象。也包含由解析守卫(resolve guard)解析而来的值。

    • paramMap

      一个 Observable,其中包含一个由当前路由的必要参数和可选参数组成的map对象。用这个 map 可以获取来自同名参数的单一值或多重值。

    • queryParamMap

      一个 Observable,其中包含一个对所有路由都有效的查询参数组成的map对象。 用这个 map 可以获取来自查询参数的单一值或多重值。

    • fragment

      一个适用于所有路由的 URL 的 fragment(片段)的 Observable。

    • outlet

      要把该路由渲染到的 RouterOutlet 的名字。对于无名路由,它的路由名是 primary,而不是空串。

    • routeConfig

      用于该路由的路由配置信息,其中包含原始路径。

    • parent

      当该路由是一个子路由时,表示该路由的父级 ActivatedRoute。

    • firstChild

      包含该路由的子路由列表中的第一个 ActivatedRoute。

    • children

      包含当前路由下所有已激活的子路由。

    (3)路由事件

    • NavigationStart

      本事件会在导航开始时触发。

    • RoutesRecognized

      本事件会在路由器解析完 URL,并识别出了相应的路由时触发

    • RouteConfigLoadStart

      本事件会在 Router 对一个路由配置进行惰性加载之前触发。

    • RouteConfigLoadEnd

      本事件会在路由被惰性加载之后触发。

    • NavigationEnd

      本事件会在导航成功结束之后触发。

    • NavigationCancel

      本事件会在导航被取消之后触发。 这可能是因为在导航期间某个路由守卫返回了 false。

    • NavigationError

      这个事件会在导航由于意料之外的错误而失败时触发。

    (4)路由器部件

    • Router(路由器)

      为激活的 URL 显示应用组件。管理从一个组件到另一个组件的导航

    • RouterModule

      一个独立的 Angular 模块,用于提供所需的服务提供商,以及用来在应用视图之间进行导航的指令。

    • Routes(路由数组)

      定义了一个路由数组,每一个都会把一个 URL 路径映射到一个组件。

    • Route(路由)

      定义路由器该如何根据 URL 模式(pattern)来导航到组件。大多数路由都由路径和组件类构成。

    • RouterOutlet(路由出口)

      该指令()用来标记出路由器该在哪里显示视图。

    • RouterLink(路由链接)

      这个指令把可点击的 HTML 元素绑定到某个路由。点击带有 routerLink 指令(绑定到字符串或链接参数数组)的元素时就会触发一次导航。

    • RouterLinkActive(活动路由链接)

      当 HTML 元素上或元素内的routerLink变为激活或非激活状态时,该指令为这个 HTML 元素添加或移除 CSS 类。

    • ActivatedRoute(激活的路由)

      为每个路由组件提供提供的一个服务,它包含特定于路由的信息,比如路由参数、静态数据、解析数据、全局查询参数和全局碎片(fragment)。

    • RouterState(路由器状态)

      路由器的当前状态包含了一棵由程序中激活的路由构成的树。它包含一些用于遍历路由树的快捷方法。

    • 链接参数数组

      这个数组会被路由器解释成一个路由操作指南。你可以把一个RouterLink绑定到该数组,或者把它作为参数传给Router.navigate方法。

    • 路由组件

      一个带有RouterOutlet的 Angular 组件,它根据路由器的导航来显示相应的视图。

    (5)获取参数

    用 ActivatedRoute 服务来接收路由的参数,从参数中取得 id

    1
    2
    3
    4
    5
    6
    ngOnInit() {
    this.hero$ = this.route.paramMap.pipe(
    switchMap((params: ParamMap) =>
    this.service.getHero(params.get('id')))
    );
    }

    ParamMap API:

    • has(name)

      如果参数名位于参数列表中,就返回 true 。

    • get(name)

      如果这个 map 中有参数名对应的参数值(字符串),就返回它,否则返回 null。如果参数值实际上是一个数组,就返回它的第一个元素。

    • getAll(name)

      如果这个 map 中有参数名对应的值,就返回一个字符串数组,否则返回空数组。当一个参数名可能对应多个值的时候,请使用 getAll。

    • keys

      返回这个 map 中的所有参数名组成的字符串数组。

    如果很确定组件不会被复用,可用snapshot

    1
    2
    3
    4
    5
    ngOnInit() {
    let id = this.route.snapshot.paramMap.get('id');

    this.hero$ = this.service.getHero(id);
    }

    (6)导航跳转

    1
    2
    3
    gotoHeroes() {
    this.router.navigate(['/heroes']);
    }

    (7)路由动画

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    import { animate, state, style, transition, trigger } from '@angular/animations';

    export const slideInDownAnimation =
    trigger('routeAnimation', [
    state('*',
    style({
    opacity: 1,
    transform: 'translateX(0)'
    })
    ),
    transition(':enter', [
    style({
    opacity: 0,
    transform: 'translateX(-100%)'
    }),
    animate('0.2s ease-in')
    ]),
    transition(':leave', [
    animate('0.5s ease-out', style({
    opacity: 0,
    transform: 'translateY(100%)'
    }))
    ])
    ]);

    (8)子路由

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    import { NgModule }             from '@angular/core';
    import { RouterModule, Routes } from '@angular/router';

    import { CrisisCenterHomeComponent } from './crisis-center-home.component';
    import { CrisisListComponent } from './crisis-list.component';
    import { CrisisCenterComponent } from './crisis-center.component';
    import { CrisisDetailComponent } from './crisis-detail.component';

    要导航到 CrisisCenterHomeComponent,完整的 URL 是 /crisis-center (/crisis-center + '' + '')。
    要导航到 CrisisDetailComponent,完整的 URL 是 /crisis-center/2 (/crisis-center + '' + '/2')。
    const crisisCenterRoutes: Routes = [
    {
    path: 'crisis-center',
    component: CrisisCenterComponent,
    children: [
    {
    path: '',
    component: CrisisListComponent,
    children: [
    {
    path: ':id',
    component: CrisisDetailComponent
    },
    {
    path: '',
    component: CrisisCenterHomeComponent
    }
    ]
    }
    ]
    }
    ];

    @NgModule({
    imports: [
    RouterModule.forChild(crisisCenterRoutes)
    ],
    exports: [
    RouterModule
    ]
    })
    export class CrisisCenterRoutingModule { }

    (9)相对导航

    1
    2
    3
    ./ 或 无前导斜线 形式是相对于当前级别的。
    ../ 会回到当前路由路径的上一级。
    this.router.navigate(['../', { id: crisisId, foo: 'foo' }], { relativeTo: this.route });

    (10)用命名出口(outlet)显示多重路由:解决弹出框路由问题

    1
    2
    3
    <a [routerLink]="[{ outlets: { popup: ['compose'] } }]">Contact</a>
    <router-outlet></router-outlet>
    <router-outlet name="popup"></router-outlet>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    import { Component, HostBinding } from '@angular/core';
    import { Router } from '@angular/router';

    import { slideInDownAnimation } from './animations';

    @Component({
    templateUrl: './compose-message.component.html',
    styles: [ ':host { position: relative; bottom: 10%; }' ],
    animations: [ slideInDownAnimation ]
    })
    export class ComposeMessageComponent {
    @HostBinding('@routeAnimation') routeAnimation = true;
    @HostBinding('style.display') display = 'block';
    @HostBinding('style.position') position = 'absolute';

    details: string;
    sending = false;

    constructor(private router: Router) {}

    send() {
    this.sending = true;
    this.details = 'Sending Message...';

    setTimeout(() => {
    this.sending = false;
    this.closePopup();
    }, 1000);
    }

    cancel() {
    this.closePopup();
    }

    closePopup() {
    this.router.navigate([{ outlets: { popup: null }}]);
    }
    }

    (11)认证:CanActivate,CanActivateChild,解决登录保护问题

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    import { Injectable }       from '@angular/core';
    import {
    CanActivate, Router,
    ActivatedRouteSnapshot,
    RouterStateSnapshot,
    CanActivateChild
    } from '@angular/router';
    import { AuthService } from './auth.service';

    @Injectable()
    export class AuthGuard implements CanActivate, CanActivateChild {
    constructor(private authService: AuthService, private router: Router) {}

    canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): boolean {
    let url: string = state.url;

    return this.checkLogin(url);
    }

    canActivateChild(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): boolean {
    return this.canActivate(route, state);
    }

    /* . . . */
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    const adminRoutes: Routes = [
    {
    path: 'admin',
    component: AdminComponent,
    canActivate: [AuthGuard],
    children: [
    {
    path: '',
    canActivateChild: [AuthGuard],
    children: [
    { path: 'crises', component: ManageCrisesComponent },
    { path: 'heroes', component: ManageHeroesComponent },
    { path: '', component: AdminDashboardComponent }
    ]
    }
    ]
    }
    ];

    @NgModule({
    imports: [
    RouterModule.forChild(adminRoutes)
    ],
    exports: [
    RouterModule
    ]
    })
    export class AdminRoutingModule {}
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    import { Injectable } from '@angular/core';

    import { Observable, of } from 'rxjs';
    import { tap, delay } from 'rxjs/operators';

    @Injectable()
    export class AuthService {
    isLoggedIn = false;

    login(): Observable<boolean> {
    return of(true).pipe(
    delay(1000),
    tap(val => this.isLoggedIn = true)
    );
    }

    logout(): void {
    this.isLoggedIn = false;
    }
    }

    (12)CanDeactivate:处理未保存的更改

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    import { Injectable }           from '@angular/core';
    import { Observable } from 'rxjs';
    import { CanDeactivate,
    ActivatedRouteSnapshot,
    RouterStateSnapshot } from '@angular/router';

    import { CrisisDetailComponent } from './crisis-center/crisis-detail.component';

    @Injectable()
    export class CanDeactivateGuard implements CanDeactivate<CrisisDetailComponent> {

    canDeactivate(
    component: CrisisDetailComponent,
    route: ActivatedRouteSnapshot,
    state: RouterStateSnapshot
    ): Observable<boolean> | boolean {
    console.log(route.paramMap.get('id'));

    console.log(state.url);

    if (!component.crisis || component.crisis.name === component.editName) {
    return true;
    }
    return component.dialogService.confirm('Discard changes?');
    }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    import { NgModule }             from '@angular/core';
    import { RouterModule, Routes } from '@angular/router';

    import { CrisisCenterHomeComponent } from './crisis-center-home.component';
    import { CrisisListComponent } from './crisis-list.component';
    import { CrisisCenterComponent } from './crisis-center.component';
    import { CrisisDetailComponent } from './crisis-detail.component';

    import { CanDeactivateGuard } from '../can-deactivate-guard.service';

    const crisisCenterRoutes: Routes = [
    {
    path: '',
    redirectTo: '/crisis-center',
    pathMatch: 'full'
    },
    {
    path: 'crisis-center',
    component: CrisisCenterComponent,
    children: [
    {
    path: '',
    component: CrisisListComponent,
    children: [
    {
    path: ':id',
    component: CrisisDetailComponent,
    canDeactivate: [CanDeactivateGuard]
    },
    {
    path: '',
    component: CrisisCenterHomeComponent
    }
    ]
    }
    ]
    }
    ];

    @NgModule({
    imports: [
    RouterModule.forChild(crisisCenterRoutes)
    ],
    exports: [
    RouterModule
    ]
    })
    export class CrisisCenterRoutingModule { }

    (13)Resolve: 预先获取组件数据

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    import { Injectable }             from '@angular/core';
    import { Router, Resolve, RouterStateSnapshot,
    ActivatedRouteSnapshot } from '@angular/router';
    import { Observable } from 'rxjs';
    import { map, take } from 'rxjs/operators';

    import { Crisis, CrisisService } from './crisis.service';

    @Injectable()
    export class CrisisDetailResolver implements Resolve<Crisis> {
    constructor(private cs: CrisisService, private router: Router) {}

    resolve(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<Crisis> {
    let id = route.paramMap.get('id');

    return this.cs.getCrisis(id).pipe(
    take(1),
    map(crisis => {
    if (crisis) {
    return crisis;
    } else {
    this.router.navigate(['/crisis-center']);
    return null;
    }
    })
    );
    }
    }

    (14)NavigationExtras:查询参数及片段

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    import { Injectable }       from '@angular/core';
    import {
    CanActivate, Router,
    ActivatedRouteSnapshot,
    RouterStateSnapshot,
    CanActivateChild,
    NavigationExtras
    } from '@angular/router';
    import { AuthService } from './auth.service';

    @Injectable()
    export class AuthGuard implements CanActivate, CanActivateChild {
    constructor(private authService: AuthService, private router: Router) {}

    canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): boolean {
    let url: string = state.url;

    return this.checkLogin(url);
    }

    canActivateChild(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): boolean {
    return this.canActivate(route, state);
    }

    checkLogin(url: string): boolean {
    if (this.authService.isLoggedIn) { return true; }

    this.authService.redirectUrl = url;

    let sessionId = 123456789;

    let navigationExtras: NavigationExtras = {
    queryParams: { 'session_id': sessionId },
    fragment: 'anchor'
    };

    this.router.navigate(['/login'], navigationExtras);
    return false;
    }
    }

    (15)懒加载与预加载

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    import { NgModule }     from '@angular/core';
    import {
    RouterModule, Routes,
    } from '@angular/router';

    import { ComposeMessageComponent } from './compose-message.component';
    import { PageNotFoundComponent } from './not-found.component';

    import { CanDeactivateGuard } from './can-deactivate-guard.service';
    import { AuthGuard } from './auth-guard.service';

    const appRoutes: Routes = [
    弹窗
    {
    path: 'compose',
    component: ComposeMessageComponent,
    outlet: 'popup'
    },

    PreloadAllModules 预加载策略不会加载被CanLoad守卫所保护的特性区。
    {
    path: 'admin',
    loadChildren: 'app/admin/admin.module#AdminModule',
    canLoad: [AuthGuard]
    },

    给它一个 loadChildren 属性(注意不是 children 属性),把它设置为 AdminModule 的地址。 该地址是 AdminModule 的文件路径(相对于 app 目录的),加上一个 # 分隔符,再加上导出模块的类名 AdminModule。

    当路由器导航到这个路由时,它会用 loadChildren 字符串来动态加载 AdminModule,然后把 AdminModule 添加到当前的路由配置中, 最后,它把所请求的路由加载到目标 admin 组件中。

    惰性加载和重新配置工作只会发生一次,也就是在该路由首次被请求时。在后续的请求中,该模块和路由都是立即可用的。
    {
    path: 'crisis-center',
    loadChildren: 'app/crisis-center/crisis-center.module#CrisisCenterModule'
    },
    { path: '', redirectTo: '/heroes', pathMatch: 'full' },
    { path: '**', component: PageNotFoundComponent }
    ];

    @NgModule({
    imports: [
    RouterModule.forRoot(
    appRoutes,
    )
    ],
    exports: [
    RouterModule
    ],
    providers: [
    CanDeactivateGuard
    ]
    })
    export class AppRoutingModule {}

    自定义预加载策略

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    import { Injectable } from '@angular/core';
    import { PreloadingStrategy, Route } from '@angular/router';
    import { Observable, of } from 'rxjs';

    @Injectable()
    export class SelectivePreloadingStrategy implements PreloadingStrategy {
    preloadedModules: string[] = [];

    preload(route: Route, load: () => Observable<any>): Observable<any> {
    if (route.data && route.data['preload']) {
    this.preloadedModules.push(route.path);

    console.log('Preloaded: ' + route.path);

    return load();
    } else {
    return of(null);
    }
    }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    import { Component, OnInit }    from '@angular/core';
    import { ActivatedRoute } from '@angular/router';
    import { Observable } from 'rxjs';
    import { map } from 'rxjs/operators';

    import { SelectivePreloadingStrategy } from '../selective-preloading-strategy';


    @Component({
    template: `
    <p>Dashboard</p>

    <p>Session ID: {{ sessionId | async }}</p>
    <a id="anchor"></a>
    <p>Token: {{ token | async }}</p>

    Preloaded Modules
    <ul>
    <li *ngFor="let module of modules">{{ module }}</li>
    </ul>
    `
    })
    export class AdminDashboardComponent implements OnInit {
    sessionId: Observable<string>;
    token: Observable<string>;
    modules: string[];

    constructor(
    private route: ActivatedRoute,
    private preloadStrategy: SelectivePreloadingStrategy
    ) {
    this.modules = preloadStrategy.preloadedModules;
    }

    ngOnInit() {
    this.sessionId = this.route
    .queryParamMap
    .pipe(map(params => params.get('session_id') || 'None'));

    this.token = this.route
    .fragment
    .pipe(map(fragment => fragment || 'None'));
    }
    }
  3. 测试

    测试文件的扩展名必须是 .spec.ts,这样工具才能识别出它是一个测试文件,也叫规约(spec)文件。

    (1)端到端

    component-interaction/e2e/src/app.e2e-spec.ts

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    let _heroNames = ['Mr. IQ', 'Magneta', 'Bombasto'];
    let _masterName = 'Master';

    it('should pass properties to children properly', function () {
    let parent = element.all(by.tagName('app-hero-parent')).get(0);
    let heroes = parent.all(by.tagName('app-hero-child'));

    for (let i = 0; i < _heroNames.length; i++) {
    let childTitle = heroes.get(i).element(by.tagName('h3')).getText();
    let childDetail = heroes.get(i).element(by.tagName('p')).getText();
    expect(childTitle).toEqual(_heroNames[i] + ' says:');
    expect(childDetail).toContain(_masterName);
    }
    });

    AngularJs是不直接操作DOM的,但是在平时的开发当中,我们有的时候还是需要操作一些DOM的,如果使用原生的JS的话操作过于麻烦,所以大家一般都是使用jQuery,jQuery虽然好用,但是AngularJs是不建议和JQuery同时使用的,所以AngularJs给我们也提供了一些操作DOM的方法———Jqlite

    查阅官方提供的api,可以看到使用方法是angular.element(ele),其中,允许传入的参数ele的类型是“HTML string or DOMElement to be wrapped into jQuery.”一般传入参数DOMElement。

    angular.element:将DOM元素或者HTML字符串一包装成一个jQuery元素。

    用法:

    1
    2
    angular.element('#testID2').find(’.test2‘).removeClass(’.test3‘);
    angular.element(document.querySelector("#span1")).addClass('test1');

    angular.element(ele).更多函数:

    • addClass()-为每个匹配的元素添加指定的样式类名
    • after()-在匹配元素集合中的每个元素后面插入参数所指定的内容,作为其兄弟节点
    • append()-在每个匹配元素里面的末尾处插入参数内容
    • attr() - 获取匹配的元素集合中的第一个元素的属性的值
    • bind() - 为一个元素绑定一个事件处理程序
    • children() - 获得匹配元素集合中每个元素的子元素,选择器选择性筛选
    • clone()-创建一个匹配的元素集合的深度拷贝副本
    • contents()-获得匹配元素集合中每个元素的子元素,包括文字和注释节点
    • css() - 获取匹配元素集合中的第一个元素的样式属性的值
    • data()-在匹配元素上存储任意相关数据
    • detach()-从DOM中去掉所有匹配的元素
    • empty()-从DOM中移除集合中匹配元素的所有子节点
    • eq()-减少匹配元素的集合为指定的索引的哪一个元素
    • find() - 通过一个选择器,jQuery对象,或元素过滤,得到当前匹配的元素集合中每个元素的后代
    • hasClass()-确定任何一个匹配元素是否有被分配给定的(样式)类
    • html()-获取集合中第一个匹配元素的HTML内容
    • next() - 取得匹配的元素集合中每一个元素紧邻的后面同辈元素的元素集合。如果提供一个选择器,那么只有紧跟着的兄弟元素满足选择器时,才会返回此元素
    • on() - 在选定的元素上绑定一个或多个事件处理函数
    • off() - 移除一个事件处理函数
    • one() - 为元素的事件添加处理函数。处理函数在每个元素上每种事件类型最多执行一次
    • parent() - 取得匹配元素集合中,每个元素的父元素,可以提供一个可选的选择器
    • prepend()-将参数内容插入到每个匹配元素的前面(元素内部)
    • prop()-获取匹配的元素集中第一个元素的属性(property)值
    • ready()-当DOM准备就绪时,指定一个函数来执行
    • remove()-将匹配元素集合从DOM中删除。(同时移除元素上的事件及 jQuery 数据。)
    • removeAttr()-为匹配的元素集合中的每个元素中移除一个属性(attribute)
    • removeClass()-移除集合中每个匹配元素上一个,多个或全部样式
    • removeData()-在元素上移除绑定的数据
    • replaceWith()-用提供的内容替换集合中所有匹配的元素并且返回被删除元素的集合
    • text()-得到匹配元素集合中每个元素的合并文本,包括他们的后代
    • toggleClass()-在匹配的元素集合中的每个元素上添加或删除一个或多个样式类,取决于这个样式类是否存在或值切换属性。即:如果存在(不存在)就删除(添加)一个类
    • triggerHandler() -为一个事件执行附加到元素的所有处理程序
    • unbind() - 从元素上删除一个以前附加事件处理程序
    • val()-获取匹配的元素集合中第一个元素的当前值
    • wrap()-在每个匹配的元素外层包上一个html元素

    (2)普通测试

    • 服务
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20
      21
      22
      23
      24
      describe('ValueService', () => {
      let service: ValueService;
      beforeEach(() => { service = new ValueService(); });

      it('#getValue should return real value', () => {
      expect(service.getValue()).toBe('real value');
      });

      it('#getObservableValue should return value from observable',
      (done: DoneFn) => {
      service.getObservableValue().subscribe(value => {
      expect(value).toBe('observable value');
      done();
      });
      });

      it('#getPromiseValue should return value from a promise',
      (done: DoneFn) => {
      service.getPromiseValue().then(value => {
      expect(value).toBe('promise value');
      done();
      });
      });
      });

    带有依赖的服务

    1
    2
    3
    4
    5
    @Injectable()
    export class MasterService {
    constructor(private valueService: ValueService) { }
    getValue() { return this.valueService.getValue(); }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    describe('MasterService without Angular testing support', () => {
    let masterService: MasterService;

    it('#getValue should return real value from the real service', () => {
    masterService = new MasterService(new ValueService());
    expect(masterService.getValue()).toBe('real value');
    });

    it('#getValue should return faked value from a fakeService', () => {
    masterService = new MasterService(new FakeValueService());
    expect(masterService.getValue()).toBe('faked service value');
    });

    it('#getValue should return faked value from a fake object', () => {
    const fake = { getValue: () => 'fake value' };
    masterService = new MasterService(fake as ValueService);
    expect(masterService.getValue()).toBe('fake value');
    });

    it('#getValue should return stubbed value from a spy', () => {
    const valueServiceSpy =
    jasmine.createSpyObj('ValueService', ['getValue']);

    const stubValue = 'stub value';
    valueServiceSpy.getValue.and.returnValue(stubValue);

    masterService = new MasterService(valueServiceSpy);

    expect(masterService.getValue())
    .toBe(stubValue, 'service returned stub value');
    expect(valueServiceSpy.getValue.calls.count())
    .toBe(1, 'spy method was called once');
    expect(valueServiceSpy.getValue.calls.mostRecent().returnValue)
    .toBe(stubValue);
    });
    });

    HTTP 服务

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    let httpClientSpy: { get: jasmine.Spy };
    let heroService: HeroService;

    beforeEach(() => {
    httpClientSpy = jasmine.createSpyObj('HttpClient', ['get']);
    heroService = new HeroService(<any> httpClientSpy);
    });

    it('should return expected heroes (HttpClient called once)', () => {
    const expectedHeroes: Hero[] =
    [{ id: 1, name: 'A' }, { id: 2, name: 'B' }];

    httpClientSpy.get.and.returnValue(asyncData(expectedHeroes));

    heroService.getHeroes().subscribe(
    heroes => expect(heroes).toEqual(expectedHeroes, 'expected heroes'),
    fail
    );
    expect(httpClientSpy.get.calls.count()).toBe(1, 'one call');
    });

    it('should return an error when the server returns a 404', () => {
    const errorResponse = new HttpErrorResponse({
    error: 'test 404 error',
    status: 404, statusText: 'Not Found'
    });

    httpClientSpy.get.and.returnValue(asyncError(errorResponse));

    heroService.getHeroes().subscribe(
    heroes => fail('expected an error, not heroes'),
    error => expect(error.message).toContain('test 404 error')
    );
    });
    • 组件
      单独测试组件类
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      @Component({
      selector: 'lightswitch-comp',
      template: `
      <button (click)="clicked()">Click me!</button>
      <span>{{message}}</span>`
      })
      export class LightswitchComponent {
      isOn = false;
      clicked() { this.isOn = !this.isOn; }
      get message() { return `The light is ${this.isOn ? 'On' : 'Off'}`; }
      }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    describe('LightswitchComp', () => {
    it('#clicked() should toggle #isOn', () => {
    const comp = new LightswitchComponent();
    expect(comp.isOn).toBe(false, 'off at first');
    comp.clicked();
    expect(comp.isOn).toBe(true, 'on after click');
    comp.clicked();
    expect(comp.isOn).toBe(false, 'off after second click');
    });

    it('#clicked() should set #message to "is on"', () => {
    const comp = new LightswitchComponent();
    expect(comp.message).toMatch(/is off/i, 'off at first');
    comp.clicked();
    expect(comp.message).toMatch(/is on/i, 'on after clicked');
    });
    });
    1
    2
    3
    4
    5
    export class DashboardHeroComponent {
    @Input() hero: Hero;
    @Output() selected = new EventEmitter<Hero>();
    click() { this.selected.emit(this.hero); }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    it('raises the selected event when clicked', () => {
    const comp = new DashboardHeroComponent();
    const hero: Hero = { id: 42, name: 'Test' };
    comp.hero = hero;

    comp.selected.subscribe(selectedHero => expect(selectedHero).toBe(hero));
    comp.click();
    });
    1
    2
    3
    4
    5
    6
    7
    8
    9
    export class WelcomeComponent  implements OnInit {
    welcome: string;
    constructor(private userService: UserService) { }

    ngOnInit(): void {
    this.welcome = this.userService.isLoggedIn ?
    'Welcome, ' + this.userService.user.name : 'Please log in.';
    }
    }
    1
    2
    3
    4
    class MockUserService {
    isLoggedIn = true;
    user = { name: 'Test User'};
    };
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    beforeEach(() => {
    TestBed.configureTestingModule({
    providers: [
    WelcomeComponent,
    { provide: UserService, useClass: MockUserService }
    ]
    });
    comp = TestBed.get(WelcomeComponent);
    userService = TestBed.get(UserService);
    });

    it('should not have welcome message after construction', () => {
    expect(comp.welcome).toBeUndefined();
    });

    it('should welcome logged in user after Angular calls ngOnInit', () => {
    comp.ngOnInit();
    expect(comp.welcome).toContain(userService.user.name);
    });

    it('should ask user to log in if not logged in after ngOnInit', () => {
    userService.isLoggedIn = false;
    comp.ngOnInit();
    expect(comp.welcome).not.toContain(userService.user.name);
    expect(comp.welcome).toContain('log in');
    });

    组件绑定

    1
    2
    3
    4
    5
    6
    7
    8
    @Component({
    selector: 'app-banner',
    template: '<h1>{{title}}</h1>',
    styles: ['h1 { color: green; font-size: 350%}']
    })
    export class BannerComponent {
    title = 'Test Tour of Heroes';
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    let component: BannerComponent;
    let fixture: ComponentFixture<BannerComponent>;
    let h1: HTMLElement;

    TestBed.configureTestingModule({
    declarations: [ BannerComponent ],
    providers: [
    { provide: ComponentFixtureAutoDetect, useValue: true }
    ]
    });

    beforeEach(() => {
    TestBed.configureTestingModule({
    declarations: [ BannerComponent ],
    });
    fixture = TestBed.createComponent(BannerComponent);
    component = fixture.componentInstance;
    h1 = fixture.nativeElement.querySelector('h1');
    });

    it('no title in the DOM after createComponent()', () => {
    expect(h1.textContent).toEqual('');
    });

    it('should display a different test title', () => {
    component.title = 'Test Title';
    fixture.detectChanges();
    expect(h1.textContent).toContain('Test Title');
    });

    使用 dispatchEvent() 修改输入值

    模拟用户输入,就要找到 \<input> 元素并设置它的 value 属性。要调用 fixture.detectChanges() 来触发 Angular 的变更检测。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    it('should convert hero name to Title Case', () => {
    const hostElement = fixture.nativeElement;
    const nameInput: HTMLInputElement = hostElement.querySelector('input');
    const nameDisplay: HTMLElement = hostElement.querySelector('span');

    nameInput.value = 'quick BROWN fOx';

    nameInput.dispatchEvent(newEvent('input'));

    fixture.detectChanges();

    expect(nameDisplay.textContent).toBe('Quick Brown Fox');
    });

    获取注入的服务

    1
    userService = fixture.debugElement.injector.get(UserService);

    带有异步服务的组件,使用间谍(Spy)进行测试

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    beforeEach(() => {
    testQuote = 'Test Quote';

    const twainService = jasmine.createSpyObj('TwainService', ['getQuote']);
    getQuoteSpy = twainService.getQuote.and.returnValue( of(testQuote) );

    TestBed.configureTestingModule({
    declarations: [ TwainComponent ],
    providers: [
    { provide: TwainService, useValue: twainService }
    ]
    });

    fixture = TestBed.createComponent(TwainComponent);
    component = fixture.componentInstance;
    quoteEl = fixture.nativeElement.querySelector('.twain');
    });

    同步测试

    1
    2
    3
    4
    5
    6
    it('should show quote after component initialized', () => {
    fixture.detectChanges();

    expect(quoteEl.textContent).toBe(testQuote);
    expect(getQuoteSpy.calls.any()).toBe(true, 'getQuote called');
    });

    使用 fakeAsync() 进行异步测试

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    it('should display error when TwainService fails', fakeAsync(() => {
    getQuoteSpy.and.returnValue(
    throwError('TwainService test failure'));

    fixture.detectChanges();

    tick();

    fixture.detectChanges();

    expect(errorMessage()).toMatch(/test failure/, 'should display error');
    expect(quoteEl.textContent).toBe('...', 'should show placeholder');
    }));

    带有输入输出参数的组件

    1
    2
    3
    <dashboard-hero *ngFor="let hero of heroes"  class="col-1-4"
    [hero]=hero (selected)="gotoDetail($event)" >
    </dashboard-hero>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    @Component({
    selector: 'dashboard-hero',
    template: `
    <div (click)="click()" class="hero">
    {{hero.name | uppercase}}
    </div>`,
    styleUrls: [ './dashboard-hero.component.css' ]
    })
    export class DashboardHeroComponent {
    @Input() hero: Hero;
    @Output() selected = new EventEmitter<Hero>();
    click() { this.selected.emit(this.hero); }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    TestBed.configureTestingModule({
    declarations: [ DashboardHeroComponent ]
    })
    fixture = TestBed.createComponent(DashboardHeroComponent);
    comp = fixture.componentInstance;

    heroDe = fixture.debugElement.query(By.css('.hero'));
    heroEl = heroDe.nativeElement;

    expectedHero = { id: 42, name: 'Test Name' };

    comp.hero = expectedHero;

    fixture.detectChanges();

    it('should display hero name in uppercase', () => {
    const expectedPipedName = expectedHero.name.toUpperCase();
    expect(heroEl.textContent).toContain(expectedPipedName);
    });

    it('should raise selected event when clicked (triggerEventHandler)', () => {
    let selectedHero: Hero;
    comp.selected.subscribe((hero: Hero) => selectedHero = hero);

    heroDe.triggerEventHandler('click', null);
    expect(selectedHero).toBe(expectedHero);
    });

    it('should raise selected event when clicked (element.click)', () => {
    let selectedHero: Hero;
    comp.selected.subscribe((hero: Hero) => selectedHero = hero);

    heroEl.click();
    expect(selectedHero).toBe(expectedHero);
    });

    位于测试宿主中的组件

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    @Component({
    template: `
    <dashboard-hero
    [hero]="hero" (selected)="onSelected($event)">
    </dashboard-hero>`
    })
    class TestHostComponent {
    hero: Hero = {id: 42, name: 'Test Name' };
    selectedHero: Hero;
    onSelected(hero: Hero) { this.selectedHero = hero; }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    TestBed.configureTestingModule({
    declarations: [ DashboardHeroComponent, TestHostComponent ]
    })
    fixture = TestBed.createComponent(TestHostComponent);
    testHost = fixture.componentInstance;
    heroEl = fixture.nativeElement.querySelector('.hero');
    fixture.detectChanges();

    it('should display hero name', () => {
    const expectedPipedName = testHost.hero.name.toUpperCase();
    expect(heroEl.textContent).toContain(expectedPipedName);
    });

    it('should raise selected event when clicked', () => {
    click(heroEl);
    expect(testHost.selectedHero).toBe(testHost.hero);
    });

    路由组件

    1
    2
    3
    4
    5
    6
    7
    8
    constructor(
    private router: Router,
    private heroService: HeroService) {}
    )
    gotoDetail(hero: Hero) {
    let url = `/heroes/${hero.id}`;
    this.router.navigateByUrl(url);
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    const routerSpy = jasmine.createSpyObj('Router', ['navigateByUrl']);
    const heroServiceSpy = jasmine.createSpyObj('HeroService', ['getHeroes']);

    TestBed.configureTestingModule({
    providers: [
    { provide: HeroService, useValue: heroServiceSpy },
    { provide: Router, useValue: routerSpy }
    ]
    })

    it('should tell ROUTER to navigate when hero clicked', () => {

    heroClick();

    const spy = router.navigateByUrl as jasmine.Spy;
    const navArgs = spy.calls.first().args[0];

    const id = comp.heroes[0].id;
    expect(navArgs).toBe('/heroes/' + id,
    'should nav to HeroDetail for first hero');
    });

    路由目标组件

    1
    2
    3
    4
    5
    6
    7
    8
    constructor(
    private heroDetailService: HeroDetailService,
    private route: ActivatedRoute,
    private router: Router) {}
    )
    ngOnInit(): void {
    this.route.paramMap.subscribe(pmap => this.getHero(pmap.get('id')));
    }

    需要测试替身

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    import { convertToParamMap, ParamMap, Params } from '@angular/router';
    import { ReplaySubject } from 'rxjs';

    export class ActivatedRouteStub {
    private subject = new ReplaySubject<ParamMap>();

    constructor(initialParams?: Params) {
    this.setParamMap(initialParams);
    }

    readonly paramMap = this.subject.asObservable();

    setParamMap(params?: Params) {
    this.subject.next(convertToParamMap(params));
    };
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    describe('when navigate to existing hero', () => {
    let expectedHero: Hero;

    beforeEach(async(() => {
    expectedHero = firstHero;
    activatedRoute.setParamMap({ id: expectedHero.id });
    createComponent();
    }));

    it('should display that hero\'s name', () => {
    expect(page.nameDisplay.textContent).toBe(expectedHero.name);
    });
    });

    describe('when navigate to non-existent hero id', () => {
    beforeEach(async(() => {
    activatedRoute.setParamMap({ id: 99999 });
    createComponent();
    }));

    it('should try to navigate back to hero list', () => {
    expect(page.gotoListSpy.calls.any()).toBe(true, 'comp.gotoList called');
    expect(page.navigateSpy.calls.any()).toBe(true, 'router.navigate called');
    });
    });

    describe('when navigate with no hero id', () => {
    beforeEach(async( createComponent ));

    it('should have hero.id === 0', () => {
    expect(component.hero.id).toBe(0);
    });

    it('should display empty hero name', () => {
    expect(page.nameDisplay.textContent).toBe('');
    });
    });

    对嵌套组件的测试

    1
    2
    3
    4
    5
    6
    7
    8
    <app-banner></app-banner>
    <app-welcome></app-welcome>
    <nav>
    <a routerLink="/dashboard">Dashboard</a>
    <a routerLink="/heroes">Heroes</a>
    <a routerLink="/about">About</a>
    </nav>
    <router-outlet></router-outlet>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    @Component({selector: 'app-banner', template: ''})
    class BannerStubComponent {}

    @Component({selector: 'router-outlet', template: ''})
    class RouterOutletStubComponent { }

    @Component({selector: 'app-welcome', template: ''})
    class WelcomeStubComponent {}

    TestBed.configureTestingModule({
    declarations: [
    AppComponent,
    BannerStubComponent,
    RouterLinkDirectiveStub
    ],
    schemas: [ NO_ERRORS_SCHEMA ]
    })

    带有 RouterLink 的组件

    1
    2
    3
    4
    5
    <nav>
    <a routerLink="/dashboard">Dashboard</a>
    <a routerLink="/heroes">Heroes</a>
    <a routerLink="/about">About</a>
    </nav>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    @Directive({
    selector: '[routerLink]',
    host: { '(click)': 'onClick()' }
    })
    export class RouterLinkDirectiveStub {
    @Input('routerLink') linkParams: any;
    navigatedTo: any = null;

    onClick() {
    this.navigatedTo = this.linkParams;
    }
    }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    beforeEach(() => {
    fixture.detectChanges();
    By.directive 来定位一个带附属指令的链接元素
    linkDes = fixture.debugElement
    .queryAll(By.directive(RouterLinkDirectiveStub));

    routerLinks = linkDes.map(de => de.injector.get(RouterLinkDirectiveStub));
    });

    it('can get RouterLinks from template', () => {
    expect(routerLinks.length).toBe(3, 'should have 3 routerLinks');
    expect(routerLinks[0].linkParams).toBe('/dashboard');
    expect(routerLinks[1].linkParams).toBe('/heroes');
    expect(routerLinks[2].linkParams).toBe('/about');
    });

    it('can click Heroes link in template', () => {
    const heroesLinkDe = linkDes[1]; // heroes link DebugElement
    const heroesLink = routerLinks[1]; // heroes link directive

    expect(heroesLink.navigatedTo).toBeNull('should not have navigated yet');

    heroesLinkDe.triggerEventHandler('click', null);
    fixture.detectChanges();

    expect(heroesLink.navigatedTo).toBe('/heroes');
    });

    使用页面(page)对象

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    <div *ngIf="hero">
    <h2><span>{{hero.name | titlecase}}</span> Details</h2>
    <div>
    <label>id: </label>{{hero.id}}</div>
    <div>
    <label for="name">name: </label>
    <input id="name" [(ngModel)]="hero.name" placeholder="name" />
    </div>
    <button (click)="save()">Save</button>
    <button (click)="cancel()">Cancel</button>
    </div>
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    class Page {
    get buttons() { return this.queryAll<HTMLButtonElement>('button'); }
    get saveBtn() { return this.buttons[0]; }
    get cancelBtn() { return this.buttons[1]; }
    get nameDisplay() { return this.query<HTMLElement>('span'); }
    get nameInput() { return this.query<HTMLInputElement>('input'); }

    gotoListSpy: jasmine.Spy;
    navigateSpy: jasmine.Spy;

    constructor(fixture: ComponentFixture<HeroDetailComponent>) {
    const routerSpy = <any> fixture.debugElement.injector.get(Router);
    this.navigateSpy = routerSpy.navigate;

    const component = fixture.componentInstance;
    this.gotoListSpy = spyOn(component, 'gotoList').and.callThrough();
    }

    private query<T>(selector: string): T {
    return fixture.nativeElement.querySelector(selector);
    }

    private queryAll<T>(selector: string): T[] {
    return fixture.nativeElement.querySelectorAll(selector);
    }
    }

    function createComponent() {
    fixture = TestBed.createComponent(HeroDetailComponent);
    component = fixture.componentInstance;
    page = new Page(fixture);

    fixture.detectChanges();
    return fixture.whenStable().then(() => {
    fixture.detectChanges();
    });
    }

    it('should display that hero\'s name', () => {
    expect(page.nameDisplay.textContent).toBe(expectedHero.name);
    });

    it('should navigate when click cancel', () => {
    click(page.cancelBtn);
    expect(page.navigateSpy.calls.any()).toBe(true, 'router.navigate called');
    });

    it('should save when click save but not navigate immediately', () => {
    const hds = fixture.debugElement.injector.get(HeroDetailService);
    const saveSpy = spyOn(hds, 'saveHero').and.callThrough();

    click(page.saveBtn);
    expect(saveSpy.calls.any()).toBe(true, 'HeroDetailService.save called');
    expect(page.navigateSpy.calls.any()).toBe(false, 'router.navigate not called');
    });

    it('should navigate when click save and save resolves', fakeAsync(() => {
    click(page.saveBtn);
    tick();
    expect(page.navigateSpy.calls.any()).toBe(true, 'router.navigate called');
    }));

    it('should convert hero name to Title Case', () => {
    const hostElement = fixture.nativeElement;
    const nameInput: HTMLInputElement = hostElement.querySelector('input');
    const nameDisplay: HTMLElement = hostElement.querySelector('span');

    nameInput.value = 'quick BROWN fOx';

    nameInput.dispatchEvent(newEvent('input'));

    fixture.detectChanges();

    expect(nameDisplay.textContent).toBe('Quick Brown Fox');
    });
    • 指令
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      import { Directive, ElementRef, Input, OnChanges } from '@angular/core';

      @Directive({ selector: '[highlight]' })
      export class HighlightDirective implements OnChanges {

      defaultColor = 'rgb(211, 211, 211)';

      @Input('highlight') bgColor: string;

      constructor(private el: ElementRef) {
      el.nativeElement.style.customProperty = true;
      }

      ngOnChanges() {
      this.el.nativeElement.style.backgroundColor = this.bgColor || this.defaultColor;
      }
      }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    import { Component } from '@angular/core';
    @Component({
    template: `
    <h2 highlight="skyblue">About</h2>
    <h3>Quote of the day:</h3>
    <twain-quote></twain-quote>
    `
    })
    export class AboutComponent { }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    beforeEach(() => {
    fixture = TestBed.configureTestingModule({
    declarations: [ HighlightDirective, TestComponent ]
    })
    .createComponent(TestComponent);

    fixture.detectChanges();

    des = fixture.debugElement.queryAll(By.directive(HighlightDirective));

    bareH2 = fixture.debugElement.query(By.css('h2:not([highlight])'));
    });

    it('should have three highlighted elements', () => {
    expect(des.length).toBe(3);
    });

    it('should color 1st <h2> background "yellow"', () => {
    const bgColor = des[0].nativeElement.style.backgroundColor;
    expect(bgColor).toBe('yellow');
    });

    it('should color 2nd <h2> background w/ default color', () => {
    const dir = des[1].injector.get(HighlightDirective) as HighlightDirective;
    const bgColor = des[1].nativeElement.style.backgroundColor;
    expect(bgColor).toBe(dir.defaultColor);
    });

    it('should bind <input> background to value color', () => {
    const input = des[2].nativeElement as HTMLInputElement;
    expect(input.style.backgroundColor).toBe('cyan', 'initial backgroundColor');

    input.value = 'green';
    input.dispatchEvent(newEvent('input'));
    fixture.detectChanges();

    expect(input.style.backgroundColor).toBe('green', 'changed backgroundColor');
    });


    it('bare <h2> should not have a customProperty', () => {
    expect(bareH2.properties['customProperty']).toBeUndefined();
    });
    • 管道
      1
      2
      3
      4
      5
      6
      7
      8
      9
      import { Pipe, PipeTransform } from '@angular/core';

      @Pipe({name: 'titlecase', pure: true})
      export class TitleCasePipe implements PipeTransform {
      transform(input: string): string {
      return input.length === 0 ? '' :
      input.replace(/\w\S*/g, (txt => txt[0].toUpperCase() + txt.substr(1).toLowerCase() ));
      }
      }
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    describe('TitleCasePipe', () => {
    let pipe = new TitleCasePipe();

    it('transforms "abc" to "Abc"', () => {
    expect(pipe.transform('abc')).toBe('Abc');
    });

    it('transforms "abc def" to "Abc Def"', () => {
    expect(pipe.transform('abc def')).toBe('Abc Def');
    });

    // ... more tests ...

    });
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    it('should convert hero name to Title Case', () => {
    const hostElement = fixture.nativeElement;
    const nameInput: HTMLInputElement = hostElement.querySelector('input');
    const nameDisplay: HTMLElement = hostElement.querySelector('span');

    nameInput.value = 'quick BROWN fOx';

    nameInput.dispatchEvent(newEvent('input'));

    fixture.detectChanges();

    expect(nameDisplay.textContent).toBe('Quick Brown Fox');
    });
    • spec

    在浏览器中,像调试应用一样调试测试程序 spec。

    显示 Karma 的浏览器窗口(之前被隐藏了)。
    
    点击“DEBUG”按钮;它打开一页新浏览器标签并重新开始运行测试程序
    
    打开浏览器的“Developer Tools”(Windows 上的 Ctrl-Shift-I 或者 OSX 上的 `Command-Option-I)。
    
    选择“sources”页
    
    打开 1st.spec.ts 测试文件(Control/Command-P, 然后输入文件名字)。
    
    在测试程序中设置断点。
    
    刷新浏览器...然后它就会停在断点上。
    
(3)测试工具 API
* async

    在一个特殊的 async 测试区域中运行测试(it)的函数体或准备函数(beforeEach)。 参见前面的讨论。
    
1
2
3
4
5
6
7
8
9
10
it('should show quote after getQuote (async)', async(() => {
fixture.detectChanges();
expect(quoteEl.textContent).toBe('...', 'should show placeholder');

fixture.whenStable().then(() => {
fixture.detectChanges();
expect(quoteEl.textContent).toBe(testQuote);
expect(errorMessage()).toBeNull('should not show error');
});
}));
* fakeAsync 在一个特殊的 fakeAsync 测试区域中运行测试(it)的函数体,以便启用线性风格的控制流。 参见前面的讨论。 * tick 通过在 fakeAsync 测试区域中刷新定时器和微任务(micro-task)队列来仿真时间的流逝以及异步活动的完成。 好奇和执着的读者可能会喜欢这篇长博客: "Tasks, microtasks, queues and schedules". 接受一个可选参数,它可以把虚拟时钟往前推进特定的微秒数。 清除调度到那个时间帧中的异步活动。 参见前面的讨论。 * inject 从当前的 TestBed 注入器中把一个或多个服务注入到一个测试函数中。 它不能用于注入组件自身提供的服务。 参见 debugElement.injector 部分的讨论。 * discardPeriodicTasks 当 fakeAsync 测试程序以正在运行的计时器事件任务(排队中的 setTimeOut 和 setInterval 的回调)结束时, 测试会失败,并显示一条明确的错误信息。 一般来讲,测试程序应该以无排队任务结束。 当待执行计时器任务存在时,调用 discardPeriodicTasks 来触发任务队列,防止该错误发生。 * flushMicrotasks 当 fakeAsync 测试程序以待执行微任务(比如未解析的承诺)结束时,测试会失败并显示明确的错误信息。 一般来说,测试应该等待微任务结束。 当待执行微任务存在时,调用 flushMicrotasks 来触发微任务队列,防止该错误发生。 * ComponentFixtureAutoDetect 一个服务提供商令牌,用于开启自动变更检测。 * getTestBed 获取当前 TestBed 实例。 通常用不上,因为 TestBed 的静态类方法已经够用。 TestBed 实例有一些很少需要用到的方法,它们没有对应的静态方法。 TestBed 类 * configureTestingModule 测试垫片(karma-test-shim, browser-test-shim)创建了初始测试环境和默认测试模块。 默认测试模块是使用基本声明和一些 Angular 服务替代品,它们是所有测试程序都需要的。 调用 configureTestingModule 来为一套特定的测试定义测试模块配置,添加和删除导入、(组件、指令和管道的)声明和服务提供商。 * compileComponents 在配置好测试模块之后,异步编译它。 如果测试模块中的任何一个组件具有 templateUrl 或 styleUrls,那么你必须调用这个方法,因为获取组件的模板或样式文件必须是异步的。 参见前面的讨论。 调用完 compileComponents 之后,TestBed 的配置就会在当前测试期间被冻结。 * createComponent 基于当前 TestBed 的配置创建一个类型为 T 的组件实例。 一旦调用,TestBed 的配置就会在当前测试期间被冻结。
1
const fixture = TestBed.createComponent(BannerComponent);
* overrideModule 替换指定的 NgModule 的元数据。回想一下,模块可以导入其他模块。 overrideModule 方法可以深入到当前测试模块深处,修改其中一个内部模块。 * overrideComponent 替换指定组件类的元数据,该组件类可能嵌套在一个很深的内部模块中。 * overrideDirective 替换指定指令类的元数据,该指令可能嵌套在一个很深的内部模块中。 * overridePipe 替换指定管道类的元数据,该管道可能嵌套在一个很深的内部模块中。 * get 从当前 TestBed 注入器获取一个服务。 inject 函数通常都能胜任这项工作,但是如果它没法提供该服务时就会抛出一个异常。 如果该服务是可选的呢? TestBed.get() 方法可以接受可选的第二参数,当 Angular 找不到指定的服务提供商时,就会返回该对象service = TestBed.get(NotProvided, null); 一旦调用,TestBed 的配置就会在当前测试期间被冻结。
1
userService = TestBed.get(UserService);
* initTestEnvironment 为整套测试的运行初始化测试环境。 测试垫片(karma-test-shim, browser-test-shim)会为你调用它,所以你很少需要自己调用它。 这个方法只能被调用一次。如果确实需要在测试程序运行期间改变这个默认设置,那么先调用 resetTestEnvironment。 指定 Angular 编译器工厂,PlatformRef,和默认 Angular 测试模块。 以 @angular/platform-<platform_name>/testing/<platform_name> 的形式提供非浏览器平台的替代品。 * resetTestEnvironment 重设初始测试环境,包括默认测试模块在内。 ComponentFixture 类 TestBed.createComponent<T> 会创建一个组件 T 的实例,并为该组件返回一个强类型的 ComponentFixture。 ComponentFixture 的属性和方法提供了对组件、它的 DOM 和它的 Angular 环境方面的访问。 属性 * componentInstance 被 TestBed.createComponent 创建的组件类实例。 * debugElement 与组件根元素关联的 DebugElement。 debugElement 提供了在测试和调试期间深入探查组件及其 DOM 元素的功能。 它对于测试者是一个极其重要的属性。它的大多数主要成员在后面都有讲解。
1
const bannerDe: DebugElement = fixture.debugElement;
* nativeElement 组件的原生根 DOM 元素。
1
2
3
4
5
it('should have <p> with "banner works!"', () => {
const bannerElement: HTMLElement = fixture.nativeElement;
const p = bannerElement.querySelector('p');
expect(p.textContent).toEqual('banner works!');
});
1
2
3
4
5
6
it('should find the <p> with fixture.debugElement.query(By.css)', () => {
const bannerDe: DebugElement = fixture.debugElement;
const paragraphDe = bannerDe.query(By.css('p'));
const p: HTMLElement = paragraphDe.nativeElement;
expect(p.textContent).toEqual('banner works!');
});
* changeDetectorRef 组件的 ChangeDetectorRef。 在测试一个拥有 ChangeDetectionStrategy.OnPush 的组件,或者在组件的变化测试在你的程序控制下时,ChangeDetectorRef 是最重要的。 方法 fixture 方法使 Angular 对组件树执行某些任务。 在触发 Angular 行为来模拟的用户行为时,调用这些方法。 * detectChanges 为组件触发一轮变化检查。 调用它来初始化组件(它调用 ngOnInit)。或者在你的测试代码改变了组件的数据绑定属性值后调用它。 Angular 不能检测到你已经改变了 personComponent.name 属性,也不会更新 name 的绑定,直到你调用了 detectChanges。 之后,运行 checkNoChanges,来确认没有循环更新,除非它被这样调用:detectChanges(false)。 * autoDetectChanges 设置 fixture 是否应该自动试图检测变化。 当自动检测打开时,测试 fixture 监听 zone 事件,并调用 detectChanges。 当你的测试代码直接修改了组件属性值时,你还是要调用 fixture.detectChanges 来触发数据绑定更新。 默认值是 false,喜欢对测试行为进行精细控制的测试者一般保持它为 false。 * checkNoChanges 运行一次变更检测来确认没有待处理的变化。如果有未处理的变化,它将抛出一个错误。 * isStable 如果 fixture 当前是稳定的,则返回 true。 如果有异步任务没有完成,则返回 false。 * whenStable 返回一个承诺,在 fixture 稳定时解析。 要想在完成了异步活动或异步变更检测之后再继续测试,可以对那个承诺对象进行挂钩。 参见 前面。 * destroy 触发组件的销毁。 DebugElement:提供了对组件的 DOM 的访问。 * nativeElement 与浏览器中 DOM 元素对应(WebWorkers 时,值为 null)。 * query 调用 query(predicate: Predicate<DebugElement>) 会在子树的任意深度中查找能和谓词函数匹配的第一个 DebugElement。 * queryAll 调用 queryAll(predicate: Predicate<DebugElement>) 会在子树的任意深度中查找能和谓词函数匹配的所有 DebugElement。 * injector 宿主依赖注入器。 比如,根元素的组件实例注入器。 * componentInstance 元素自己的组件实例(如果有)。 * context 为元素提供父级上下文的对象。 通常是控制该元素的祖级组件实例。 当一个元素被 *ngFor 重复,它的上下文为 NgForRow,它的 $implicit 属性值是该行的实例值。 比如,*ngFor="let hero of heroes" 里的 hero。 * children DebugElement 的直接子元素。可以通过继续深入 children 来遍历这棵树。 DebugElement 还有 childNodes,即 DebugNode 对象列表。 DebugElement 从 DebugNode 对象衍生,而且通常节点(node)比元素多。测试者通常忽略赤裸节点。 * parent DebugElement 的父级。如果 DebugElement 是根元素,parent 为 null。 * name 元素的标签名字,如果它是一个元素的话。 * triggerEventHandler 如果在该元素的 listeners 集合中有相应的监听器,就根据名字触发这个事件。 如果事件缺乏监听器,或者有其它问题,考虑调用 nativeElement.dispatchEvent(eventObject)。 * listeners 元素的 @Output 属性以及/或者元素的事件属性所附带的回调函数。 * providerTokens 组件注入器的查询令牌。 包括组件自己的令牌和组件的 providers 元数据中列出来的令牌。 * source source 是在源组件模板中查询这个元素的处所。 * references 与模板本地变量(比如 #foo)关联的词典对象,关键字与本地变量名字配对。

生命周期

  1. 钩子与用途
钩子 用途及时机
ngOnChanges() 当 Angular(重新)设置数据绑定输入属性时响应。 该方法接受当前和上一属性值的 SimpleChanges 对象。当被绑定的输入属性的值发生变化时调用,首次调用一定会发生在 ngOnInit() 之前。
ngOnInit() 在构造函数之后马上执行复杂的初始化逻辑,或设置完输入属性之后,对该组件进行准备。在第一轮 ngOnChanges() 完成之后调用,只调用一次。
ngDoCheck() 检测并在发生Angular无法或不愿意自己检测的变化时作出反应。在每个 Angular 变更检测周期中调用,ngOnChanges() 和 ngOnInit() 之后。
ngAfterContentInit() 每次创建了组件的子视图后调用,只调用一次。
ngAfterContentChecked() 子视图中的每一次数据变更后调用。
ngAfterViewInit() 外来内容被投影到组件之后调用。应用:@ViewChild本地变量
ngAfterViewChecked() 外来内容被投影到组件发生变更之后调用。
ngOnDestroy() 该组件消失之前,可用来通知应用程序中其它部分的最后一个时间点。释放不会被垃圾收集器自动回收的资源的地方。取消那些对可观察对象和DOM事件的订阅。停止定时器。注销该指令曾注册到全局服务或应用级服务中的各种回调函数。如果不这么做,就会有导致内存泄露的风险。
  1. 通过侦探(spy),窥探生命周期内部细节:
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    let nextId = 1;

    // Spy on any element to which it is applied.
    // Usage: <div mySpy>...</div>
    @Directive({selector: '[mySpy]'})
    export class SpyDirective implements OnInit, OnDestroy {

    constructor(private logger: LoggerService) { }

    ngOnInit() { this.logIt(`onInit`); }

    ngOnDestroy() { this.logIt(`onDestroy`); }

    private logIt(msg: string) {
    this.logger.log(`Spy #${nextId++} ${msg}`);
    }
    }
1
2
3
<div *ngFor="let hero of heroes" mySpy class="heroes">
{{hero}}
</div>
  1. 输入属性变化:

    1
    2
    3
    4
    5
    6
    7
    8
    ngOnChanges(changes: SimpleChanges) {
    for (let propName in changes) {
    let chng = changes[propName];
    let cur = JSON.stringify(chng.currentValue);
    let prev = JSON.stringify(chng.previousValue);
    this.changeLog.push(`${propName}: currentValue = ${cur}, previousValue = ${prev}`);
    }
    }
  2. 特殊更改,如input的hover,click,输入,由于调用频繁,故逻辑尽量简化

    1
    2
    3
    4
    5
    6
    7
    ngDoCheck() {
    if (this.hero.name !== this.oldHeroName) {
    this.changeDetected = true;
    this.changeLog.push(`DoCheck: Hero name changed to "${this.hero.name}" from "${this.oldHeroName}"`);
    this.oldHeroName = this.hero.name;
    }
    }
  3. 外来内容占位符:

    1
    <ng-content></ng-content>

概念梳理

  1. HTML attribute 与 DOM property 的对比

    attribute 是由 HTML 定义的。property 是由 DOM (Document Object Model) 定义的。

    • 少量 HTML attribute 和 property 之间有着 1:1 的映射,如 id。
    • 有些 HTML attribute 没有对应的 property,如 colspan。
    • 有些 DOM property 没有对应的 attribute,如 textContent。
    • 大量 HTML attribute 看起来映射到了 property…… 但却不像你想的那样!
    • 最后一类尤其让人困惑…… 除非你能理解这个普遍原则:

      attribute 初始化 DOM property,然后它们的任务就完成了。property 的值可以改变;attribute 的值不能改变。

      1.1

      例如,当浏览器渲染

      type
      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      15
      16
      17
      18
      19
      20

      当用户在输入框中输入 “Sally” 时,DOM 元素的 value 这个 property 变成了 “Sally”。 但是该 HTML 的 value 这个 attribute 保持不变。如果你读取 input 元素的 attribute,就会发现确实没变: ```input.getAttribute('value') // 返回 "Bob"```,因此需要用到```document.getElementById("demo1").value;```。

      HTML 的 value 这个 attribute 指定了初始值;DOM 的 value 这个 property 是当前值。

      1.2

      disabled 这个 attribute 是另一种特例。按钮的 disabled 这个 property 是 false,因为默认情况下按钮是可用的。 当你添加 disabled 这个 attribute 时,只要它出现了按钮的 disabled 这个 property 就初始化为 true,于是按钮就被禁用了。

      添加或删除 disabled 这个 attribute 会禁用或启用这个按钮。但 attribute 的值无关紧要,这就是你为什么没法通过 ```<button disabled="false">仍被禁用</button> ```这种写法来启用按钮。

      设置按钮的 disabled 这个 property(如,通过 Angular 绑定)可以禁用或启用这个按钮。 这就是 property 的价值。

      就算名字相同,HTML attribute 和 DOM property 也不是同一样东西。

      ---

      所以,在 Angular 的世界中,attribute 唯一的作用是用来初始化元素和指令的状态。 当进行数据绑定时,只是在与元素和指令的 property 和事件打交道。

      设置attribute的办法:```<tr><td [attr.colspan]="1 + 1">One-Two</td></tr>

  2. 控制视图的封装模式:原生 (Native)、仿真 (Emulated) 和无 (None)

    • Native 没有样式能进来,组件样式出不去。(只适用于有原生 Shadow DOM 支持的浏览器)
    • Emulated (默认值)全局样式能进来,组件样式出不去(会在DOM中加入特殊属性)
    • None 这跟把组件的样式直接放进 HTML 是一样的
  3. 纯(pure)管道与非纯(impure)管道

    纯管道:只有在它检测到输入值发生了纯变更时才会执行纯管道。 纯变更是指对原始类型值(String、Number、Boolean、Symbol)的更改, 或者对对象引用(Date、Array、Function、Object)的更改。

    非纯管道:会在每个组件的变更检测周期中执行,非纯管道可能会被调用很多次,和每个按键或每次鼠标移动一样频繁。

  4. 同步验证器和异步验证器

    同步验证器函数接受一个控件实例,然后返回一组验证错误或 null。你可以在实例化一个 FormControl 时把它作为构造函数的第二个参数传进去。

    异步验证器函数接受一个控件实例,并返回一个承诺(Promise)或可观察对象(Observable),它们稍后会发出一组验证错误或者 null。你可以在实例化一个 FormControl 时把它作为构造函数的第三个参数传进去。

    出于性能方面的考虑,只有在所有同步验证器都通过之后,Angular 才会运行异步验证器。当每一个异步验证器都执行完之后,才会设置这些验证错误。

  5. 可观察对象 vs. 承诺

    • 可观察对象是声明式的,在被订阅之前,它不会开始执行。承诺是在创建时就立即执行的。这让可观察对象可用于定义那些应该按需执行的功能。

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      // declare a publishing operation
      new Observable((observer) => { subscriber_fn });
      // initiate execution
      observable.subscribe(() => {
      // observer handles notifications
      });
      // initiate execution
      new Promise((resolve, reject) => { executer_fn });
      // handle return value
      promise.then((value) => {
      // handle result here
      });
    • 可观察对象能提供多个值。承诺只提供一个。这让可观察对象可用于随着时间的推移获取多个值。

    • 可观察对象会区分串联处理和订阅语句。承诺只有 .then() 语句。这让可观察对象可用于创建供系统的其它部分使用而不希望立即执行的复杂功能。

      • observable.map((v) => 2*v);

      • promise.then((v) => 2*v);

    • 可观察对象的 subscribe() 会负责处理错误。承诺会把错误推送给它的子承诺。这让可观察对象可用于进行集中式、可预测的错误处理。

      1
      2
      3
      4
      5
      6
      obs.subscribe(() => {
      throw Error('my error');
      });
      promise.then(() => {
      throw Error('my error');
      });
    • 可观察对象的订阅是可取消的。取消订阅会移除监听器,使其不再接受将来的值,并通知订阅者函数取消正在进行的工作。承诺是不可取消的。

      1
      2
      const sub = obs.subscribe(...);
      sub.unsubscribe();

      下列代码片段揭示了同样的操作要如何分别使用可观察对象和承诺进行实现。

    • 创建

      可观察对象
      new Observable((observer) => {

      observer.next(123);
      

      });

      承诺
      new Promise((resolve, reject) => {

      resolve(123);
      

      });

    • 转换

      可观察对象
      obs.map((value) => value * 2 );

      承诺
      promise.then((value) => value * 2);

    • 订阅

      可观察对象
      sub = obs.subscribe((value) => {
      console.log(value)
      });

      承诺
      promise.then((value) => {
      console.log(value);
      });

    • 取消订阅

      可观察对象
      sub.unsubscribe();

      承诺被解析时隐式完成。

  6. 可观察对象 vs. 事件 API

    • 创建与取消

      可观察对象

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      // Setup
      let clicks$ = fromEvent(buttonEl, ‘click’);
      // Begin listening
      let subscription = clicks$
      .subscribe(e => console.log(‘Clicked’, e))
      // Stop listening
      subscription.unsubscribe();
      function handler(e) {
      console.log(‘Clicked’, e);
      }

      事件 API

      1
      2
      3
      4
      // Setup & begin listening
      button.addEventListener(‘click’, handler);
      // Stop listening
      button.removeEventListener(‘click’, handler);
    • 订阅

      可观察对象

      1
      2
      3
      observable.subscribe(() => {
      // notification handlers here
      });

      事件 API

      1
      2
      3
      element.addEventListener(eventName, (event) => {
      // notification handler here
      });
    • 配置

      可观察对象
      监听按键,提供一个流来表示这些输入的值。

      1
      2
      3
      fromEvent(inputEl, 'keydown').pipe(
      map(e => e.target.value)
      );

      事件 API
      不支持配置。

      1
      2
      3
      4
      element.addEventListener(eventName, (event) => {
      // Cannot change the passed Event into another
      // value before it gets to the handler
      });
  7. angular启动过程

    AppModule

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    /* JavaScript imports */
    import { BrowserModule } from '@angular/platform-browser';
    import { NgModule } from '@angular/core';
    import { FormsModule } from '@angular/forms';
    import { HttpModule } from '@angular/http';

    import { AppComponent } from './app.component';

    /* the AppModule class with the @NgModule decorator */
    @NgModule({
    //declarations —— 该应用所拥有的组件,当创建更多组件时,要把它们添加到 declarations 中

    declarations: [
    AppComponent
    ],
    //imports —— 导入 BrowserModule 以获取浏览器特有的服务,比如 DOM 渲染、无害化处理和位置(location)

    imports: [
    BrowserModule,
    FormsModule,
    HttpModule
    ],
    //providers —— 各种服务提供商

    providers: [],
    //bootstrap —— 根组件,Angular 创建它并插入 index.html 宿主页面

    bootstrap: [AppComponent]
    })
    export class AppModule { }

    创建指令

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    import { Directive } from '@angular/core';

    @Directive({
    selector: '[appItem]'
    })
    export class ItemDirective {
    // code goes here
    constructor() { }

    }

    然后再app.module.ts中

    1
    2
    3
    4
    5
    6
    import { ItemDirective } from './item.directive';

    declarations: [
    AppComponent,
    ItemDirective
    ],

    服务提供

    1
    2
    3
    4
    5
    6
    7
    8
    import { Injectable } from '@angular/core';
    import { UserModule } from './user.module';

    @Injectable({
    providedIn: UserModule,
    })
    export class UserService {
    }

    路由

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    import { NgModule } from '@angular/core';
    import { Routes, RouterModule } from '@angular/router';

    import { CustomerListComponent } from './customer-list/customer-list.component';

    const routes: Routes = [
    {
    path: '',
    component: CustomerListComponent
    }
    ];

    @NgModule({
    imports: [RouterModule.forChild(routes)],
    exports: [RouterModule]
    })
    export class CustomersRoutingModule { }

前端插件

2018-04-17
  1. 产品专题制作神器

    通过纯前端jquery编写,快速制作产品专题,把psd高效转化为html

  2. js算法

    包括:各种排序算法(快排、归并等),搜索算法(dfs、bfs),最短路径算法(dijkstra),最小生成树算法(prim)

  3. 轮播图和打包样例

    轮播图:滑动式、渐隐渐现式、触摸式、响应式,支持mobile和PC、左右和上下轮播
    打包:gulp和webpack

  4. canvas绘画

    四国军棋棋盘,太极图

asp.net项目

2018-04-17

功能:

  1. urlAdapt
  2. 判断userAgent
  3. 判断是否Wifi
  4. jsonp样例
  5. 移动端页面
  6. 单元测试
  7. ado实体类模型生成mysql entities实体类
  8. UnitOfWork通过context对sql增删改查进行封装,并产生数据表仓库上下文repository
  9. 数据表仓库利用linq,提供各种方法
  10. 静态构造函数
  11. 定时任务-quartz
  12. 文件系统
  13. 文件上传
  14. AES对称加密,用于跨域session和cookie
  15. 深复制泛型list
  16. 获取IP地址
  17. 图形验证码
  18. 视频canvas ffps
  19. opener和fileReader
  20. smtp和exchange发送邮件
  21. 反序列化字符串
  22. lucene全文搜索架构
  23. 商城静态首页样例(后续可能会用框架改写),自动补全,flex,border-box
  24. 表单样例:前端自定义select,radio,scrollBar,省市选择,后端request,response应用
  25. 移动端适配:flexible,sass转换dpr,字体,图片函数

期待更多扩展

  1. 支付接口:微信、支付宝、银行
  2. pdf导出

全文搜索lucene5.3.1说明文档

2018-04-17

1. 工作原理

2. 项目结构

3. 数据结构

4. 业务逻辑

工作原理

全文检索(Full-Text Retrieval)是计算机程序通过扫描文章中的每一个词,对每一个词建立一个索引,指明该词在文章中出现的次数和位置。当用户查询时根据建立的索引查找,类似于通过字典的检索字表查字的过程。关于全文检索的特性,我们要知道:1,只处理文本。2,不处理语义。3,搜索时英文不区分大小写。4,结果列表有相关度排序。

参考:

  1. lucene全文检索精华
  2. 全文检索的基本原理
  3. Lucene5.3.1 API

(1) 分词器

lucene需要通过分词器(analyzer)拆分句子、词组,以便存储和搜索,本项目用的是IK分词器2012V5版本。

友情提示:创建索引的分词方法须与搜索时的分词方法一致。

(2) 创建索引

我们会从数据库拿到一些数据,每个字段对应lucene的每个域(field),经过分词处理的域的组合形成一个文档(document)。如下图:

  • 数据表

    | | 字段1 | 字段2 |
    | ——–| —— | —— |
    | id=1 | abc | abc |
    | id=2 | abc | abc |
    | id=3 | abc | abc |

  • lucene文档

    | | 域1 | 域2 |
    | ——–| —— | —— |
    | 索引1 | a,b,c | a,b,c |
    | 索引2 | a,b,c | a,b,c |
    | 索引3 | a,b,c | a,b,c |

当然,需要事先设置文档的保存路径(directory),设置文档的名字(type),创建写入器(IndexWriter),写入器导致数据每次的改动都要保存(commit)和关闭(close)。

(3) 搜索

(4) 索引表的增删改

  • 增(add):同创建索引
  • 删(delete):删除指定索引(deleteDocuments),删除全部索引(deleteAll)
  • 改(update):更新索引,机制为先删除再创建(updateDocument)

参考样例1

参考样例2

项目结构

  • Lucene531
    • src
      • com.search
        • SearchHelper.java –索引表的增删改查
      • com.model
        • SearchModel.java –数据结构模型类
      • com.servlet
        • InitialServlet.java –初始化索引表入口
        • ManagerServlet.java –索引表增删改入口
        • SearchServlet.java –搜索入口
      • com.util
        • EntryUtil.java –初始化索引表、定时任务、搜索组装
        • HelpUtil.java –工具函数
        • Output.java –异常信息打印
        • SQLUtil.java –获取数据库数据
    • config.properties
    • WebRoot
      • index.html –搜索页面
      • initial.html –初始化索引表页面
      • manager.html –索引表增删改页面

数据结构

  1. 数据模型 SearchModel.java

    与数据库表对应如下:

id(int) name(String) model(String) detail(String) classid(int)
Test id(int) name(varchar) model(varchar) detail(text/varchar) classid(int)
hits(int) updatetime(Date) other(String) visible(Boolean)
Test hits(bigint) updatetime(datetime) other(varchar) visible(bit/smallint)
classname(String)
TestClass classname(varchar)
  1. 搜索数据组装 EntryUtil.java

    2.1 json:空集合和搜索结果数量。(原因:搜索不到结果,或关键词长度小于2)

    数据样例:

    1
    2
    3
    4
    {
    “result” :[],
    “testCount”:”0”
    }

    2.2 test的json数据和test的搜索结果数量。(最多不超过500条)

    数据样例:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    {
    “result” :
    [
    {
    “classid”:”1”,
    ”detail”:”aaa”,
    ”displayorder”:”1”,
    ”hits”:”999”,
    ”id”:”1”,
    ”model”:”sadsad”,
    ”name”:”sad”,
    ”other”:”asd”,
    ”updatetime”:”2012-08-17 16:22:00”,
    ”visible”:”true”,
    ”classname”:”asddd”
    },
    {...},
    ...,
    {...}
    ],
    “testCount”:”500”
    }

    2.3 增删改和初始化索引表

    成功:

    1
    [{“errCode”:0}]

    失败:

    1
    [{“errCode”:-1}]

业务逻辑

函数实现

  1. EntryUtil.java –初始化索引表、定时任务、搜索组装

    1.1 static 静态构造函数

    • 第一次访问会初始化索引表和设置定时初始化索引表任务。

      1.2 Boolean initializeIndex() 初始化索引表

    • 创建索引表

    • 返回标志符

      1.3 void setTime() 定时初始化索引表任务

    • 设置每天24:00调用初始化索引表函数

      1.4 String searchServer(String keywords,String type) 返回搜索数据

    • 过滤关键词长度小于2

    • 搜索关键词,并获得搜索结果数量
    • 数据组装(详见数据结构第2点)
  1. SQLUtil.java –获取数据库数据

    2.1 static SQLUtil getInstance() 获取数据库实例

    2.2 Connection getConnection() 数据库连接

    • 获取配置文件中的链接字符串
    • 设置数据库驱动
    • 获取连接并返回

      2.3 ArrayList getProductList() 获取test列表

    • 执行SQL语句

    • 填充数据模型(详见数据结构第1点)
    • 关闭连接

      2.4 SearchModel getProductChangedData(String id) 获取test改动数据

    • 执行SQL语句

    • 填充数据模型(详见数据结构第1点)
    • 关闭连接
  2. HelpUtil.java –工具函数

    3.1 String filterHtml(String html) 过滤危险字符

    • 去除js的&nbsp
    • 去除html及其属性
    • 将标点符号 Unicode空白符替换为“|”

      3.2 Boolean filterString_setBootst(String s) 判断是否常用词

    • 常用词包括aa,bb,cc,dd

      3.3 String[] mergeIdentical(String[] str) 合并字符串数组中相同的字符串

      3.4 String convertToJson(ArrayList datalist) 列表转json

      3.5 ArrayList fillDisplayorder(ArrayList datalist) 填充列表的displayorder项,按升序排列

      3.6 String responseFormat(String maindata,String dataCount) 数据组装函数

      3.7 日期和字符串相互转换函数

    • String dateToString(Date date)

    • Date stringToDate(String dateString)
  3. SearchHelper.java –索引表的增删改查

    4.1 FSDirectory getDirectory(String type) 创建文档

    • 获取配置文件的文档文件夹路径
    • 创建文件并返回

      4.2 String Token(String str) 分词

    • 使用IK分词,词组以“|”隔开

      4.3 boolean createIndex(ArrayList datalist, String type) 创建索引

    • 创建IK分析器 Analyzer

    • 创建文档 getDirectory
    • 配置分析器 IndexWriterConfig
    • 创建写入器 IndexWriter
    • 清空文档索引内容 deleteAll
    • 创建每一条索引 createSingleIndex
    • 保存和关闭

      4.4 boolean createSingleIndex(IndexWriter iwriter, SearchModel data) 创建一条索引

    • 新建文档 Document

    • 设置文档属性 FieldType

      • setStoreTermVectorOffsets 记录相对增量
      • setStoreTermVectorPositions 记录位置信息
      • setStoreTermVectors 存储向量信息
      • freeze 阻止改动信息
    • 创建域 Field

    • 设置域权重 setBoost
    • 向文档加入域 add
    • 写入文档 addDocument

      4.5 ArrayList search(String keywords, String type) 查询关键词

    • 过滤危险字符

    • 打开文档,创建分析器
    • 关键词分词
      • IK分词数组,权重最小
      • 纯数字和字母数组(字母和数字分开)
      • 纯数字和字母数组(字母和数字可以连在一起),权重最大
    • 使用多种搜索方式组合搜索(详见工作原理第(3)点)
    • 查询结果高亮

      • FragListBuilder使用SimpleFragListBuilder
      • FragmentsBuilder使用ScoreOrderFragmentsBuilder
      • FastVectorHighlighter
      • getFieldQuery
      • getBestFragment
    • 数据按需填充,如限制得分或条数

    • 关闭写入器和文档

      4.6 int searchByTerm(String field,String name,String type) 查找域目标数量

    • 通过精确查询,计算目标数量

      4.7 int getSearchCount(String keywords, String type) 获取搜索结果条数

    • 与搜索关键词的搜索逻辑相同,搜索完后计数

      4.8 索引增删改

    • boolean addIndex(SearchModel data, String type)

    • boolean updateIndex(String id, SearchModel data, String type)
    • boolean deleteAllIndex(String type)
    • boolean deleteIndex(String id, String type)
  4. Output.java –异常信息打印

    5.1 boolean createFile(String fileName,String filecontent) 创建文件

    5.2 boolean writeFileContent(String filepath,String newstr) 向文件中写入内容

函数关系

InitialServlet 初始化索引表流程

直接初始化索引,详见1.2

ManagerServlet 索引表增删改流程

  1. java获取post参数
  2. 判断type
  3. 判断id是否存在
    • 若存在:判断visible:1为更新索引操作;0为删除索引操作
    • 若不存在:判断visible:1为插入索引;0不做任何操作
  • visible:2.4
  • 更新索引操作:4.8
  • 删除索引操作:4.8
  • 插入索引:4.8
  • 异常:获取数据库数据为空

SearchServlet 搜索流程

大致流程:

0 1 2 3 4 5 6 7 8
1 1.1 1.2 1.3 return
4.3 4.8 4.4 return
2 1.4 3.1 4.5 4.7 3.5 3.4 3.6 return

Express项目

2018-04-17

node app

浏览器:localhost:3000

首页 (/)

根据session,显示p Hello 名字,没登录,名字为visitor

登录 (/login)

连接数据库,校验登录信息。

其中,密码通过时间进行md5加密。

登录后记录session,需要session秘钥和中间件。

注册 (/register)

连接数据库。

密码通过时间进行md5加密。

注册后记录session。

获取姓名 (/getname)ajax

获取session姓名

聊天室 (/chat)

检查用户名

websocket

  • connection 提示用户加入,显示在线列表
  • disconnect 提示用户退出
  • message 广播信息,加密通信,可防抓包窃听

其它

  • 为传图方便,开放跨域攻击,没过滤内容
  • 由于会出现加解密乱码,故舍弃自定义进制加密法
  • 用户名:0f4a@cf9bu5#6h&
  • 密码:111
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
//加密通信用到的函数(在控制台输入)
function encrypt(str, pwd) {
if(str == '') {
return '';
}
str = encodeURIComponent(str);
if(!pwd || pwd == '') {
pwd = 'kb1234a';
}
pwd = encodeURIComponent(pwd);
if(pwd == '' || pwd.length <= 0) {
return '';
}
var prand = '';
for(var i = 0, len = pwd.length; i < len; i += 1) {
prand += pwd.charCodeAt(i).toString();
}
var sPos = Math.floor(prand.length / 5);
var mult = parseInt(prand.charAt(sPos) + prand.charAt(sPos * 2) + prand.charAt(sPos * 3) +
prand.charAt(sPos * 4) + prand.charAt(sPos * 5));
var incr = Math.ceil(pwd.length / 2);
var modu = Math.pow(2, 31) - 1;
if(mult < 2) {
return '';
}
var salt = Math.round(Math.random() * 1000000000) % 100000000;
prand += salt;
while(prand.length > 10) {
prand = (parseInt(prand.substring(0, 10)) +
parseInt(prand.substring(10, prand.length))).toString();
}
prand = (mult * prand + incr) % modu;
var encChr = '';
var encStr = '';
for(var i = 0, len = str.length; i < len; i += 1) {
encChr = parseInt(str.charCodeAt(i) ^ Math.floor((prand / modu) * 255));
if(encChr < 16) {
encStr += '0' + encChr.toString(16);
}else{
encStr += encChr.toString(16);
}
prand = (mult * prand + incr) % modu;
}
salt = salt.toString(16);
while(salt.length < 8) {
salt = "0" + salt;
}
encStr += salt;
return encStr;
}

function decrypt(str, pwd) {
if(str == ''){
return '';
}
if(!pwd || pwd == ''){
pwd = 'kb1234a';
}
pwd = encodeURIComponent(pwd);
if(str == undefined || str.length < 8) {
return '';
}
if(pwd == undefined || pwd.length <= 0) {
return '';
}
var prand = '';
for(var i = 0, len = pwd.length; i < len; i += 1) {
prand += pwd.charCodeAt(i).toString();
}
var sPos = Math.floor(prand.length / 5);
var mult = parseInt(prand.charAt(sPos) + prand.charAt(sPos * 2) + prand.charAt(sPos * 3) +
prand.charAt(sPos * 4) + prand.charAt(sPos * 5));
var incr = Math.round(pwd.length / 2);
var modu = Math.pow(2, 31) - 1;
var salt = parseInt(str.substring(str.length - 8, str.length), 16);
str = str.substring(0, str.length - 8);
prand += salt;
while(prand.length > 10) {
prand = (parseInt(prand.substring(0, 10)) +
parseInt(prand.substring(10, prand.length))).toString();
}
prand = (mult * prand + incr) % modu;
var encChr = '';
var encStr = '';
for(var i = 0, len = str.length; i < len; i += 2) {
encChr = parseInt(parseInt(str.substring(i, i + 2), 16) ^ Math.floor((prand / modu) * 255));
encStr += String.fromCharCode(encChr);
prand = (mult * prand + incr) % modu;
}
return decodeURIComponent(encStr);
}
<<<<<<< HEAD

function html2Escape(sHtml) {
return sHtml.replace(/[<>&"]/g,function(c){return {'<':'&lt;','>':'&gt;','&':'&amp;','"':'&quot;'}[c];});
}


<script>window.location="http://baidu.com"</script>


=======

多人聊天室 (/roomchat) 未完成

上传 (/upload)

  • 上传图片,完成后直接显示
  • 上传文件,显示进度、速度,可中断

CentOS7 环境部署

2018-04-17

mysql安装:

用MariaDB代替

教程:http://blog.csdn.net/lipingping951462/article/details/51898191

导入数据库:http://blog.csdn.net/guochaoxxl/article/details/52784565

Centos7 下mysql大小写敏感:

  1. 编辑/etc/my.cnf文件,在[mysqld]节下 添加 lower_case_table_names=1 参数,并设置相应的值 (备注:为0时大小写敏感,为1时大小写不敏感,默认为0)。(必须是在[mysqld]节点下添加,否则没有效果)

  2. 重启mariadb:
    systemctl restart mariadb.service

Jexus 大小写敏感解决:

  1. cd /usr/jexus/
  2. vim jws
  3. 将#export MONO_IOMAP=”all”前面的“#”去掉!
  4. 重启Jexus服务: /usr/jexus/jws restart

.net 环境搭建

教程:http://blog.csdn.net/u010098331/article/details/51647977

远程传文件夹

1
$ scp -r TPLINKmWebsite root@172.31.249.6:/var/www

命令含义:

防火墙设置

关闭防火墙

1
2
systemctl stop firewalld.service             #停止firewall
systemctl disable firewalld.service #禁止firewall开机启动

开启端口

1
firewall-cmd --zone=public --add-port=80/tcp --permanent

命令含义:

  • –zone #作用域
  • –add-port=80/tcp #添加端口,格式为:端口/通讯协议
  • –permanent #永久生效,没有此参数重启后失效

重启防火墙

1
firewall-cmd --reload

tomcat

1
2
3
4
5
6
systemctl start tomcat
systemctl restart tomcat
systemctl stop tomcat
/usr/share/tomcat
输入命令开启日志打印输出,命令# tail -f catalina.out
ctrl+c退出打印,返回命令行

ps命令显示进程

1
ps -ef|grep tomcat

nginx

  • nginx提示地址或端口被占用解决
    http://blog.csdn.net/mtm2012/article/details/42775647

  • DNS重启失效的解决
    https://www.cnblogs.com/lcword/p/5917468.html

  • 各种报错,以下必须写到nginx.conf下,不能include

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    79
    80
    81
    82
    83
    84
    85
    86
    87
    88
    89
    upstream smb {
    server 192.168.153.132:8080;
    }

    upstream security {
    server 192.168.153.132:8081;
    }

    upstream service {
    server 192.168.153.132:8082;
    }

    upstream web {
    server 192.168.153.132:8083;
    }

    upstream webm {
    server 192.168.153.132:8084;
    }

    server {
    listen 8090;
    server_name 192.168.153.132:8090;

    #charset koi8-r;

    #access_log logs/host.access.log main;

    location / {
    proxy_pass http://smb;
    index index.html index.htm;
    }
    }

    server {
    listen 8091;
    server_name 192.168.153.132:8091;

    #charset koi8-r;

    #access_log logs/host.access.log main;

    location / {
    proxy_pass http://security;
    index index.html index.htm;
    }
    }

    server {
    listen 8092;
    server_name 192.168.153.132:8092;

    #charset koi8-r;

    #access_log logs/host.access.log main;

    location / {
    proxy_pass http://service;
    index index.html index.htm;
    }
    }

    server {
    listen 8093;
    server_name 192.168.153.132:8093;

    #charset koi8-r;

    #access_log logs/host.access.log main;

    location / {
    proxy_pass http://web;
    index index.html index.htm;
    }
    }

    server {
    listen 8094;
    server_name 192.168.153.132:8094;

    #charset koi8-r;

    #access_log logs/host.access.log main;

    location / {
    proxy_pass http://webm;
    index index.html index.htm;
    }
    }

更多参考:

  1. Linux常用操作:https://github.com/xpsilvester/Notes/tree/master/Linux
  2. workbranch使用教程:https://jingyan.baidu.com/article/3f16e003c2da162591c103e4.html
  3. windows-mysql安装教程:

    3.1 http://www.jb51.net/article/127626.htm

    3.2 http://blog.csdn.net/JLongSL/article/details/56484762
  4. centos-mysql安装教程:

    4.1 http://blog.csdn.net/u011673111/article/details/50962862

    4.2 http://blog.csdn.net/zhu19774279/article/details/51602001
  5. centos-workbranch安装教程:http://blog.csdn.net/zzpzheng/article/details/48575963
  6. centos-asp.net环境搭建:http://blog.csdn.net/u010098331/article/details/51647977
  7. centos-nginx安装:http://blog.csdn.net/u012402276/article/details/51985172
  8. centos-php/apache安装:http://www.linuxidc.com/Linux/2014-12/111030.htm
  9. mysql大小写设置不敏感:https://www.cnblogs.com/xinhuaxuan/p/6537879.html

centos6 命令记录

  • sudo /etc/init.d/mysqld restart #重启mysql
  • sudo /etc/init.d/mysqld stop #停止mysql
  • sudo /etc/init.d/mysqld start #启动mysql
  • sudo /etc/init.d/httpd restart #重启Apche
  • sudo /usr/jexus/jws start #启动Jexus
  • sudo /usr/local/nginx-1.11.2/sbin/nginx #启动nginx
  • sudo /usr/local/nginx-1.11.2/sbin/nginx -s reload #重启nginx
  • sudo /usr/local/nginx-1.11.2/sbin/nginx -s stop #停止nginx
  • service iptables restart #重启防火墙

git 基本命令

2018-04-17
avatar zhaoyangkanshijie blog