張斌 任富彬 沈煒

摘? 要：食品安全問(wèn)題是關(guān)系國(guó)計(jì)民生的大事，在互聯(lián)網(wǎng)時(shí)代的今天，有一款可以解決食品安全的軟件是非常有必要的，有關(guān)食品的原料采購(gòu)及成品去向都要在平臺(tái)中進(jìn)行備案。若一件食品有問(wèn)題，則可以快速定位該批食品，定位問(wèn)題廠家及該批貨源所有去向，及時(shí)召回，可以有效地解決食品安全問(wèn)題。而在微服務(wù)快速發(fā)展的今天，我們可以使用微服務(wù)框架SpringCloud快速有效的進(jìn)行食品安全溯源系統(tǒng)的開(kāi)發(fā)。

關(guān)鍵詞：微服務(wù);食品安全;溯源;NoSQL;消息中間件

中圖分類號(hào)：TP311.5? ? ?文獻(xiàn)標(biāo)識(shí)碼：A

Abstract：Food safety is a major issue related to national economy and people's livelihood.In today's Internet era，it is necessary to design and implement a system to solve the problems in the field of food safety.The procurement of raw materials for food and the destination of finished products must be filed on the platform.In case of problems for a piece of food，the batch of such products，the related manufacturers and all the destinations of the batch can be quickly located and recalled in time，which can effectively solve the problems in food safety.Moreover，with the rapid development of micro-services，we can use the micro-services framework SpringCloud to quickly and effectively develop food safety traceability systems.

Keywords：micro-service;food safety;traceability;NoSQL;message-oriented middleware

1? ?引言（Introduction）

近年來(lái)，食品安全事故給社會(huì)帶來(lái)了深刻的負(fù)面影響，公眾對(duì)食品安全和監(jiān)管的要求也越來(lái)越高[1]。國(guó)家雖然不斷完善和推出新的法律法規(guī)，但是食品安全問(wèn)題依然層出不窮，所以我們考慮開(kāi)發(fā)一個(gè)互聯(lián)網(wǎng)項(xiàng)目，將每個(gè)食品從生產(chǎn)到售出到用戶手中都以數(shù)據(jù)的形式記錄下來(lái)，隨時(shí)進(jìn)行安全監(jiān)管，提高消費(fèi)者對(duì)食品安全和政府監(jiān)管的信心。本系統(tǒng)考慮使用當(dāng)下流行的微服務(wù)框架SpringCloud，能夠進(jìn)行快速讀寫的NoSQL數(shù)據(jù)庫(kù)Redis及當(dāng)下流行的用于消息推送及流量削峰的消息中間件[2]RabbitMQ來(lái)進(jìn)行開(kāi)發(fā)。

2? ?微服務(wù)介紹（Micro-service introduction）

最初的單體架構(gòu)，在java中可以理解為一個(gè)Java Web應(yīng)用程序，從JSP時(shí)代到中間過(guò)渡使用的流行的Struts+Spring+ Hibernate框架及SpringMVC+Spring+Mybatis框架，都屬于單體架構(gòu)，包含視圖層、業(yè)務(wù)層、數(shù)據(jù)訪問(wèn)層，也就是我們常說(shuō)的MVC架構(gòu)，從Controller到Service到最后與數(shù)據(jù)庫(kù)操作相關(guān)的Dao層，所有服務(wù)都寫在一個(gè)程序中，沒(méi)有任何拆分，各模塊之間耦合度高，如果有一個(gè)地方要修改，要從上到下controller到dao的去修改，且因?yàn)樵谝粋€(gè)程序中，其他模塊被影響的可能性也非常大，每次都要等待所有開(kāi)發(fā)人員完成后才能完成部署，團(tuán)隊(duì)靈活性非常低。且因?yàn)樗械墓δ芏紝懺谝黄?，在程序啟?dòng)時(shí)，一個(gè)進(jìn)程包含了所有的業(yè)務(wù)邏輯，系統(tǒng)的啟動(dòng)時(shí)間會(huì)比較長(zhǎng)。而且當(dāng)添加新的需求或改進(jìn)時(shí)，無(wú)法針對(duì)單點(diǎn)增加，每次都要進(jìn)行全局的修改部署，影響團(tuán)隊(duì)效率。單體服務(wù)架構(gòu)圖如圖1所示。

微服務(wù)架構(gòu)是近些年來(lái)隨著互聯(lián)網(wǎng)快速發(fā)展衍生的新的系統(tǒng)架構(gòu)，它可以將一個(gè)完整的應(yīng)用從數(shù)據(jù)存儲(chǔ)到模塊劃分垂直的拆分為多個(gè)不同的服務(wù)，每個(gè)服務(wù)負(fù)責(zé)自己的模塊，相互獨(dú)立，都能獨(dú)立部署、維護(hù)及擴(kuò)展，服務(wù)之間通過(guò)諸如RESTful API或RPC的方式來(lái)進(jìn)行相互調(diào)用。微服務(wù)是一種新的適應(yīng)于當(dāng)今互聯(lián)網(wǎng)行業(yè)需求的架構(gòu)風(fēng)格，一個(gè)大型復(fù)雜的軟件系統(tǒng)可以由一個(gè)或多個(gè)微服務(wù)組成，且各微服務(wù)之間是松耦合的。每個(gè)微服務(wù)僅需要關(guān)注自身的業(yè)務(wù)邏輯即可。微服務(wù)架構(gòu)示意圖如圖2所示。

3? 系統(tǒng)技術(shù)選型及總體架構(gòu)設(shè)計(jì)（System technology selection and overall architecture design）

Spring Cloud是Spring團(tuán)隊(duì)基于Spring Boot實(shí)現(xiàn)的微服務(wù)框架，它整合了諸多優(yōu)秀的開(kāi)源組件，如服務(wù)網(wǎng)關(guān)zuul和gateway，提供服務(wù)間調(diào)用的feign組件，用于服務(wù)注冊(cè)及服務(wù)發(fā)現(xiàn)的eureka和consul，負(fù)載均衡組件ribbon，服務(wù)間調(diào)用組件feign，配置中心config，容錯(cuò)組件hystrix，智能路由等。

Redis是一個(gè)開(kāi)源的使用ANSIC語(yǔ)言編寫的key-value存儲(chǔ)系統(tǒng)，是當(dāng)前比較熱門的NOSQL[3]系統(tǒng)之一。Redis的讀寫操作都在內(nèi)存中進(jìn)行，讀取速度可以達(dá)到110000次/s，寫速度可以達(dá)到81000次/s，效率遠(yuǎn)遠(yuǎn)高于數(shù)據(jù)庫(kù)的只有千級(jí)的并發(fā)量。所以很多短時(shí)間不會(huì)發(fā)生變化的數(shù)據(jù)我們都可以存儲(chǔ)在Redis中，提高用戶的響應(yīng)速度，減輕數(shù)據(jù)庫(kù)壓力。

RabbitMQ是使用Erlang語(yǔ)言編寫的基于AMQP協(xié)議的開(kāi)源的消息代理和隊(duì)列服務(wù)器。它憑借自身高可靠、易擴(kuò)展、高可用及豐富的功能特性成為最流行的消息中間件之一。當(dāng)我們使用消息中間件進(jìn)行服務(wù)間的消息推送時(shí)，當(dāng)服務(wù)A向服務(wù)B發(fā)送消息，如果當(dāng)時(shí)網(wǎng)絡(luò)不可用，或B服務(wù)出現(xiàn)故障，消息中間件都將保留著這份消息，直到服務(wù)B可以接受執(zhí)行并消費(fèi)消息，可以防止服務(wù)間因?yàn)橐粋€(gè)服務(wù)出現(xiàn)問(wèn)題而出現(xiàn)阻塞。

（1）數(shù)據(jù)庫(kù)：將食品安全溯源系統(tǒng)的全部數(shù)據(jù)都存放在MySQL數(shù)據(jù)庫(kù)中，MySQL是當(dāng)下最流行的關(guān)系型數(shù)據(jù)庫(kù)管理系統(tǒng)之一，特別在WEB系統(tǒng)方面使用尤為廣泛，這里我們將所有的企業(yè)信息，食品信息包括食品的原材料采購(gòu)及成品售出去向等信息，每次的企業(yè)生產(chǎn)報(bào)備信息等都存儲(chǔ)在數(shù)據(jù)庫(kù)中，考慮到數(shù)據(jù)庫(kù)的并發(fā)量，在系統(tǒng)中我們會(huì)將特定的符合條件的數(shù)據(jù)存放在Redis中，通過(guò)設(shè)置過(guò)期時(shí)間等來(lái)根據(jù)特定場(chǎng)景對(duì)數(shù)據(jù)的實(shí)時(shí)性進(jìn)行維護(hù)，提高數(shù)據(jù)讀寫效率，提高系統(tǒng)響應(yīng)速度。

（2）業(yè)務(wù)邏輯層：首先將整個(gè)系統(tǒng)拆分為不同的服務(wù)模塊，主要分為服務(wù)提供者和服務(wù)消費(fèi)者兩大類，服務(wù)提供者包括企業(yè)模塊、食品模塊、備案模塊，包含短信發(fā)送服務(wù)等功能的基礎(chǔ)模塊，服務(wù)消費(fèi)者包括企業(yè)端模塊和監(jiān)管端模塊。企業(yè)首先進(jìn)行注冊(cè)，通過(guò)上傳營(yíng)業(yè)執(zhí)照等成功進(jìn)行資格審查后，可以進(jìn)行食品生產(chǎn)及銷售備案，而所有的企業(yè)信息，食品生產(chǎn)及銷售信息等都可以在監(jiān)管端清晰地展示出來(lái)。

（3）展示界面：主要通過(guò)ElementUI+vue.js實(shí)現(xiàn)前端頁(yè)面的展示，前端頁(yè)面主要分為兩部分，提供給企業(yè)使用的企業(yè)系統(tǒng)和提供給政府監(jiān)管方使用的監(jiān)管系統(tǒng)。在監(jiān)管系統(tǒng)中，我們可以通過(guò)Echarts圖表的方式來(lái)清晰的展示我們想要得到的各種信息。

4? ?系統(tǒng)模塊設(shè)計(jì)（System module design）

4.1? ?企業(yè)端模塊

企業(yè)通過(guò)手機(jī)號(hào)進(jìn)行企業(yè)注冊(cè)，注冊(cè)后企業(yè)的默認(rèn)狀態(tài)為未認(rèn)證狀態(tài)，通過(guò)上傳營(yíng)業(yè)執(zhí)照進(jìn)行企業(yè)合法性審核并等待監(jiān)管端進(jìn)行審核。若審核通過(guò)，企業(yè)可以上傳生產(chǎn)/銷售許可證進(jìn)行相關(guān)生產(chǎn)/銷售資質(zhì)的審核申請(qǐng)，同樣在審核通過(guò)后可以進(jìn)行食品登記并在進(jìn)行生產(chǎn)/銷售備案后進(jìn)行食品生產(chǎn)和出貨銷售。企業(yè)注冊(cè)流程圖如圖4所示。

企業(yè)注冊(cè)后可以進(jìn)行生產(chǎn)報(bào)備，包括使用的原材料信息，生產(chǎn)的食品件數(shù)，一次生產(chǎn)報(bào)備會(huì)有一個(gè)唯一的身份標(biāo)識(shí)碼，如果需要食品溯源時(shí)，這個(gè)碼就是可以快速定位全部食品去向的“身份證”。生產(chǎn)結(jié)束后會(huì)進(jìn)入企業(yè)的庫(kù)存信息中，每次進(jìn)行銷售的時(shí)候要進(jìn)行食品銷售報(bào)備，包括交易企業(yè)信息、銷售件數(shù)、銷售件數(shù)要在庫(kù)存中扣除，當(dāng)庫(kù)存售光，即該批次的食品銷售完畢，每一級(jí)的經(jīng)銷商在出貨銷售的時(shí)候也要進(jìn)行銷售報(bào)備，直到末級(jí)經(jīng)銷商（如超市）。

4.2? ?監(jiān)管端模塊

監(jiān)管端模塊是給政府或食藥監(jiān)等監(jiān)管部門使用的一套系統(tǒng)，這里可以直觀地看到全部食品生產(chǎn)企業(yè)及銷售企業(yè)的一切行為，可以看到每次的食品生產(chǎn)及銷售的報(bào)備情況，更是有一鍵追溯功能能夠快速定位問(wèn)題食品的去向可以快速追回。

首先監(jiān)管端賬號(hào)由系統(tǒng)管理員提供給監(jiān)管方，在賬號(hào)第一次登錄時(shí)需要用戶綁定手機(jī)，在通過(guò)手機(jī)驗(yàn)證碼校驗(yàn)后可以輸入自定義的新密碼，且后面可以通過(guò)手機(jī)號(hào)登錄。

登錄成功后首先進(jìn)入工作臺(tái)頁(yè)面，這里可以直觀地查看系統(tǒng)中全部企業(yè)的大體情況，里面有各種Echarts圖表做的各種統(tǒng)計(jì)，主要分為企業(yè)模塊和報(bào)備模塊，如當(dāng)月報(bào)備企業(yè)數(shù)和未報(bào)備企業(yè)數(shù)，按地區(qū)顯示地區(qū)的入網(wǎng)企業(yè)數(shù)和報(bào)備企業(yè)數(shù)，當(dāng)月報(bào)備總數(shù)及同比上漲比例等。

通過(guò)工作臺(tái)的功能導(dǎo)航欄可以進(jìn)入企業(yè)管理模塊，這里可以查看各種類型的企業(yè)列表及對(duì)單個(gè)企業(yè)進(jìn)行操作，可以按照當(dāng)月報(bào)備或未報(bào)備類型來(lái)查看企業(yè)列表，也可以通過(guò)精確查找或模糊匹配來(lái)完成目標(biāo)企業(yè)的查找。在查看企業(yè)中，我們可以通過(guò)發(fā)送短信的方式給企業(yè)相關(guān)負(fù)責(zé)人發(fā)送通知，也可以通過(guò)消息隊(duì)列來(lái)進(jìn)行站內(nèi)消息的收發(fā)，企業(yè)審核的功能也是在這里完成的，若發(fā)現(xiàn)企業(yè)異常行為可以將企業(yè)加入異常名單中，異常名單中的企業(yè)不能進(jìn)行生產(chǎn)/銷售報(bào)備，企業(yè)要通過(guò)上傳材料解除異常且通過(guò)審核后才可以恢復(fù)正常。

監(jiān)管端功能流程圖如圖5所示。

5? ?系統(tǒng)實(shí)現(xiàn)（System implementation）

5.1? ?系統(tǒng)架構(gòu)實(shí)現(xiàn)

食品安全溯源系統(tǒng)采用SpringCloud+MySQL+Redis+

RabbitMQ的微服務(wù)架構(gòu)方式搭建而成。

接口請(qǐng)求到我們的服務(wù)的時(shí)候首先要經(jīng)過(guò)網(wǎng)關(guān)，這里我們使用的是Spring Cloud[4]生態(tài)體系中的第二代網(wǎng)關(guān)Spring Cloud Gateway。Spring Cloud Gateway是Spring官方基于Spring5.0、Spring Boot2.0和Project Reactor等技術(shù)開(kāi)發(fā)的網(wǎng)關(guān)，它為微服務(wù)架構(gòu)提供了簡(jiǎn)單、有效且統(tǒng)一的API路由管理方式，其不僅提供統(tǒng)一的路由方式，并且還基于Filter鏈的方式提供了網(wǎng)關(guān)基本的功能，例如：安全、監(jiān)控/埋點(diǎn)、限流等。

服務(wù)治理[5]我們采用Spring Cloud的Consul組件，Spring Cloud Consul是一個(gè)分布式高可用的系統(tǒng)服務(wù)發(fā)現(xiàn)與配置工具，提供包括服務(wù)發(fā)現(xiàn)、配置和分段功能在內(nèi)的全功能控制平面。有了Consul，服務(wù)可以通過(guò)DNS或者HTTP直接找到它所以來(lái)的服務(wù)，Consul提供健康檢查的機(jī)制，Consul還支持多數(shù)據(jù)中心，這意味著用戶不用為了多數(shù)據(jù)中心自己做抽象。

Spring Cloud Feign使我們使用的服務(wù)間調(diào)用組件，它是一種聲明式、模板化的HTTP客戶端。在Spring Cloud中使用Feign，可以做到使用HTTP請(qǐng)求訪問(wèn)遠(yuǎn)端服務(wù)，就像調(diào)用本地方法一樣，開(kāi)發(fā)者完全感知不到這是在調(diào)用遠(yuǎn)程方法，更感知不到在訪問(wèn)HTTP方法。

Spring Cloud Ribbon組件是微服務(wù)體系中彈性擴(kuò)展的基礎(chǔ)組件，其豐富的負(fù)載均衡策略、重試機(jī)制、支持多協(xié)議的異步與響應(yīng)式模型、容錯(cuò)、緩存與批處理等功能都可以讓我們?cè)跇?gòu)建微服務(wù)架構(gòu)時(shí)更加方便快捷。

Spring Cloud Hystrix是Spring Cloud提供的一個(gè)針對(duì)分布式系統(tǒng)容錯(cuò)處理的開(kāi)源組件，它是一個(gè)延遲和容錯(cuò)庫(kù)，旨在隔離遠(yuǎn)程系統(tǒng)、服務(wù)和第三方庫(kù)，阻止級(jí)聯(lián)故障，在復(fù)雜的分布式系統(tǒng)中實(shí)現(xiàn)恢復(fù)能力。

Spring Cloud Config是Spring Cloud微服務(wù)體系中的配置中心，是微服務(wù)中不可獲取的一部分，其能夠很好的將程序中配置日益增多的各種功能的開(kāi)關(guān)、參數(shù)的配置、服務(wù)器的地址，配置修改后實(shí)時(shí)生效，灰度發(fā)布，分環(huán)境、分集群管理配置等進(jìn)行全面的集中化管理，有利于系統(tǒng)的配置管理和維護(hù)。

Redis是一款在內(nèi)存中進(jìn)行讀寫的非關(guān)系型Key-Value存儲(chǔ)系統(tǒng)，作為一個(gè)內(nèi)存數(shù)據(jù)庫(kù)，Redis讀寫數(shù)據(jù)的時(shí)候不會(huì)受到硬盤I/O速度的限制，讀取速度可以達(dá)到110000次/秒，寫入速度達(dá)到81000次/秒，遠(yuǎn)遠(yuǎn)優(yōu)于常規(guī)DB數(shù)據(jù)庫(kù)的讀取速度[6]。它支持多種數(shù)據(jù)類型，并支持原子性操作。Redis與其他Cache相比，擁有更多的數(shù)據(jù)結(jié)構(gòu)并支持更豐富的數(shù)據(jù)操作。Redis最主要的應(yīng)用場(chǎng)景之一便是業(yè)務(wù)緩存，將一些不經(jīng)常改變但又經(jīng)常訪問(wèn)的熱點(diǎn)數(shù)據(jù)常駐在內(nèi)存中，并在內(nèi)存中完成對(duì)數(shù)據(jù)的操作有效地減少數(shù)據(jù)庫(kù)讀取次數(shù)，減少數(shù)據(jù)庫(kù)壓力，提高響應(yīng)時(shí)間，增強(qiáng)吞吐量。

5.2? ?持久化實(shí)現(xiàn)

數(shù)據(jù)庫(kù)使用流行的關(guān)系型數(shù)據(jù)庫(kù)MySQL，使用的持久層框架為SpringBoot自帶的Spring Data Jpa，Spring Data JPA是Spring Data的一個(gè)子項(xiàng)目，它通過(guò)提供基于JPA的Repsitory極大地減少了JPA作為數(shù)據(jù)訪問(wèn)方案的代碼量。

5.3? ?業(yè)務(wù)邏輯流程

本系統(tǒng)從前端接受的數(shù)據(jù)類型均為json格式，在通過(guò)路由匹配找到對(duì)應(yīng)的Controller方法后開(kāi)始執(zhí)行我們的業(yè)務(wù)邏輯代碼。Controller在接受前端傳遞的參數(shù)后去service層處理邏輯，service層通過(guò)redis中或通過(guò)dao層取出相應(yīng)數(shù)據(jù)，若是調(diào)用其他服務(wù)的接口，則在service層中通過(guò)feign組件調(diào)用其他服務(wù)的接口，將數(shù)據(jù)封裝好后返回給controller層，再同樣以json的格式返回給用戶。

5.4? ?頁(yè)面實(shí)現(xiàn)

前端采用ElementUI+VUE.js的前端架構(gòu)來(lái)實(shí)現(xiàn)前端頁(yè)面開(kāi)發(fā)，VUE負(fù)責(zé)與后臺(tái)數(shù)據(jù)交互和前端頁(yè)面數(shù)據(jù)的動(dòng)態(tài)渲染，ElementUI負(fù)責(zé)靜態(tài)頁(yè)面的編寫，圖表使用Echarts插件進(jìn)行生成。

6? ?結(jié)論（Conclusion）

本文描述了SpringCloud微服務(wù)架構(gòu)的開(kāi)發(fā)理念，介紹了Spring Cloud提供的微服務(wù)組件，并且基于微服務(wù)架構(gòu)體系開(kāi)發(fā)了食品安全溯源系統(tǒng)。介紹了系統(tǒng)中各個(gè)模塊的設(shè)計(jì)和實(shí)現(xiàn)方法，傳統(tǒng)的監(jiān)管類軟件都是基于傳統(tǒng)的單體架構(gòu)開(kāi)發(fā)的，代碼臃腫繁雜，冗余較高，本文將微服務(wù)架構(gòu)應(yīng)該在相關(guān)軟件中，為監(jiān)管部門提供更加完善的技術(shù)支持，提高開(kāi)發(fā)效率，提高系統(tǒng)的響應(yīng)速度，且對(duì)于新需求的添加更為簡(jiǎn)單快捷與之前的系統(tǒng)功能沖突性小，且負(fù)載均衡和智能容錯(cuò)等功能都可以幫助監(jiān)管部門更好更直觀的進(jìn)行食品安全監(jiān)管。

參考文獻(xiàn)（References）

[1] Hantoro I，Ansje J.L?hr，Belleghem F G A J V ，et al.Microplastics in coastal areas and seafood： implications for food safety[J].Food Additives & Contaminants：Part A，2019：1-38.

[2] Walraven S，Landuyt D，Rafique A，et al.PaaSHopper：Policy-driven middleware for multi-PaaS environments[J].Journal of Internet Services and Applications，2015，6（1）：2.

[3] Jing H，Haihong E，Guan L，et al.Survey on NoSQL database[C].International Conference on Pervasive Computing & Applications，2011.

[4] 王方旭.基于Spring Cloud和Docker的微服務(wù)架構(gòu)設(shè)計(jì)[J].中國(guó)信息化，2018（3）：53-55.

[5] 張羽.一種分布式服務(wù)治理框架的設(shè)計(jì)與實(shí)現(xiàn)[D].北京交通大學(xué)，2016.

[6] 林紅.基于Redis的氣象數(shù)據(jù)分發(fā)管理系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn)[J].軟件工程，2019（03）：47-50.