8)使用Service Worker进行后台同步 - Background Sync
后台同步可以让你在关闭网站后,进行一些被中断的请求或操作
本文中的代码可以在learning-pwa的sync分支上找到(git clone后注意切换到sync分支)。

1. 引言

生活中经常会有这样的场景:
用户拿出手机,浏览着我们的网站,发现了一个很有趣的信息,点击了“提交”按钮。然而不幸的是,这时用户到了一个网络环境极差的地方,或者是根本没有网络。他能够做的只有看着页面上的提示框和不断旋转的等待小圆圈。1s、5s、30s、1min……无尽的等待后,用户将手机放回了口袋,而这一次的请求也被终止了——由于当下极差的网络终止在了客户端。
上面的场景其实暴露了两个问题:
  1. 1.
    普通的页面发起的请求会随着浏览器进程的结束/或者Tab页面的关闭而终止;
  2. 2.
    无网环境下,没有一种机制能“维持”住该请求,以待有网情况下再进行请求。
然而,Service Worker的后台同步功能规避了这些缺陷。
Could not load image
后台同步功能演示
下面就让我们先来了解下后台同步(Background Sync)的工作原理。

2. 后台同步(Background Sync)是如何工作的?

后台同步应该算是Service Worker相关功能(API)中比较易于理解与使用的一个。
其大致的流程如下:
Could not load image
后台同步流程
  1. 1.
    首先,你需要在Service Worker中监听sync事件;
  2. 2.
    然后,在浏览器中发起后台同步sync(图中第一步);
  3. 3.
    之后,会触发Service Worker的sync事件,在该监听的回调中进行操作,例如向后端发起请求(图中第二步)
  4. 4.
    最后,可以在Service Worker中对服务端返回的数据进行处理。
由于Service Worker在用户关闭该网站后仍可以运行,因此该流程名为“后台同步”实在是非常贴切。
怎么样,在我们已经有了一定的Service Worker基础之后,后台同步这一功能相比之前的功能,是不是非常易于理解?

3. 如何使用后台同步功能?

既然已经理解了该功能的大致流程,那么接下来就让我们来实际操作一下吧。

3.1 client触发sync事件

1
// index.js
2
navigator.serviceWorker.ready.then(function (registration) {
3
var tag = "sample_sync";
4
document.getElementById('js-sync-btn').addEventListener('click', function () {
5
registration.sync.register(tag).then(function () {
6
console.log('后台同步已触发', tag);
7
}).catch(function (err) {
8
console.log('后台同步触发失败', err);
9
});
10
});
11
});
Copied!
由于后台同步功能需要在Service Worker注册完成后触发,因此较好的一个方式是在navigator.serviceWorker.ready之后绑定相关操作。例如上面的代码中,我们在ready后绑定了按钮的点击事件。当按钮被点击后,会使用registration.sync.register()方法来触发Service Worker的sync事件。
registration.sync返回一个SyncManager对象,其上包含registergetTags两个方法:
register() Create a new sync registration and return a Promise.
getTags() Return a list of developer-defined identifiers for SyncManager registration.
register()方法可以注册一个后台同步事件,其中接收的参数tag用于作为这个后台同步的唯一标识。
当然,如果想要代码更健壮的话,我们还需要在调用前进行特性检测:
1
// index.js
2
if ('serviceWorker' in navigator && 'SyncManager' in window) {
3
// ……
4
}
Copied!

3.2 在Service Worker中监听sync事件

当client触发了sync事件后,剩下的就交给Service Worker。理论上此时就不需要client(前端站点)参与了。例如另一个经典场景:用户离开时页面(unload)时在client端触发sync事件,剩下的操作交给Service Worker,Service Worker的操作可以在离开页面后正常进行。
像添加fetch和push事件监听那样,我们可以为Service Worker添加sync事件的监听:
1
// sw.js
2
self.addEventListener('sync', function (e) {
3
// ……
4
});
Copied!
在sync事件的event对象上可以取到tag值,该值就是我们在上一节注册sync时的唯一标识。通过这个tag就可以区分出不同的后台同步事件。例如,当该值为'sample_sync'时我们向后端发送一个请求:
1
// sw.js
2
self.addEventListener('sync', function (e) {
3
console.log(`service worker需要进行后台同步,tag: ${e.tag}`);
4
var init = {
5
method: 'GET'
6
};
7
if (e.tag === 'sample_sync') {
8
var request = new Request(`sync?name=AlienZHOU`, init);
9
e.waitUntil(
10
fetch(request).then(function (response) {
11
response.json().then(console.log.bind(console));
12
return response;
13
})
14
);
15
}
16
});
Copied!
这里我通过e.tag来判断client触发的不同sync事件,并在监听到tag为'sample_sync'的sync事件后,构建了一个request对象,使用fetch API来进行后端请求。
需要特别注意的是,fetch请求一定要放在e.waitUntil()内。因为我们要保证“后台同步”,将Promise对象放在e.waitUntil()内可以确保在用户离开我们的网站后,Service Worker会持续在后台运行,等待该请求完成。

3.3 完善我们的后端服务

实际上,经过上面两小节,我们的大致工作已经完成。不过还缺少一个小环节:我们的KOA服务器上还没有sync路由和接口。添加一下,以保证demo可以正常运行:
1
// app.js
2
router.get('/sync', async (ctx, next) => {
3
console.log(`Hello ${ctx.request.query.name}, I have received your msg`);
4
ctx.response.body = {
5
status: 0
6
};
7
});
Copied!

3.4 Demo效果展示

下面就来看一下这个demo的运行效果:
Could not load image
demo演示
可以看到,在网络环境正常的情况下,点击“同步”按钮会立即触发Service Worker中的sync事件监听,并向服务端发送请求;而在断网情况下,点击“同步”按钮,控制台虽然显示注册了同步事件,但是并不会触发Service Worker的sync监听回调,指到恢复网络连接,才会在后台(Service Worker)中进行相关处理。
下面再来看一下触发sync事件后,关闭网站的效果:
Could not load image
demo演示
可以看到,即使在关闭网站后再重新连接网络,服务端依然可以收到来自客户端的请求(说明Service Worker在后台进行了相关处理)。

4. 如何在后台同步时获取所需的数据?

其实上一节结束,我们就已经可以了解最基础的后台同步功能了。而这部分则会进一步探讨后台同步中的一个重要问题:如何在后台同步时获取并发送client中的数据?
例如在我们的上一个Demo中,用户的姓名name是硬编码在Service Worker中的,而实际上,我们希望能在页面上提供一个输入框,将用户的输入内容在后台同步中进行发送。
实现的方式有两种:使用postMessage或使用indexedDB。

4.1 使用postMessage

我们知道,在浏览器主线程与Web Worker线程之间可以通过postMessage来进行通信。因此,我们也可以使用这个方法来向Service Worker“传输”数据。
大致思路如下:
  1. 1.
    client触发sync事件;
  2. 2.
    在sync注册完成后,使用postMessage和Service Worker通信;
  3. 3.
    在Service Worker的sync事件回调中等待message事件的消息;
  4. 4.
    收到message事件的消息后,将其中的信息提交到服务端。
1
// index.js
2
// 使用postMessage来传输sync数据
3
navigator.serviceWorker.ready.then(function (registration) {
4
var tag = 'sample_sync_event';
5
6
document.getElementById('js-sync-event-btn').addEventListener('click', function () {
7
registration.sync.register(tag).then(function () {
8
console.log('后台同步已触发', tag);
9
10
// 使用postMessage进行数据通信
11
var inputValue = document.querySelector('#js-search-input').value;
12
var msg = JSON.stringify({type: 'bgsync', msg: {name: inputValue}});
13
navigator.serviceWorker.controller.postMessage(msg);
14
}).catch(function (err) {
15
console.log('后台同步触发失败', err);
16
});
17
});
18
});
Copied!
registration.sync.register完成后,调用navigator.serviceWorker.controller.postMessage来向Service Worker Post数据。
为了提高代码的可维护性,我在sw.js中创建了一个SimpleEvent类,你可以把它看做一个最简单的EventBus。用来解耦Service Worker的message事件和sync事件。
1
// sw.js
2
class SimpleEvent {
3
constructor() {
4
this.listenrs = {};
5
}
6
7
once(tag, cb) {
8
this.listenrs[tag] || (this.listenrs[tag] = []);
9
this.listenrs[tag].push(cb);
10
}
11
12
trigger(tag, data) {
13
this.listenrs[tag] = this.listenrs[tag] || [];
14
let listenr;
15
while (listenr = this.listenrs[tag].shift()) {
16
listenr(data)
17
}
18
}
19
}
Copied!
在message事件中监听client发来的消息,并通过SimpleEvent通知所有监听者。
1
// sw.js
2
const simpleEvent = new SimpleEvent();
3
self.addEventListener('message', function (e) {
4
var data = JSON.parse(e.data);
5
var type = data.type;
6
var msg = data.msg;
7
console.log(`service worker收到消息 type:${type};msg:${JSON.stringify(msg)}`);
8
9
simpleEvent.trigger(type, msg);
10
});
Copied!
在sync事件中,使用SimpleEvent监听bgsync来获取数据,然后再调用fetch方法。注意,由于e.waitUntil()需要接收Promise作为参数,因此需要对SimpleEvent.once进行Promisfy。
1
// sw.js
2
self.addEventListener('sync', function (e) {
3
if (e.tag === xxx) {
4
// ……
5
}
6
7
// sample_sync_event同步事件,使用postMessage来进行数据通信
8
else if (e.tag === 'sample_sync_event') {
9
// 将SimpleEvent.once封装为Promise调用
10
let msgPromise = new Promise(function (resolve, reject) {
11
// 监听message事件中触发的事件通知
12
simpleEvent.once('bgsync', function (data) {
13
resolve(data);
14
});
15
// 五秒超时
16
setTimeout(resolve, 5000);
17
});
18
19
e.waitUntil(
20
msgPromise.then(function (data) {
21
var name = data && data.name ? data.name : 'anonymous';
22
var request = new Request(`sync?name=${name}`, init);
23
return fetch(request)
24
}).then(function (response) {
25
response.json().then(console.log.bind(console));
26
return response;
27
})
28
);
29
}
30
});
Copied!
是不是非常简单?
Could not load image
demo演示
进行后台同步时,使用postMessage来实现client向Service Worker的传输数据,方便与直观,是一个不错的方法。

4.2 使用indexedDB

在client与Servcie Worker之间同步数据,还有一个可行的思路:client先将数据存在某处,待Servcie Worker需要时再读取使用即可。
为此需要找一个存数据的地方。你第一个想到的可能就是localStorage了。
然而,不知道你是否还记得我在最开始介绍Service Worker时所提到的,为了保证性能,实现部分操作的非阻塞,在Service Worker中我们经常会碰到异步操作(因此大多数API都是Promise形式的)。那么像localStorage这样的同步API会变成异步化么?答案很简单:不会,并且localStorage在Servcie Worker中无法调用。
不过不要气馁,我们还另一个强大的数据存储方式——indexedDB。它是可以在Service Worker中使用的。对于indexedDB的使用方式,本系列后续会有文章具体介绍,因此在这里的就不重点讲解indexedDB的使用方式了。
首先,需要一个方法用于连接数据库并创建相应的store:
1
// index.js
2
function openStore(storeName) {
3
return new Promise(function (resolve, reject) {
4
if (!('indexedDB' in window)) {
5
reject('don\'t support indexedDB');
6
}
7
var request = indexedDB.open('PWA_DB', 1);
8
request.onerror = function(e) {
9
console.log('连接数据库失败');
10
reject(e);
11
}
12
request.onsuccess = function(e) {
13
console.log('连接数据库成功');
14
resolve(e.target.result);
15
}
16
request.onupgradeneeded = function (e) {
17
console.log('数据库版本升级');
18
var db = e.srcElement.result;
19
if (e.oldVersion === 0) {
20
if (!db.objectStoreNames.contains(storeName)) {
21
var store = db.createObjectStore(storeName, {
22
keyPath: 'tag'
23
});
24
store.createIndex(storeName + 'Index', 'tag', {unique: false});
25
console.log('创建索引成功');
26
}
27
}
28
}
29
});
30
}
Copied!
然后,在navigator.serviceWorker.ready中打开该数据库连接,并在点击按钮时,先将数据存入indexedDB,再注册sync:
1
// index.js
2
navigator.serviceWorker.ready.then(function (registration) {
3
return Promise.all([
4
openStore(STORE_NAME),
5
registration
6
]);
7
}).then(function (result) {
8
var db = result[0];
9
var registration = result[1];
10
var tag = 'sample_sync_db';
11
12
document.getElementById('js-sync-db-btn').addEventListener('click', function () {
13
// 将数据存储进indexedDB
14
var inputValue = document.querySelector('#js-search-input').value;
15
var tx = db.transaction(STORE_NAME, 'readwrite');
16
var store = tx.objectStore(STORE_NAME);
17
var item = {
18
tag: tag,
19
name: inputValue
20
};
21
store.put(item);
22
23
registration.sync.register(tag).then(function () {
24
console.log('后台同步已触发', tag);
25
}).catch(function (err) {
26
console.log('后台同步触发失败', err);
27
});
28
});
29
});
Copied!
同样的,在Service Worker中也需要相应的数据库连接方法:
1
// sw.js
2
function openStore(storeName) {
3
return new Promise(function (resolve, reject) {
4
var request = indexedDB.open('PWA_DB', 1);
5
request.onerror = function(e) {
6
console.log('连接数据库失败');
7
reject(e);
8
}
9
request.onsuccess = function(e) {
10
console.log('连接数据库成功');
11
resolve(e.target.result);
12
}
13
});
14
}
Copied!
并且在sync事件的回调中,get到indexedDB中对应的数据,最后再向后端发送请求:
1
// index.js
2
self.addEventListener('sync', function (e) {
3
if (e.tag === xxx) {
4
// ……
5
}
6
else if (e.tag === yyy) {
7
// ……
8
}
9
10
// sample_sync_db同步事件,使用indexedDB来获取需要同步的数据
11
else if (e.tag === 'sample_sync_db') {
12
// 将数据库查询封装为Promise类型的请求
13
var dbQueryPromise = new Promise(function (resolve, reject) {
14
var STORE_NAME = 'SyncData';
15
// 连接indexedDB
16
openStore(e.tag).then(function (db) {
17
try {
18
// 创建事务进行数据库查询
19
var tx = db.transaction(STORE_NAME, 'readonly');
20
var store = tx.objectStore(STORE_NAME);
21
var dbRequest = store.get(e.tag);
22
dbRequest.onsuccess = function (e) {
23
resolve(e.target.result);
24
};
25
dbRequest.onerror = function (err) {
26
reject(err);
27
};
28
}
29
catch (err) {
30
reject(err);
31
}
32
});
33
});
34
35
e.waitUntil(
36
// 通过数据库查询获取需要同步的数据
37
dbQueryPromise.then(function (data) {
38
console.log(data);
39
var name = data && data.name ? data.name : 'anonymous';
40
var request = new Request(`sync?name=${name}`, init);
41
return fetch(request)
42
}).then(function (response) {
43
response.json().then(console.log.bind(console));
44
return response;
45
})
46
);
47
}
48
});
Copied!
相比于postMessage,使用indexedDB的方案要更复杂一点。它比较适用于一些需要数据持久化的场景。
Could not load image
在后台同步中使用indexedDB

5. 兼容性

依照惯例,我们还是来简单看一下文中相关功能的兼容性。
Could not load image
令人悲伤的是,基本只有Google自家的Chrome可用。
然后是indexedDB
Could not load image
相较于Background Sync还是有着不错的兼容性的。而且在safari(包括iOS safari)中也得到了支持。

6. 写在最后

从文中的内容以及google developer中的一些实例来看,Background Sync是一个非常有潜力的API。然而令人堪忧的兼容性在一定程度上限制了它的发挥空间。不过,作为一项技术,还是非常值得我们学习与了解的。本文中所有的代码示例均可以在learn-pwa/sync上找到。
到目前为止,我们已经学习了PWA中的多个知识点,在其基础上,已经可以帮助我们进行原有站点的PWA升级。学习是一方面,实践是另一方面。在下一篇文章里,我会整理一些在业务中升级PWA时碰到的问题,以及对应的解决方案。

参考资料