第七章 Web开发实战2——商品详情页

电玩女神 2023-10-17 14:06 42阅读 0赞

本章以京东商品详情页为例，京东商品详情页虽然仅是单个页面，但是其数据聚合源是非常多的，除了一些实时性要求比较高的如价格、库存、服务支持等通过AJAX异步加载加载之外，其他的数据都是在后端做数据聚合然后拼装网页模板的。

[http://item.jd.com/1217499.html][http_item.jd.com_1217499.html]  
![点击查看原始大小图片][57080353-3ed7-3f34-84fc-9ab7d8a31e16.png]  
  
![点击查看原始大小图片][3e17cf60-74a5-3a29-90af-6a17a7cef5d6.png]

如图所示，商品页主要包括商品基本信息（基本信息、图片列表、颜色/尺码关系、扩展属性、规格参数、包装清单、售后保障等）、商品介绍、其他信息（分类、品牌、店铺【第三方卖家】、店内分类【第三方卖家】、同类相关品牌）。更多细节此处就不阐述了。

整个京东有数亿商品，如果每次动态获取如上内容进行模板拼装，数据来源之多足以造成性能无法满足要求；最初的解决方案是生成静态页，但是静态页的最大的问题：1、无法迅速响应页面需求变更；2、很难做多版本线上对比测试。如上两个因素足以制约商品页的多样化发展，因此静态化技术不是很好的方案。

通过分析，数据主要分为四种：商品页基本信息、商品介绍（异步加载）、其他信息（分类、品牌、店铺等）、其他需要实时展示的数据（价格、库存等）。而其他信息如分类、品牌、店铺是非常少的，完全可以放到一个占用内存很小的Redis中存储；而商品基本信息我们可以借鉴静态化技术将数据做聚合存储，这样的好处是数据是原子的，而模板是随时可变的，吸收了静态页聚合的优点，弥补了静态页的多版本缺点；另外一个非常严重的问题就是严重依赖这些相关系统，如果它们挂了或响应慢则商品页就挂了或响应慢；商品介绍我们也通过AJAX技术惰性加载（因为是第二屏，只有当用户滚动鼠标到该屏时才显示）；而实时展示数据通过AJAX技术做异步加载；因此我们可以做如下设计：

1、接收商品变更消息，做商品基本信息的聚合，即从多个数据源获取商品相关信息如图片列表、颜色尺码、规格参数、扩展属性等等，聚合为一个大的JSON数据做成数据闭环，以key-value存储；因为是闭环，即使依赖的系统挂了我们商品页还是能继续服务的，对商品页不会造成任何影响；

2、接收商品介绍变更消息，存储商品介绍信息；

3、介绍其他信息变更消息，存储其他信息。

整个架构如下图所示：  
![点击查看原始大小图片][5342ca19-7fd1-3719-8aea-6513cf2fbe3e.png]

### 技术选型 ###

MQ可以使用如[Apache ActiveMQ][]；

Worker/动态服务可以通过如Java技术实现；

RPC可以选择如[alibaba Dubbo][]；

KV持久化存储可以选择[SSDB][]（如果使用SSD盘则可以选择[SSDB+RocksDB引擎][SSDB_RocksDB]）或者[ARDB][]（LMDB引擎版）；

缓存使用Redis；

SSDB/Redis分片使用如Twemproxy，这样不管使用Java还是Nginx+Lua，它们都不关心分片逻辑；

前端模板拼装使用Nginx+Lua；

数据集群数据存储的机器可以采用RAID技术或者主从模式防止单点故障；

因为数据变更不频繁，可以考虑SSD替代机械硬盘。

### 核心流程 ###

1、首先我们监听商品数据变更消息；

2、接收到消息后，数据聚合Worker通过RPC调用相关系统获取所有要展示的数据，此处获取数据的来源可能非常多而且响应速度完全受制于这些系统，可能耗时几百毫秒甚至上秒的时间；

3、将数据聚合为JSON串存储到相关数据集群；

4、前端Nginx通过Lua获取相关集群的数据进行展示；商品页需要获取基本信息+其他信息进行模板拼装，即拼装模板仅需要两次调用（另外因为其他信息数据量少且对一致性要求不高，因此我们完全可以缓存到Nginx本地全局内存，这样可以减少远程调用提高性能）；当页面滚动到商品介绍页面时异步调用商品介绍服务获取数据；

5、如果从聚合的SSDB集群/Redis中获取不到相关数据；则回源到动态服务通过RPC调用相关系统获取所有要展示的数据返回（此处可以做限流处理，因为如果大量请求过来的话可能导致服务雪崩，需要采取保护措施），此处的逻辑和数据聚合Worker完全一样；然后发送MQ通知数据变更，这样下次访问时就可以从聚合的SSDB集群/Redis中获取数据了。

基本流程如上所述，主要分为Worker、动态服务、数据存储和前端展示；因为系统非常复杂，只介绍动态服务和前端展示、数据存储架构；Worker部分不做实现。

### 项目搭建 ###

项目部署目录结构。

/usr/chapter7

ssdb\_basic\_7770.conf

ssdb\_basic\_7771.conf

ssdb\_basic\_7772.conf

ssdb\_basic\_7773.conf

ssdb\_desc\_8880.conf

ssdb\_desc\_8881.conf

ssdb\_desc\_8882.conf

ssdb\_desc\_8883.conf

redis\_other\_6660.conf

redis\_other\_6661.conf

nginx\_chapter7.conf

nutcracker.yml

nutcracker.init

item.html

header.html

footer.html

item.lua

desc.lua

lualib

item.lua

item

common.lua

webapp

WEB-INF

lib

classes

web.xml

### 数据存储实现 ###

![点击查看原始大小图片][2068df57-dea0-3cb1-980b-d66745a99622.png]

整体架构为主从模式，写数据到主集群，读数据从从集群读取数据，这样当一个集群不足以支撑流量时可以使用更多的集群来支撑更多的访问量；集群分片使用Twemproxy实现。

**商品基本信息SSDB集群配置**

vim /usr/chapter7/ssdb\_basic\_7770.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_7770 
2.  pidfile = /usr/data/ssdb\_7770.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 7770
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14. logger: 
15.  level: error 
16.  output: /usr/data/ssdb\_7770.log 
17.  rotate: 
18.  size: 1000000000
19. 
20. leveldb: 
21.  cache\_size: 500
22.  block\_size: 32
23.  write\_buffer\_size: 64
24.  compaction\_speed: 1000
25.  compression: yes

vim /usr/chapter7/ssdb\_basic\_7771.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_7771 
2.  pidfile = /usr/data/ssdb\_7771.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 7771
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14. logger: 
15.  level: error 
16.  output: /usr/data/ssdb\_7771.log 
17.  rotate: 
18.  size: 1000000000
19. 
20. leveldb: 
21.  cache\_size: 500
22.  block\_size: 32
23.  write\_buffer\_size: 64
24.  compaction\_speed: 1000
25.  compression: yes

vim /usr/chapter7/ssdb\_basic\_7772.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_7772 
2.  pidfile = /usr/data/ssdb\_7772.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 7772
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14.  type: sync 
15.  ip: 127.0.0.1
16.  port: 7770
17. 
18. logger: 
19.  level: error 
20.  output: /usr/data/ssdb\_7772.log 
21.  rotate: 
22.  size: 1000000000
23. 
24. leveldb: 
25.  cache\_size: 500
26.  block\_size: 32
27.  write\_buffer\_size: 64
28.  compaction\_speed: 1000
29.  compression: yes

vim /usr/chapter7/ssdb\_basic\_7773.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_7773 
2.  pidfile = /usr/data/ssdb\_7773.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 7773
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14.  type: sync 
15.  ip: 127.0.0.1
16.  port: 7771
17. 
18. logger: 
19.  level: error 
20.  output: /usr/data/ssdb\_7773.log 
21.  rotate: 
22.  size: 1000000000
23. 
24. leveldb: 
25.  cache\_size: 500
26.  block\_size: 32
27.  write\_buffer\_size: 64
28.  compaction\_speed: 1000
29.  compression: yes

配置文件使用Tab而不是空格做缩排，（复制到配置文件后请把空格替换为Tab）。主从关系：7770(主)-->7772(从)，7771(主)--->7773(从)；配置文件如何配置请参考[https://github.com/ideawu/ssdb-docs/blob/master/src/zh\_cn/config.md][https_github.com_ideawu_ssdb-docs_blob_master_src_zh_cn_config.md]。

**创建工作目录**

Java代码 ![收藏代码][icon_star.png]

1.  mkdir -p /usr/data/ssdb\_7770 
2.  mkdir -p /usr/data/ssdb\_7771 
3.  mkdir -p /usr/data/ssdb\_7772 
4.  mkdir -p /usr/data/ssdb\_7773

**启动**

Java代码 ![收藏代码][icon_star.png]

1.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_basic\_7770.conf & 
2.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_basic\_7771.conf & 
3.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_basic\_7772.conf & 
4.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_basic\_7773.conf &

通过ps -aux | grep ssdb命令看是否启动了，tail -f nohup.out查看错误信息。

**商品介绍SSDB集群配置**

vim /usr/chapter7/ssdb\_desc\_8880.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_8880 
2.  pidfile = /usr/data/ssdb8880.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 8880
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14. logger: 
15.  level: error 
16.  output: /usr/data/ssdb\_8880.log 
17.  rotate: 
18.  size: 1000000000
19. 
20. leveldb: 
21.  cache\_size: 500
22.  block\_size: 32
23.  write\_buffer\_size: 64
24.  compaction\_speed: 1000
25.  compression: yes

vim /usr/chapter7/ssdb\_desc\_8881.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_8881 
2.  pidfile = /usr/data/ssdb8881.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 8881
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. logger: 
11.  level: error 
12.  output: /usr/data/ssdb\_8881.log 
13.  rotate: 
14.  size: 1000000000
15. 
16. leveldb: 
17.  cache\_size: 500
18.  block\_size: 32
19.  write\_buffer\_size: 64
20.  compaction\_speed: 1000
21.  compression: yes

vim /usr/chapter7/ssdb\_desc\_8882.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_8882 
2.  pidfile = /usr/data/ssdb\_8882.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 8882
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14. replication: 
15.  binlog: yes 
16.  sync\_speed: -1
17.  slaveof: 
18.  type: sync 
19.  ip: 127.0.0.1
20.  port: 8880
21. 
22. logger: 
23.  level: error 
24.  output: /usr/data/ssdb\_8882.log 
25.  rotate: 
26.  size: 1000000000
27. 
28. leveldb: 
29.  cache\_size: 500
30.  block\_size: 32
31.  write\_buffer\_size: 64
32.  compaction\_speed: 1000
33.  compression: yes

vim /usr/chapter7/ssdb\_desc\_8883.conf

Java代码 ![收藏代码][icon_star.png]

1.  work\_dir = /usr/data/ssdb\_8883 
2.  pidfile = /usr/data/ssdb\_8883.pid 
3.  
4.  server: 
5.   ip: 0.0.0.0
6.   port: 8883
7.   allow: 127.0.0.1
8.   allow: 192.168
9.  
10. replication: 
11.  binlog: yes 
12.  sync\_speed: -1
13.  slaveof: 
14.  type: sync 
15.  ip: 127.0.0.1
16.  port: 8881
17. 
18. logger: 
19.  level: error 
20.  output: /usr/data/ssdb\_8883.log 
21.  rotate: 
22.  size: 1000000000
23. 
24. leveldb: 
25.  cache\_size: 500
26.  block\_size: 32
27.  write\_buffer\_size: 64
28.  compaction\_speed: 1000
29.  compression: yes

配置文件使用Tab而不是空格做缩排（复制到配置文件后请把空格替换为Tab）。主从关系：7770(主)-->7772(从)，7771(主)--->7773(从)；配置文件如何配置请参考[https://github.com/ideawu/ssdb-docs/blob/master/src/zh\_cn/config.md][https_github.com_ideawu_ssdb-docs_blob_master_src_zh_cn_config.md]。

**创建工作目录**

Java代码 ![收藏代码][icon_star.png]

1.  mkdir -p /usr/data/ssdb\_888\{ 0,1,2,3\}

**启动**

Java代码 ![收藏代码][icon_star.png]

1.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_desc\_8880.conf & 
2.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_desc\_8881.conf & 
3.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_desc\_8882.conf & 
4.  nohup /usr/servers/ssdb-1.8.0/ssdb-server /usr/chapter7/ssdb\_desc\_8883.conf &

通过ps -aux | grep ssdb命令看是否启动了，tail -f nohup.out查看错误信息。

**其他信息Redis配置**

vim /usr/chapter7/redis\_6660.conf

Java代码 ![收藏代码][icon_star.png]

1.  port 6660
2.  pidfile "/var/run/redis\_6660.pid"
3.  \#设置内存大小，根据实际情况设置，此处测试仅设置20mb 
4.  maxmemory 20mb 
5.  \#内存不足时，所有KEY按照LRU算法删除 
6.  maxmemory-policy allkeys-lru 
7.  \#Redis的过期算法不是精确的而是通过采样来算的，默认采样为3个，此处我们改成10
8.  maxmemory-samples 10
9.  \#不进行RDB持久化 
10. save “” 
11. \#不进行AOF持久化 
12. appendonly no

vim /usr/chapter7/redis\_6661.conf

Java代码 ![收藏代码][icon_star.png]

1.  port 6661
2.  pidfile "/var/run/redis\_6661.pid"
3.  \#设置内存大小，根据实际情况设置，此处测试仅设置20mb 
4.  maxmemory 20mb 
5.  \#内存不足时，所有KEY按照LRU算法进行删除 
6.  maxmemory-policy allkeys-lru 
7.  \#Redis的过期算法不是精确的而是通过采样来算的，默认采样为3个，此处我们改成10
8.  maxmemory-samples 10
9.  \#不进行RDB持久化 
10. save “” 
11. \#不进行AOF持久化 
12. appendonly no 
13. \#主从 
14. slaveof 127.0.0.1 6660

vim /usr/chapter7/redis\_6662.conf

Java代码 ![收藏代码][icon_star.png]

1.  port 6662
2.  pidfile "/var/run/redis\_6662.pid"
3.  \#设置内存大小，根据实际情况设置，此处测试仅设置20mb 
4.  maxmemory 20mb 
5.  \#内存不足时，所有KEY按照LRU算法进行删除 
6.  maxmemory-policy allkeys-lru 
7.  \#Redis的过期算法不是精确的而是通过采样来算的，默认采样为3个，此处我们改成10
8.  maxmemory-samples 10
9.  \#不进行RDB持久化 
10. save “” 
11. \#不进行AOF持久化 
12. appendonly no 
13. \#主从 
14. slaveof 127.0.0.1 6660

如上配置放到配置文件最末尾即可；此处内存不足时的驱逐算法为所有KEY按照LRU进行删除（实际是内存基本上不会遇到满的情况）；主从关系：6660(主)-->6661(从)和6660(主)-->6662(从)。

**启动**

Java代码 ![收藏代码][icon_star.png]

1.  nohup /usr/servers/redis-2.8.19/src/redis-server /usr/chapter7/redis\_6660.conf & 
2.  nohup /usr/servers/redis-2.8.19/src/redis-server /usr/chapter7/redis\_6661.conf & 
3.  nohup /usr/servers/redis-2.8.19/src/redis-server /usr/chapter7/redis\_6662.conf &

通过ps -aux | grep redis命令看是否启动了，tail -f nohup.out查看错误信息。

**测试**

测试时在主SSDB/Redis中写入数据，然后从从SSDB/Redis能读取到数据即表示配置主从成功。

测试商品基本信息SSDB集群

Java代码 ![收藏代码][icon_star.png]

1.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 7770
2.  127.0.0.1:7770> set i 1
3.  OK 
4.  127.0.0.1:7770> 
5.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 7772
6.  127.0.0.1:7772> get i 
7.  "1"

测试商品介绍SSDB集群

Java代码 ![收藏代码][icon_star.png]

1.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 8880
2.  127.0.0.1:8880> set i 1
3.  OK 
4.  127.0.0.1:8880> 
5.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 8882
6.  127.0.0.1:8882> get i 
7.  "1"

测试其他信息集群

Java代码 ![收藏代码][icon_star.png]

1.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 6660
2.  127.0.0.1:6660> set i 1
3.  OK 
4.  127.0.0.1:6660> get i 
5.  "1"
6.  127.0.0.1:6660> 
7.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 6661
8.  127.0.0.1:6661> get i 
9.  "1"

**Twemproxy配置**

vim /usr/chapter7/nutcracker.yml

Java代码 ![收藏代码][icon_star.png]

1.  basic\_master: 
2.   listen: 127.0.0.1:1111
3.   hash: fnv1a\_64 
4.   distribution: ketama 
5.   redis: true
6.   timeout: 1000
7.   hash\_tag: "::"
8.   servers: 
9.   \- 127.0.0.1:7770:1 server1 
10.  \- 127.0.0.1:7771:1 server2 
11. 
12. basic\_slave: 
13.  listen: 127.0.0.1:1112
14.  hash: fnv1a\_64 
15.  distribution: ketama 
16.  redis: true
17.  timeout: 1000
18.  hash\_tag: "::"
19.  servers: 
20.  \- 127.0.0.1:7772:1 server1 
21.  \- 127.0.0.1:7773:1 server2 
22. 
23. 
24. desc\_master: 
25.  listen: 127.0.0.1:1113
26.  hash: fnv1a\_64 
27.  distribution: ketama 
28.  redis: true
29.  timeout: 1000
30.  hash\_tag: "::"
31.  servers: 
32.  \- 127.0.0.1:8880:1 server1 
33.  \- 127.0.0.1:8881:1 server2 
34. 
35. desc\_slave: 
36.  listen: 127.0.0.1:1114
37.  hash: fnv1a\_64 
38.  distribution: ketama 
39.  redis: true
40.  timeout: 1000
41.  servers: 
42.  \- 127.0.0.1:8882:1 server1 
43.  \- 127.0.0.1:8883:1 server2 
44. 
45. other\_master: 
46.  listen: 127.0.0.1:1115
47.  hash: fnv1a\_64 
48.  distribution: random 
49.  redis: true
50.  timeout: 1000
51.  hash\_tag: "::"
52.  servers: 
53.  \- 127.0.0.1:6660:1 server1 
54. 
55. 
56. other\_slave: 
57.  listen: 127.0.0.1:1116
58.  hash: fnv1a\_64 
59.  distribution: random 
60.  redis: true
61.  timeout: 1000
62.  hash\_tag: "::"
63.  servers: 
64.  \- 127.0.0.1:6661:1 server1 
65.  \- 127.0.0.1:6662:1 server2

1、因为我们使用了主从，所以需要给server起一个名字如server1、server2；否则分片算法默认根据ip:port:weight，这样就会主从数据的分片算法不一致；

2、其他信息Redis因为每个Redis是对等的，因此分片算法可以使用random；

3、我们使用了hash\_tag，可以保证相同的tag在一个分片上（本例配置了但没有用到该特性）。

复制第六章的nutcracker.init，帮把配置文件改为usr/chapter7/nutcracker.yml。然后通过/usr/chapter7/nutcracker.init start启动Twemproxy。

测试主从集群是否工作正常：

Java代码 ![收藏代码][icon_star.png]

1.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1111
2.  127.0.0.1:1111> set i 1
3.  OK 
4.  127.0.0.1:1111> 
5.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1112
6.  127.0.0.1:1112> get i 
7.  "1"
8.  127.0.0.1:1112> 
9.  root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1113
10. 127.0.0.1:1113> set i 1
11. OK 
12. 127.0.0.1:1113> 
13. root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1114
14. 127.0.0.1:1114> get i 
15. "1"
16. 127.0.0.1:1114> 
17. root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1115
18. 127.0.0.1:1115> set i 1
19. OK 
20. 127.0.0.1:1115> 
21. root@kaitao:/usr/chapter7\# /usr/servers/redis-2.8.19/src/redis-cli -p 1116
22. 127.0.0.1:1116> get i 
23. "1"

到此数据集群配置成功。

### 动态服务实现 ###

因为真实数据是从多个子系统获取，很难模拟这么多子系统交互，所以此处我们使用假数据来进行实现。

**项目搭建**

我们使用Maven搭建Web项目，Maven知识请自行学习。

**项目依赖**

本文将最小化依赖，即仅依赖我们需要的servlet、jackson、guava、jedis。

Java代码 ![收藏代码][icon_star.png]

1.  <dependencies> 
2.   <dependency> 
3.   <groupId>javax.servlet</groupId> 
4.   <artifactId>javax.servlet-api</artifactId> 
5.   <version>3.0.1</version> 
6.   <scope>provided</scope> 
7.   </dependency> 
8.   <dependency> 
9.   <groupId>com.google.guava</groupId> 
10.  <artifactId>guava</artifactId> 
11.  <version>17.0</version> 
12.  </dependency> 
13.  <dependency> 
14.  <groupId>redis.clients</groupId> 
15.  <artifactId>jedis</artifactId> 
16.  <version>2.5.2</version> 
17.  </dependency> 
18.  <dependency> 
19.  <groupId>com.fasterxml.jackson.core</groupId> 
20.  <artifactId>jackson-core</artifactId> 
21.  <version>2.3.3</version> 
22.  </dependency> 
23.  <dependency> 
24.  <groupId>com.fasterxml.jackson.core</groupId> 
25.  <artifactId>jackson-databind</artifactId> 
26.  <version>2.3.3</version> 
27.  </dependency> 
28. </dependencies>

guava是类似于apache commons的一个基础类库，用于简化一些重复操作，可以参考[http://ifeve.com/google-guava/][http_ifeve.com_google-guava]。

**核心代码**

com.github.zhangkaitao.chapter7.servlet.ProductServiceServlet

Java代码 ![收藏代码][icon_star.png]

1.  @Override
2.  protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException \{ 
3.   String type = req.getParameter("type"); 
4.   String content = null; 
5.  try \{ 
6.  if("basic".equals(type)) \{ 
7.   content = getBasicInfo(req.getParameter("skuId")); 
8.   \} else if("desc".equals(type)) \{ 
9.   content = getDescInfo(req.getParameter("skuId")); 
10.  \} else if("other".equals(type)) \{ 
11.  content = getOtherInfo(req.getParameter("ps3Id"), req.getParameter("brandId")); 
12.  \} 
13.  \} catch (Exception e) \{ 
14.  e.printStackTrace(); 
15.  resp.setStatus(HttpServletResponse.SC\_INTERNAL\_SERVER\_ERROR); 
16. return; 
17.  \} 
18. if(content != null) \{ 
19.  resp.setCharacterEncoding("UTF-8"); 
20.  resp.getWriter().write(content); 
21.  \} else \{ 
22.  resp.setStatus(HttpServletResponse.SC\_NOT\_FOUND); 
23.  \} 
24. \}

根据请求参数type来决定调用哪个服务获取数据。

**基本信息服务**

Java代码 ![收藏代码][icon_star.png]

1.  private String getBasicInfo(String skuId) throws Exception \{ 
2.   Map<String, Object> map = new HashMap<String, Object>(); 
3.  //商品编号
4.   map.put("skuId", skuId); 
5.  //名称
6.   map.put("name", "苹果（Apple）iPhone 6 (A1586) 16GB 金色 移动联通电信4G手机"); 
7.  //一级二级三级分类
8.   map.put("ps1Id", 9987); 
9.   map.put("ps2Id", 653); 
10.  map.put("ps3Id", 655); 
11. //品牌ID
12.  map.put("brandId", 14026); 
13. //图片列表
14.  map.put("imgs", getImgs(skuId)); 
15. //上架时间
16.  map.put("date", "2014-10-09 22:29:09"); 
17. //商品毛重
18.  map.put("weight", "400"); 
19. //颜色尺码
20.  map.put("colorSize", getColorSize(skuId)); 
21. //扩展属性
22.  map.put("expands", getExpands(skuId)); 
23. //规格参数
24.  map.put("propCodes", getPropCodes(skuId)); 
25.  map.put("date", System.currentTimeMillis()); 
26.  String content = objectMapper.writeValueAsString(map); 
27. //实际应用应该是发送MQ
28.  asyncSetToRedis(basicInfoJedisPool, "p:" \+ skuId + ":", content); 
29. return objectMapper.writeValueAsString(map); 
30. \} 
31. 
32. private List<String> getImgs(String skuId) \{ 
33. return Lists.newArrayList( 
34. "jfs/t277/193/1005339798/768456/29136988/542d0798N19d42ce3.jpg", 
35. "jfs/t352/148/1022071312/209475/53b8cd7f/542d079bN3ea45c98.jpg", 
36. "jfs/t274/315/1008507116/108039/f70cb380/542d0799Na03319e6.jpg", 
37. "jfs/t337/181/1064215916/27801/b5026705/542d079aNf184ce18.jpg"
38.  ); 
39. \} 
40. 
41. private List<Map<String, Object>> getColorSize(String skuId) \{ 
42. return Lists.newArrayList( 
43.  makeColorSize(1217499, "金色", "公开版（16GB ROM）"), 
44.  makeColorSize(1217500, "深空灰", "公开版（16GB ROM）"), 
45.  makeColorSize(1217501, "银色", "公开版（16GB ROM）"), 
46.  makeColorSize(1217508, "金色", "公开版（64GB ROM）"), 
47.  makeColorSize(1217509, "深空灰", "公开版（64GB ROM）"), 
48.  makeColorSize(1217509, "银色", "公开版（64GB ROM）"), 
49.  makeColorSize(1217493, "金色", "移动4G版 （16GB）"), 
50.  makeColorSize(1217494, "深空灰", "移动4G版 （16GB）"), 
51.  makeColorSize(1217495, "银色", "移动4G版 （16GB）"), 
52.  makeColorSize(1217503, "金色", "移动4G版 （64GB）"), 
53.  makeColorSize(1217503, "金色", "移动4G版 （64GB）"), 
54.  makeColorSize(1217504, "深空灰", "移动4G版 （64GB）"), 
55.  makeColorSize(1217505, "银色", "移动4G版 （64GB）") 
56.  ); 
57. \} 
58. private Map<String, Object> makeColorSize(long skuId, String color, String size) \{ 
59.  Map<String, Object> cs1 = Maps.newHashMap(); 
60.  cs1.put("SkuId", skuId); 
61.  cs1.put("Color", color); 
62.  cs1.put("Size", size); 
63. return cs1; 
64. \} 
65. 
66. private List<List<?>> getExpands(String skuId) \{ 
67. return Lists.newArrayList( 
68.  (List<?>)Lists.newArrayList("热点", Lists.newArrayList("超薄7mm以下", "支持NFC")), 
69.  (List<?>)Lists.newArrayList("系统", "苹果（IOS）"), 
70.  (List<?>)Lists.newArrayList("系统", "苹果（IOS）"), 
71.  (List<?>)Lists.newArrayList("购买方式", "非合约机") 
72.  ); 
73. \} 
74. 
75. private Map<String, List<List<String>>> getPropCodes(String skuId) \{ 
76.  Map<String, List<List<String>>> map = Maps.newHashMap(); 
77.  map.put("主体", Lists.<List<String>>newArrayList( 
78.  Lists.<String>newArrayList("品牌", "苹果（Apple）"), 
79.  Lists.<String>newArrayList("型号", "iPhone 6 A1586"), 
80.  Lists.<String>newArrayList("颜色", "金色"), 
81.  Lists.<String>newArrayList("上市年份", "2014年") 
82.  )); 
83.  map.put("存储", Lists.<List<String>>newArrayList( 
84.  Lists.<String>newArrayList("机身内存", "16GB ROM"), 
85.  Lists.<String>newArrayList("储存卡类型", "不支持") 
86.  )); 
87.  map.put("显示", Lists.<List<String>>newArrayList( 
88.  Lists.<String>newArrayList("屏幕尺寸", "4.7英寸"), 
89.  Lists.<String>newArrayList("触摸屏", "Retina HD"), 
90.  Lists.<String>newArrayList("分辨率", "1334 x 750") 
91.  )); 
92. return map; 
93. \}

本例基本信息提供了如商品名称、图片列表、颜色尺码、扩展属性、规格参数等等数据；而为了简化逻辑大多数数据都是List/Map数据结构。

商品介绍服务

Java代码 ![收藏代码][icon_star.png]

1.  private String getDescInfo(String skuId) throws Exception \{ 
2.   Map<String, Object> map = new HashMap<String, Object>(); 
3.   map.put("content", "<div><img data-lazyload='http://img30.360buyimg.com/jgsq-productsoa/jfs/t448/127/574781110/103911/b3c80634/5472ba22N45400f4e.jpg' alt='' /><img data-lazyload='http://img30.360buyimg.com/jgsq-productsoa/jfs/t802/133/19465528/162152/e463e43/54e2b34aN11bceb70.jpg' alt='' height='386' width='750' /></div>"); 
4.   map.put("date", System.currentTimeMillis()); 
5.   String content = objectMapper.writeValueAsString(map); 
6.  //实际应用应该是发送MQ
7.   asyncSetToRedis(descInfoJedisPool, "d:" \+ skuId + ":", content); 
8.  return objectMapper.writeValueAsString(map); 
9.  \}

**其他信息服务**

Java代码 ![收藏代码][icon_star.png]

1.  private String getOtherInfo(String ps3Id, String brandId) throws Exception \{ 
2.   Map<String, Object> map = new HashMap<String, Object>(); 
3.  //面包屑
4.   List<List<?>> breadcrumb = Lists.newArrayList(); 
5.   breadcrumb.add(Lists.newArrayList(9987, "手机")); 
6.   breadcrumb.add(Lists.newArrayList(653, "手机通讯")); 
7.   breadcrumb.add(Lists.newArrayList(655, "手机")); 
8.  //品牌
9.   Map<String, Object> brand = Maps.newHashMap(); 
10.  brand.put("name", "苹果（Apple）"); 
11.  brand.put("logo", "BrandLogo/g14/M09/09/10/rBEhVlK6vdkIAAAAAAAFLXzp-lIAAHWawP\_QjwAAAVF472.png"); 
12.  map.put("breadcrumb", breadcrumb); 
13.  map.put("brand", brand); 
14. //实际应用应该是发送MQ
15.  asyncSetToRedis(otherInfoJedisPool, "s:" \+ ps3Id + ":", objectMapper.writeValueAsString(breadcrumb)); 
16.  asyncSetToRedis(otherInfoJedisPool, "b:" \+ brandId + ":", objectMapper.writeValueAsString(brand)); 
17. return objectMapper.writeValueAsString(map); 
18. \}

本例中其他信息只使用了面包屑和品牌数据。

**辅助工具**

Java代码 ![收藏代码][icon_star.png]

1.  private ObjectMapper objectMapper = new ObjectMapper(); 
2.  private JedisPool basicInfoJedisPool = createJedisPool("127.0.0.1", 1111); 
3.  private JedisPool descInfoJedisPool = createJedisPool("127.0.0.1", 1113); 
4.  private JedisPool otherInfoJedisPool = createJedisPool("127.0.0.1", 1115); 
5.  
6.  private JedisPool createJedisPool(String host, int port) \{ 
7.   GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig(); 
8.   poolConfig.setMaxTotal(100); 
9.  return new JedisPool(poolConfig, host, port); 
10. \} 
11. 
12. private ExecutorService executorService = Executors.newFixedThreadPool(10); 
13. private void asyncSetToRedis(final JedisPool jedisPool, final String key, final String content) \{ 
14.  executorService.submit(new Runnable() \{ 
15. @Override
16. public void run() \{ 
17.  Jedis jedis = null; 
18. try \{ 
19.  jedis = jedisPool.getResource(); 
20.  jedis.set(key, content); 
21.  \} catch (Exception e) \{ 
22.  e.printStackTrace(); 
23.  jedisPool.returnBrokenResource(jedis); 
24.  \} finally \{ 
25.  jedisPool.returnResource(jedis); 
26.  \} 
27. 
28.  \} 
29.  \}); 
30. \}

本例使用Jackson进行JSON的序列化；Jedis进行Redis的操作；使用线程池做异步更新（实际应用中可以使用MQ做实现）。

**web.xml配置**

Java代码 ![收藏代码][icon_star.png]

1.  <servlet> 
2.   <servlet-name>productServiceServlet</servlet-name> 
3.   <servlet-class>com.github.zhangkaitao.chapter7.servlet.ProductServiceServlet</servlet-class> 
4.  </servlet> 
5.  <servlet-mapping> 
6.   <servlet-name>productServiceServlet</servlet-name> 
7.   <url-pattern>/info</url-pattern> 
8.  </servlet-mapping>

**打WAR包**

Java代码 ![收藏代码][icon_star.png]

1.  cd D:\\workspace\\chapter7 
2.  mvn clean package

此处使用maven命令打包，比如本例将得到chapter7.war，然后将其上传到服务器的/usr/chapter7/webapp，然后通过unzip chapter6.war解压。

**配置Tomcat**

复制第六章使用的tomcat实例：

Java代码 ![收藏代码][icon_star.png]

1.  cd /usr/servers/ 
2.  cp -r tomcat-server1 tomcat-chapter7/ 
3.  vim /usr/servers/tomcat-chapter7/conf/Catalina/localhost/ROOT.xml

Java代码 ![收藏代码][icon_star.png]

1.   
2.  <Context path="" docBase="/usr/chapter7/webapp"></Context>

指向第七章的web应用路径。

**测试**

启动tomcat实例。

Java代码 ![收藏代码][icon_star.png]

1.  /usr/servers/tomcat-chapter7/bin/startup.sh

访问如下URL进行测试。

Java代码 ![收藏代码][icon_star.png]

1.  http://192.168.1.2:8080/info?type=basic&skuId=1
2.  http://192.168.1.2:8080/info?type=desc&skuId=1
3.  http://192.168.1.2:8080/info?type=other&ps3Id=1&brandId=1

**nginx配置**

vim /usr/chapter7/nginx\_chapter7.conf

Java代码 ![收藏代码][icon_star.png]

1.  upstream backend \{ 
2.   server 127.0.0.1:8080 max\_fails=5 fail\_timeout=10s weight=1; 
3.   check interval=3000 rise=1 fall=2 timeout=5000 type=tcp default\_down=false; 
4.   keepalive 100; 
5.  \} 
6.  
7.  server \{ 
8.   listen 80; 
9.   server\_name item2015.jd.com item.jd.com d.3.cn; 
10. 
11.  location ~ /backend/(.\*) \{ 
12.  \#internal; 
13.  keepalive\_timeout 30s; 
14.  keepalive\_requests 1000; 
15.  \#支持keep-alive 
16.  proxy\_http\_version 1.1; 
17.  proxy\_set\_header Connection ""; 
18. 
19.  rewrite /backend(/.\*) $1 break; 
20.  proxy\_pass\_request\_headers off; 
21.  \#more\_clear\_input\_headers Accept-Encoding; 
22.  proxy\_next\_upstream error timeout; 
23.  proxy\_pass http://backend;
24.  \} 
25. \}

此处server\_name 我们指定了item.jd.com(商品详情页)和d.3.cn(商品介绍)。其他配置可以参考第六章内容。另外实际生产环境要把\#internal打开，表示只有本nginx能访问。

vim /usr/servers/nginx/conf/nginx.conf

Java代码 ![收藏代码][icon_star.png]

1.  include /usr/chapter7/nginx\_chapter7.conf; 
2.  \#为了方便测试，注释掉example.conf 
3.  include /usr/chapter6/nginx\_chapter6.conf;

Java代码 ![收藏代码][icon_star.png]

1.  \#lua模块路径，其中”;;”表示默认搜索路径，默认到/usr/servers/nginx下找 
2.  lua\_package\_path "/usr/chapter7/lualib/?.lua;;"; \#lua 模块 
3.  lua\_package\_cpath "/usr/chapter7/lualib/?.so;;"; \#c模块

lua模块从/usr/chapter7目录加载，因为我们要写自己的模块使用。

重启nginx

/usr/servers/nginx/sbin/nginx -s reload

**绑定hosts**

192.168.1.2 item.jd.com

192.168.1.2 item2015.jd.com

192.168.1.2 d.3.cn

访问如http://item.jd.com/backend/info?type=basic&skuId=1即看到结果。

### 前端展示实现 ###

我们分为三部分实现：基础组件、商品介绍、前端展示部分。

**基础组件**

首先我们进行基础组件的实现，商品介绍和前端展示部分都需要读取Redis和Http服务，因此我们可以抽取公共部分出来复用。

vim /usr/chapter7/lualib/item/common.lua

Java代码 ![收藏代码][icon_star.png]

1.  local redis = require("resty.redis") 
2.  local ngx\_log = ngx.log 
3.  local ngx\_ERR = ngx.ERR 
4.  local function close\_redis(red) 
5.  if not red then 
6.  return
7.   end 
8.   \--释放连接(连接池实现) 
9.   local pool\_max\_idle\_time = 10000 \--毫秒 
10.  local pool\_size = 100 \--连接池大小 
11.  local ok, err = red:set\_keepalive(pool\_max\_idle\_time, pool\_size) 
12. 
13. if not ok then 
14.  ngx\_log(ngx\_ERR, "set redis keepalive error : ", err) 
15.  end 
16. end 
17. 
18. local function read\_redis(ip, port, keys) 
19.  local red = redis:new() 
20.  red:set\_timeout(1000) 
21.  local ok, err = red:connect(ip, port) 
22. if not ok then 
23.  ngx\_log(ngx\_ERR, "connect to redis error : ", err) 
24. return close\_redis(red) 
25.  end 
26.  local resp = nil 
27. if \#keys == 1 then 
28.  resp, err = red:get(keys\[1\]) 
29. else
30.  resp, err = red:mget(keys) 
31.  end 
32. if not resp then 
33.  ngx\_log(ngx\_ERR, "get redis content error : ", err) 
34. return close\_redis(red) 
35.  end 
36. 
37.  \--得到的数据为空处理 
38. if resp == ngx.null then 
39.  resp = nil 
40.  end 
41.  close\_redis(red) 
42. 
43. return resp 
44. end 
45. 
46. local function read\_http(args) 
47.  local resp = ngx.location.capture("/backend/info", \{ 
48.  method = ngx.HTTP\_GET, 
49.  args = args 
50.  \}) 
51. 
52. if not resp then 
53.  ngx\_log(ngx\_ERR, "request error") 
54. return
55.  end 
56. if resp.status ~= 200 then 
57.  ngx\_log(ngx\_ERR, "request error, status :", resp.status) 
58. return
59.  end 
60. return resp.body 
61. end 
62. 
63. local \_M = \{ 
64.  read\_redis = read\_redis, 
65.  read\_http = read\_http 
66. \} 
67. return \_M

整个逻辑和第六章类似；只是read\_redis根据参数keys个数支持get和mget。 比如read\_redis(ip, port, \{"key1"\})则调用get而read\_redis(ip, port, \{"key1", "key2"\})则调用mget。

**商品介绍**

**核心代码**

vim /usr/chapter7/desc.lua

Java代码 ![收藏代码][icon_star.png]

1.  local common = require("item.common") 
2.  local read\_redis = common.read\_redis 
3.  local read\_http = common.read\_http 
4.  local ngx\_log = ngx.log 
5.  local ngx\_ERR = ngx.ERR 
6.  local ngx\_exit = ngx.exit 
7.  local ngx\_print = ngx.print 
8.  local ngx\_re\_match = ngx.re.match 
9.  local ngx\_var = ngx.var 
10. 
11. local descKey = "d:" .. skuId .. ":"
12. local descInfoStr = read\_redis("127.0.0.1", 1114, \{descKey\}) 
13. if not descInfoStr then 
14.  ngx\_log(ngx\_ERR, "redis not found desc info, back to http, skuId : ", skuId) 
15.  descInfoStr = read\_http(\{type="desc", skuId = skuId\}) 
16. end 
17. if not descInfoStr then 
18.  ngx\_log(ngx\_ERR, "http not found basic info, skuId : ", skuId) 
19. return ngx\_exit(404) 
20. end 
21. ngx\_print("showdesc(") 
22. ngx\_print(descInfoStr) 
23. ngx\_print(")")

通过复用逻辑后整体代码简化了许多；此处读取商品介绍从集群；另外前端展示使用JSONP技术展示商品介绍。

**nginx配置**

vim /usr/chapter7/nginx\_chapter7.conf

Java代码 ![收藏代码][icon_star.png]

1.  location ~^/desc/(\\d+)$ \{ 
2.  if ($host != "d.3.cn") \{ 
3.  return 403; 
4.   \} 
5.   default\_type application/x-javascript; 
6.   charset utf-8; 
7.   lua\_code\_cache on; 
8.   set $skuId $1; 
9.   content\_by\_lua\_file /usr/chapter7/desc.lua; 
10. \}

因为item.jd.com和d.3.cn复用了同一个配置文件，此处需要限定只有d.3.cn域名能访问，防止恶意访问。

重启nginx后，访问如http://d.3.cn/desc/1即可得到JSONP结果。

### 前端展示 ###

**核心代码**

vim /usr/chapter7/item.lua

Java代码 ![收藏代码][icon_star.png]

1.  local common = require("item.common") 
2.  local item = require("item") 
3.  local read\_redis = common.read\_redis 
4.  local read\_http = common.read\_http 
5.  local cjson = require("cjson") 
6.  local cjson\_decode = cjson.decode 
7.  local ngx\_log = ngx.log 
8.  local ngx\_ERR = ngx.ERR 
9.  local ngx\_exit = ngx.exit 
10. local ngx\_print = ngx.print 
11. local ngx\_var = ngx.var 
12. 
13. 
14. local skuId = ngx\_var.skuId 
15. 
16. \--获取基本信息 
17. local basicInfoKey = "p:" .. skuId .. ":"
18. local basicInfoStr = read\_redis("127.0.0.1", 1112, \{basicInfoKey\}) 
19. if not basicInfoStr then 
20.  ngx\_log(ngx\_ERR, "redis not found basic info, back to http, skuId : ", skuId) 
21.  basicInfoStr = read\_http(\{type="basic", skuId = skuId\}) 
22. end 
23. if not basicInfoStr then 
24.  ngx\_log(ngx\_ERR, "http not found basic info, skuId : ", skuId) 
25. return ngx\_exit(404) 
26. end 
27. 
28. local basicInfo = cjson\_decode(basicInfoStr) 
29. local ps3Id = basicInfo\["ps3Id"\] 
30. local brandId = basicInfo\["brandId"\] 
31. \--获取其他信息 
32. local breadcrumbKey = "s:" .. ps3Id .. ":"
33. local brandKey = "b:" .. brandId ..":"
34. local otherInfo = read\_redis("127.0.0.1", 1116, \{breadcrumbKey, brandKey\}) or \{\} 
35. local breadcrumbStr = otherInfo\[1\] 
36. local brandStr = otherInfo\[2\] 
37. if breadcrumbStr then 
38.  basicInfo\["breadcrumb"\] = cjson\_decode(breadcrumbStr) 
39. end 
40. if brandStr then 
41.  basicInfo\["brand"\] = cjson\_decode(brandStr) 
42. end 
43. if not breadcrumbStr and not brandStr then 
44.  ngx\_log(ngx\_ERR, "redis not found other info, back to http, skuId : ", brandId) 
45.  local otherInfoStr = read\_http(\{type="other", ps3Id = ps3Id, brandId = brandId\}) 
46. if not otherInfoStr then 
47.  ngx\_log(ngx\_ERR, "http not found other info, skuId : ", skuId) 
48. else
49.  local otherInfo = cjson\_decode(otherInfoStr) 
50.  basicInfo\["breadcrumb"\] = otherInfo\["breadcrumb"\] 
51.  basicInfo\["brand"\] = otherInfo\["brand"\] 
52.  end 
53. end 
54. 
55. local name = basicInfo\["name"\] 
56. \--name to unicode 
57. basicInfo\["unicodeName"\] = item.utf8\_to\_unicode(name) 
58. \--字符串截取，超长显示... 
59. basicInfo\["moreName"\] = item.trunc(name, 10) 
60. \--初始化各分类的url 
61. item.init\_breadcrumb(basicInfo) 
62. \--初始化扩展属性 
63. item.init\_expand(basicInfo) 
64. \--初始化颜色尺码 
65. item.init\_color\_size(basicInfo) 
66. local template = require "resty.template"
67. template.caching(true) 
68. template.render("item.html", basicInfo)

整个逻辑分为四部分：1、获取基本信息；2、根据基本信息中的关联关系获取其他信息；3、初始化/格式化数据；4、渲染模板。

**初始化模块**

vim /usr/chapter7/lualib/item.lua

Java代码 ![收藏代码][icon_star.png]

1.  local bit = require("bit") 
2.  local utf8 = require("utf8") 
3.  local cjson = require("cjson") 
4.  local cjson\_encode = cjson.encode 
5.  local bit\_band = bit.band 
6.  local bit\_bor = bit.bor 
7.  local bit\_lshift = bit.lshift 
8.  local string\_format = string.format 
9.  local string\_byte = string.byte
10. local table\_concat = table.concat 
11. 
12. \--utf8转为unicode 
13. local function utf8\_to\_unicode(str) 
14. if not str or str == "" or str == ngx.null then 
15. return nil 
16.  end 
17.  local res, seq, val = \{\}, 0, nil 
18. for i = 1, \#str do
19.  local c = string\_byte(str, i) 
20. if seq == 0 then 
21. if val then 
22.  res\[\#res + 1\] = string\_format("%04x", val) 
23.  end 
24. 
25.  seq = c < 0x80 and 1 or c < 0xE0 and 2 or c < 0xF0 and 3 or 
26.  c < 0xF8 and 4 or --c < 0xFC and 5 or c < 0xFE and 6 or 
27. 0
28. if seq == 0 then 
29.  ngx.log(ngx.ERR, 'invalid UTF-8 character sequence' .. ",,," .. tostring(str)) 
30. return str 
31.  end 
32. 
33.  val = bit\_band(c, 2 ^ (8 \- seq) - 1) 
34. else
35.  val = bit\_bor(bit\_lshift(val, 6), bit\_band(c, 0x3F)) 
36.  end 
37.  seq = seq - 1
38.  end 
39. if val then 
40.  res\[\#res + 1\] = string\_format("%04x", val) 
41.  end 
42. if \#res == 0 then 
43. return str 
44.  end 
45. return "\\\\u" .. table\_concat(res, "\\\\u") 
46. end 
47. 
48. \--utf8字符串截取 
49. local function trunc(str, len) 
50. if not str then 
51. return nil 
52.  end 
53. 
54. if utf8.len(str) > len then 
55. return utf8.sub(str, 1, len) .. "..."
56.  end 
57. return str 
58. end 
59. 
60. \--初始化面包屑 
61. local function init\_breadcrumb(info) 
62.  local breadcrumb = info\["breadcrumb"\] 
63. if not breadcrumb then 
64. return
65.  end 
66. 
67.  local ps1Id = breadcrumb\[1\]\[1\] 
68.  local ps2Id = breadcrumb\[2\]\[1\] 
69.  local ps3Id = breadcrumb\[3\]\[1\] 
70. 
71.  \--此处应该根据一级分类查找url 
72.  local ps1Url = "http://shouji.jd.com/"
73.  local ps2Url = "http://channel.jd.com/shouji.html"
74.  local ps3Url = "http://list.jd.com/list.html?cat=" .. ps1Id .. "," .. ps2Id .. "," .. ps3Id 
75. 
76.  breadcrumb\[1\]\[3\] = ps1Url 
77.  breadcrumb\[2\]\[3\] = ps2Url 
78.  breadcrumb\[3\]\[3\] = ps3Url 
79. end 
80. 
81. \--初始化扩展属性 
82. local function init\_expand(info) 
83.  local expands = info\["expands"\] 
84. if not expands then 
85. return
86.  end 
87. for \_, e in ipairs(expands) do
88. if type(e\[2\]) == "table" then 
89.  e\[2\] = table\_concat(e\[2\], "，") 
90.  end 
91.  end 
92. end 
93. 
94. \--初始化颜色尺码 
95. local function init\_color\_size(info) 
96.  local colorSize = info\["colorSize"\] 
97. 
98.  \--颜色尺码JSON串 
99.  local colorSizeJson = cjson\_encode(colorSize) 
100.  \--颜色列表（不重复） 
101.  local colorList = \{\} 
102.  \--尺码列表（不重复） 
103.  local sizeList = \{\} 
104.  info\["colorSizeJson"\] = colorSizeJson 
105.  info\["colorList"\] = colorList 
106.  info\["sizeList"\] = sizeList 
107. 
108.  local colorSet = \{\} 
109.  local sizeSet = \{\} 
110. for \_, cz in ipairs(colorSize) do
111.  local color = cz\["Color"\] 
112.  local size = cz\["Size"\] 
113. if color and color ~= "" and not colorSet\[color\] then 
114.  colorList\[\#colorList + 1\] = \{color = color, url = "http://item.jd.com/" ..cz\["SkuId"\] .. ".html"\} 
115.  colorSet\[color\] = true
116.  end 
117. if size and size ~= "" and not sizeSet\[size\] then 
118.  sizeList\[\#sizeList + 1\] = \{size = size, url = "http://item.jd.com/" ..cz\["SkuId"\] .. ".html"\} 
119.  sizeSet\[size\] = ""
120.  end 
121.  end 
122. end 
123. 
124. local \_M = \{ 
125.  utf8\_to\_unicode = utf8\_to\_unicode, 
126.  trunc = trunc, 
127.  init\_breadcrumb = init\_breadcrumb, 
128.  init\_expand = init\_expand, 
129.  init\_color\_size = init\_color\_size 
130. \} 
131. 
132. return \_M

比如utf8\_to\_unicode代码之前已经见过了，其他的都是一些逻辑代码。

**模板html片段**

Java代码 ![收藏代码][icon_star.png]

1.  var pageConfig = \{ 
2.   compatible: true, 
3.   product: \{ 
4.   skuid: \{\* skuId \*\}, 
5.   name: '\{\* unicodeName \*\}', 
6.   skuidkey:'AFC266E971535B664FC926D34E91C879', 
7.   href: 'http://item.jd.com/\{\* skuId \*\}.html', 
8.   src: '\{\* imgs\[1\] \*\}', 
9.   cat: \[\{\* ps1Id \*\},\{\* ps2Id \*\},\{\* ps3Id \*\}\], 
10.  brand: \{\* brandId \*\}, 
11.  tips: false, 
12.  pType: 1, 
13.  venderId:0, 
14.  shopId:'0', 
15.  specialAttrs:\["HYKHSP-0","isDistribution","isHaveYB","isSelfService-0","isWeChatStock-0","packType","IsNewGoods","isCanUseDQ","isSupportCard","isCanUseJQ","isOverseaPurchase-0","is7ToReturn-1","isCanVAT"\], 
16.  videoPath:'', 
17.  desc: 'http://d.3.cn/desc/\{\* skuId \*\}'
18.  \} 
19.  \}; 
20.  var warestatus = 1; 
21.  \{% if colorSizeJson then %\} var ColorSize = \{\* colorSizeJson \*\};\{% end %\} 
22.  \{-raw-\} 
23. try\{(function(flag)\{ if(!flag)\{ return;\} if(window.location.hash == '\#m')\{var exp = new Date();exp.setTime(exp.getTime() + 30 \* 24 \* 60 \* 60 \* 1000);document.cookie = "pcm=1;expires=" \+ exp.toGMTString() + ";path=/;domain=jd.com";return;\}else\{var cook=document.cookie.match(new RegExp("(^| )pcm=(\[^;\]\*)(;|$)"));if(cook&&cook.length>2&&unescape(cook\[2\])=="2")\{flag=false;\}\} var userAgent = navigator.userAgent; if(userAgent)\{ userAgent = userAgent.toUpperCase();if(userAgent.indexOf("PAD")>-1)\{ return;\} var mobilePhoneList = \["IOS","IPHONE","ANDROID","WINDOWS PHONE"\];for(var i=0,len=mobilePhoneList.length;i<len;i++)\{ if(userAgent.indexOf(mobilePhoneList\[i\])>-1)\{var url="http://m.jd.com/product/"\+pageConfig.product.skuid+".html";if(flag)\{window.showtouchurl=true;\}else\{window.location.href = url;\}break;\}\}\}\})((function()\{var json=\{ "6881":3,"1195":3,"10011":3,"6980":3,"12360":3\};if(json\[pageConfig.product.cat\[0\]+""\]==1||json\[pageConfig.product.cat\[1\]+""\]==2||json\[pageConfig.product.cat\[2\]+""\]==3)\{ return false;\}else\{ return true;\}\})());\}catch(e)\{\} 
24.  \{-raw-\}

\{\* var \*\}输出变量，\{% code %\} 写代码片段，\{-raw-\} 不进行任何处理直接输出。

面包屑

Java代码 ![收藏代码][icon_star.png]

1.  <div class="breadcrumb"> 
2.   <strong><a href='\{\* breadcrumb\[1\]\[3\] \*\}'>\{\* breadcrumb\[1\]\[2\] \*\}</a></strong> 
3.   <span> 
4.   &nbsp;>&nbsp; 
5.   <a href='\{\* breadcrumb\[2\]\[3\] \*\}'>\{\* breadcrumb\[2\]\[2\] \*\}</a> 
6.   &nbsp;>&nbsp; 
7.   <a href='\{\* breadcrumb\[3\]\[3\] \*\}'>\{\* breadcrumb\[3\]\[2\] \*\}</a> 
8.   &nbsp;>&nbsp; 
9.   </span> 
10.  <span> 
11.  \{% if brand then %\} 
12.  <a href='http://www.jd.com/pinpai/\{\* ps3Id \*\}-\{\* brandId \*\}.html'>\{\* brand\['name'\] \*\}</a> 
13.  &nbsp;>&nbsp; 
14.  \{% end %\} 
15.  <a href='http://item.jd.com/\{\* skuId \*\}.html'>\{\* moreName \*\}</a> 
16.  </span> 
17. </div>

图片列表

Java代码 ![收藏代码][icon_star.png]

1.  <div id="spec-n1" class="jqzoom" οnclick="window.open('http://www.jd.com/bigimage.aspx?id=\{\* skuId \*\}')" clstag="shangpin|keycount|product|spec-n1"> 
2.   <img data-img="1" width="350" height="350" src="http://img14.360buyimg.com/n1/\{\* imgs\[1\] \*\}" alt="\{\* name \*\}"/> 
3.  </div> 
4.  <div id="spec-list" clstag="shangpin|keycount|product|spec-n5"> 
5.   <a href="javascript:;" class="spec-control" id="spec-forward"></a> 
6.   <a href="javascript:;" class="spec-control" id="spec-backward"></a> 
7.   <div class="spec-items"> 
8.   <ul class="lh"> 
9.   \{% for \_, img in ipairs(imgs) do %\} 
10.  <li><img class='img-hover' alt='\{\* name \*\}' src='http://img14.360buyimg.com/n5/\{\* img \*\}' data-url='\{\* img \*\}' data-img='1' width='50' height='50'></li> 
11.  \{% end %\} 
12.  </ul> 
13.  </div> 
14. </div>

颜色尺码选择

Java代码 ![收藏代码][icon_star.png]

1.  <div class="dt">选择颜色：</div> 
2.   <div class="dd"> 
3.   \{% for \_, color in ipairs(colorList) do %\} 
4.   <div class="item"><b></b><a href="\{\* color\['url'\] \*\}" title="\{\* color\['color'\] \*\}"><i>\{\* color\['color'\] \*\}</i></a></div> 
5.   \{% end %\} 
6.   </div> 
7.  </div> 
8.  <div id="choose-version" class="li"> 
9.   <div class="dt">选择版本：</div> 
10.  <div class="dd"> 
11.  \{% for \_, size in ipairs(sizeList) do %\} 
12.  <div class="item"><b></b><a href="\{\* size\['url'\] \*\}" title="\{\* size\['size'\] \*\}">\{\* size\['size'\] \*\}</a></div> 
13.  \{% end %\} 
14.  </div> 
15. </div>

扩展属性

Java代码 ![收藏代码][icon_star.png]

1.  <ul id="parameter2" class="p-parameter-list"> 
2.   <li title='\{\* name \*\}'>商品名称：\{\* name \*\}</li> 
3.   <li title='\{\* skuId \*\}'>商品编号：\{\* skuId \*\}</li> 
4.   \{% if brand then %\} 
5.   <li title='\{\* brand\["name"\] \*\}'>品牌： <a href='http://www.jd.com/pinpai/\{\* ps3Id \*\}-\{\* brandId \*\}.html' target='\_blank'>\{\* brand\["name"\] \*\}</a></li> 
6.   \{% end %\} 
7.   \{% if date then %\} 
8.   <li title='\{\* date \*\}'>上架时间：\{\* date \*\}</li> 
9.   \{% end %\} 
10.  \{% if weight then %\} 
11.  <li title='\{\* weight \*\}'>商品毛重：\{\* weight \*\}</li> 
12.  \{% end %\} 
13.  \{% for \_, e in pairs(expands) do %\} 
14.  <li title='\{\* e\[2\] \*\}'>\{\* e\[1\] \*\}：\{\* e\[2\] \*\}</li> 
15.  \{% end %\} 
16. </ul>

规格参数

Java代码 ![收藏代码][icon_star.png]

1.  <table cellpadding="0" cellspacing="1" width="100%" border="0" class="Ptable"> 
2.   \{% for group, pc in pairs(propCodes) do %\} 
3.   <tr><th class="tdTitle" colspan="2">\{\* group \*\}</th><tr> 
4.   \{% for \_, v in pairs(pc) do %\} 
5.   <tr><td class="tdTitle">\{\* v\[1\] \*\}</td><td>\{\* v\[2\] \*\}</td></tr> 
6.   \{% end %\} 
7.   \{% end %\} 
8.  </table>

**nginx配置**

vim /usr/chapter7/nginx\_chapter7.conf

Java代码 ![收藏代码][icon_star.png]

1.  \#模板加载位置 
2.  set $template\_root "/usr/chapter7"; 
3.  
4.  
5.  location ~ ^/(\\d+).html$ \{ 
6.  if ($host !~ "^(item|item2015)\\.jd\\.com$") \{ 
7.  return 403; 
8.   \} 
9.   default\_type 'text/html'; 
10.  charset utf-8; 
11.  lua\_code\_cache on; 
12.  set $skuId $1; 
13.  content\_by\_lua\_file /usr/chapter7/item.lua; 
14. \}

**测试**

重启nginx，访问http://item.jd.com/1217499.html可得到响应内容，本例和京东的商品详情页的数据是有些出入的，输出的页面可能是缺少一些数据的。

**优化**

**local cache**

对于其他信息，对数据一致性要求不敏感，而且数据量很少，完全可以在本地缓存全量；而且可以设置如5-10分钟的过期时间是完全可以接受的；因此可以lua\_shared\_dict全局内存进行缓存。具体逻辑可以参考

Java代码 ![收藏代码][icon_star.png]

1.  local nginx\_shared = ngx.shared 
2.  \--item.jd.com配置的缓存 
3.  local local\_cache = nginx\_shared.item\_local\_cache 
4.  local function cache\_get(key) 
5.  if not local\_cache then 
6.  return nil 
7.   end 
8.  return local\_cache:get(key) 
9.  end 
10. 
11. local function cache\_set(key, value) 
12. if not local\_cache then 
13. return nil 
14.  end 
15. return local\_cache:set(key, value, 10 \* 60) --10分钟 
16. end 
17. 
18. local function get(ip, port, keys) 
19.  local tables = \{\} 
20.  local fetchKeys = \{\} 
21.  local resp = nil 
22.  local status = STATUS\_OK 
23.  \--如果tables是个map \#tables拿不到长度 
24.  local has\_value = false
25.  \--先读取本地缓存 
26. for i, key in ipairs(keys) do
27.  local value = cache\_get(key) 
28. if value then 
29. if value == "" then 
30.  value = nil 
31.  end 
32.  tables\[key\] = value 
33.  has\_value = true
34. else
35.  fetchKeys\[\#fetchKeys + 1\] = key 
36.  end 
37.  end 
38. 
39.  \--如果还有数据没获取 从redis获取 
40. if \#fetchKeys > 0 then 
41. if \#fetchKeys == 1 then 
42.  status, resp = redis\_get(ip, port, fetchKeys\[1\]) 
43. else
44.  status, resp = redis\_mget(ip, port, fetchKeys) 
45.  end 
46. if status == STATUS\_OK then 
47. for i = 1, \#fetchKeys do
48.  local key = fetchKeys\[i\] 
49.  local value = nil 
50. if \#fetchKeys == 1 then 
51.  value = resp 
52. else
53.  value = get\_data(resp, i) 
54.  end 
55.  tables\[key\] = value 
56.  has\_value = true
57.  cache\_set(key, value or "", ttl) 
58.  end 
59.  end 
60.  end 
61.  \--如果从缓存查到 就认为ok 
62. if has\_value and status == STATUS\_NOT\_FOUND then 
63.  status = STATUS\_OK 
64.  end 
65. return status, tables 
66. end

**nginx proxy cache**

为了防止恶意刷页面/热点页面访问频繁，我们可以使用nginx proxy\_cache做页面缓存，当然更好的选择是使用CDN技术，如通过Apache Traffic Server、Squid、Varnish。

1、nginx.conf配置

Java代码 ![收藏代码][icon_star.png]

1.  proxy\_buffering on; 
2.  proxy\_buffer\_size 8k; 
3.  proxy\_buffers 256 8k; 
4.  proxy\_busy\_buffers\_size 64k; 
5.  proxy\_temp\_file\_write\_size 64k; 
6.  proxy\_temp\_path /usr/servers/nginx/proxy\_temp; 
7.  \#设置Web缓存区名称为cache\_one，内存缓存空间大小为200MB，1分钟没有被访问的内容自动清除，硬盘缓存空间大小为30GB。 
8.  proxy\_cache\_path /usr/servers/nginx/proxy\_cache levels=1:2 keys\_zone=cache\_item:200m inactive=1m max\_size=30g;

增加proxy\_cache的配置，可以通过挂载一块内存作为缓存的存储空间。更多配置规则请参考 [http://nginx.org/cn/docs/http/ngx\_http\_proxy\_module.html][http_nginx.org_cn_docs_http_ngx_http_proxy_module.html]。

2、nginx\_chapter7.conf配置

与server指令配置同级

Java代码 ![收藏代码][icon_star.png]

1.  \#\#\#\#\#\#\#\#\#\#\#\# 测试时使用的动态请求 
2.  map $host $item\_dynamic \{ 
3.  default "0"; 
4.   item2015.jd.com "1"; 
5.  \}

即如果域名为item2015.jd.com则item\_dynamic=1。

Java代码 ![收藏代码][icon_star.png]

1.  location ~ ^/(\\d+).html$ \{ 
2.   set $skuId $1; 
3.  if ($host !~ "^(item|item2015)\\.jd\\.com$") \{ 
4.  return 403; 
5.   \} 
6.  
7.   expires 3m; 
8.   proxy\_cache cache\_item; 
9.   proxy\_cache\_key $uri; 
10.  proxy\_cache\_bypass $item\_dynamic; 
11.  proxy\_no\_cache $item\_dynamic; 
12.  proxy\_cache\_valid 200 301 3m; 
13.  proxy\_cache\_use\_stale updating error timeout invalid\_header http\_500 http\_502 http\_503 http\_504; 
14.  proxy\_pass\_request\_headers off; 
15.  proxy\_set\_header Host $host; 
16.  \#支持keep-alive 
17.  proxy\_http\_version 1.1; 
18.  proxy\_set\_header Connection ""; 
19.  proxy\_pass http://127.0.0.1/proxy/$skuId.html;
20.  add\_header X-Cache '$upstream\_cache\_status'; 
21. \} 
22. 
23. location ~ ^/proxy/(\\d+).html$ \{ 
24.  allow 127.0.0.1; 
25.  deny all; 
26.  keepalive\_timeout 30s; 
27.  keepalive\_requests 1000; 
28.  default\_type 'text/html'; 
29.  charset utf-8; 
30.  lua\_code\_cache on; 
31.  set $skuId $1; 
32.  content\_by\_lua\_file /usr/chapter7/item.lua; 
33. \}

expires：设置响应缓存头信息，此处是3分钟；将会得到Cache-Control:max-age=180和类似Expires:Sat, 28 Feb 2015 10:01:10 GMT的响应头；

proxy\_cache：使用之前在nginx.conf中配置的cache\_item缓存；

proxy\_cache\_key：缓存key为uri，不包括host和参数，这样不管用户怎么通过在url上加随机数都是走缓存的；

proxy\_cache\_bypass：nginx不从缓存取响应的条件，可以写多个；如果存在一个字符串条件且不是“0”，那么nginx就不会从缓存中取响应内容；此处如果我们使用的host为item2015.jd.com时就不会从缓存取响应内容；

proxy\_no\_cache：nginx不将响应内容写入缓存的条件，可以写多个；如果存在一个字符串条件且不是“0”，那么nginx就不会从将响应内容写入缓存；此处如果我们使用的host为item2015.jd.com时就不会将响应内容写入缓存；

proxy\_cache\_valid：为不同的响应状态码设置不同的缓存时间，此处我们对200、301缓存3分钟；

proxy\_cache\_use\_stale：什么情况下使用不新鲜（过期）的缓存内容；配置和proxy\_next\_upstream内容类似；此处配置了如果连接出错、超时、404、500等都会使用不新鲜的缓存内容；此外我们配置了updating配置，通过配置它可以在nginx正在更新缓存（其中一个Worker进程）时（其他的Worker进程）使用不新鲜的缓存进行响应，这样可以减少回源的数量；

proxy\_pass\_request\_headers：我们不需要请求头，所以不传递；

proxy\_http\_version 1.1和proxy\_set\_header Connection ""：支持keepalive；

add\_header X-Cache '$upstream\_cache\_status'：添加是否缓存命中的响应头；比如命中HIT、不命中MISS、不走缓存BYPASS；比如命中会看到X-Cache：HIT响应头；

allow/deny：允许和拒绝访问的ip列表，此处我们只允许本机访问；

keepalive\_timeout 30s和keepalive\_requests 1000：支持keepalive；

nginx\_chapter7.conf清理缓存配置

Java代码 ![收藏代码][icon_star.png]

1.  location /purge \{ 
2.   allow 127.0.0.1; 
3.   allow 192.168.0.0/16; 
4.   deny all; 
5.   proxy\_cache\_purge cache\_item $arg\_url; 
6.  \}

只允许内网访问。访问如http://item.jd.com/purge?url=/11.html；如果看到Successful purge说明缓存存在并清理了。

3、修改item.lua代码

Java代码 ![收藏代码][icon_star.png]

1.  \--添加Last-Modified，用于响应304缓存 
2.  ngx.header\["Last-Modified"\] = ngx.http\_time(ngx.now()) 
3.  
4.  local template = require "resty.template"
5.  template.caching(true) 
6.  template.render("item.html", basicInfo) 
7.  ~

在渲染模板前设置Last-Modified，用于判断内容是否变更的条件，默认Nginx通过等于去比较，也可以通过配置[if\_modified\_since][if_modified_since]指令来支持小于等于比较；如果请求头发送的If-Modified-Since和Last-Modified匹配则返回304响应，即内容没有变更，使用本地缓存。此处可能看到了我们的Last-Modified是当前时间，不是商品信息变更的时间；商品信息变更时间由：商品信息变更时间、面包屑变更时间和品牌变更时间三者决定的，因此实际应用时应该取三者最大的；还一个问题就是模板内容可能变了，但是商品信息没有变，此时使用Last-Modified得到的内容可能是错误的，所以可以通过使用ETag技术来解决这个问题，ETag可以认为是内容的一个摘要，内容变更后摘要就变了。

**GZIP压缩**

修改nginx.conf配置文件

Java代码 ![收藏代码][icon_star.png]

1.  gzip on; 
2.  gzip\_min\_length 4k; 
3.  gzip\_buffers 4 16k; 
4.  gzip\_http\_version 1.0; 
5.  gzip\_proxied any; \#前端是squid的情况下要加此参数，否则squid上不缓存gzip文件 
6.  gzip\_comp\_level 2; 
7.  gzip\_types text/plain application/x-javascript text/css application/xml; 
8.  gzip\_vary on;

此处我们指定至少4k时才压缩，如果数据太小压缩没有意义。

到此整个商品详情页逻辑就介绍完了，一些细节和运维内容需要在实际开发中实际处理，无法做到面面俱到。

来源:http://jinnianshilongnian.iteye.com/blog/2188538

[http_item.jd.com_1217499.html]: http://item.jd.com/1217499.html
[57080353-3ed7-3f34-84fc-9ab7d8a31e16.png]: http://dl2.iteye.com/upload/attachment/0106/1917/57080353-3ed7-3f34-84fc-9ab7d8a31e16.png
[3e17cf60-74a5-3a29-90af-6a17a7cef5d6.png]: http://dl2.iteye.com/upload/attachment/0106/1919/3e17cf60-74a5-3a29-90af-6a17a7cef5d6.png
[5342ca19-7fd1-3719-8aea-6513cf2fbe3e.png]: http://dl2.iteye.com/upload/attachment/0106/1921/5342ca19-7fd1-3719-8aea-6513cf2fbe3e.png
[Apache ActiveMQ]: http://activemq.apache.org/
[alibaba Dubbo]: https://github.com/alibaba/dubbo
[SSDB]: https://github.com/ideawu/ssdb
[SSDB_RocksDB]: https://github.com/ideawu/ssdb-rocks
[ARDB]: https://github.com/yinqiwen/ardb
[2068df57-dea0-3cb1-980b-d66745a99622.png]: http://dl2.iteye.com/upload/attachment/0106/2060/2068df57-dea0-3cb1-980b-d66745a99622.png
[icon_star.png]: http://jinnianshilongnian.iteye.com/images/icon_star.png
[https_github.com_ideawu_ssdb-docs_blob_master_src_zh_cn_config.md]: https://github.com/ideawu/ssdb-docs/blob/master/src/zh_cn/config.md
[http_ifeve.com_google-guava]: http://ifeve.com/google-guava/
[http_nginx.org_cn_docs_http_ngx_http_proxy_module.html]: http://nginx.org/cn/docs/http/ngx_http_proxy_module.html
[if_modified_since]: http://wiki.nginx.org/HttpCoreModule#if_modified_since