一种异步更新数据的方法及系统

暂无

一种异步更新数据的方法及系统\n技术领域\n[0001] 本发明涉及数据处理领域，尤其涉及一种异步更新数据的方法及系统。\n背景技术\n[0002] 为提高站点和web应用程序的响应速度，改善客户的用户体验，缓存的使用是最常见也是最有效的技术，通常是将大的且使用频率较高的数据形成缓存，实现空间换取时间，所以在网站和应用程序的设计中如何合理的使用缓存显得尤为重要，其中，缓存数据的实效性就是其中的关键因素。\n[0003] 现有缓存技术中一般使用相对过期或绝对过期方式，这样可能会造成在同一时间点大量缓存数据集体失效的现象，一旦缓存数据过期，web服务将直接从数据存储设备中读取，而这种方式导致数据源服务器压力倍增，使web服务在该时间点访问较慢。\n发明内容\n[0004] 本发明的目的在于提供一种异步更新数据的方法及系统，从而解决现有技术中存在的前述问题。\n[0005] 为了实现上述目的，本发明所述异步更新数据的方法，该方法包括：\n[0006] S1，接收到服务器发出获取目标数据的请求，判断缓存系统中是否存储目标数据，如果是，则进入S2；如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，然后返回S1；\n[0007] S2，从缓存系统中获取缓存目标数据，向发出请求的服务器发送缓存的目标数据；\n同时，判断缓存的目标数据的缓存有效期是否过期，如果是，则发送消息到缓存更新服务器，更新缓存系统中的缓存数据，如果否，则返回S2继续判断。\n[0008] 优选地，从发出请求目标数据的服务器接收目标数据，分析所述目标数据，并获得所述目标数据的关键代码，判断缓存系统中是否存在与所述关键代码存在一一映射的数据，如果是，则缓存系统中存储目标数据，如果否，则缓存系统未存储目标数据。\n[0009] 优选地，在步骤S1之前，所述缓存系统中至少存储一个长有效期的数据。\n[0010] 优选地，步骤S2中，判断缓存的目标数据的缓存有效期是否过期，具体按照下述方法实现：获取缓存系统中存储的缓存目标数据的有效期，判断当前时间是否在所述有效期内，如果是，则所述缓存目标的缓存有效期没有过期，如果否，则所述缓存目标的缓存过期。\n[0011] 优选地，步骤S2，所述缓存更新服务器，更新缓存系统中的缓存数据，具体按照下述步骤实现：\n[0012] 缓存系统将过期的缓存目标数据以消息的形式发送到缓存更新服务器，所述缓存更新服务器判断接收到的缓存目标数据中携带的key是否已经被缓存，\n[0013] 如果是，则将该缓存目标数据存储到缓存系统中，并继续判断下一个消息；\n[0014] 如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，并继续判断下一个消息，直至完成缓存系统中数据的更新为止。\n[0015] 优选地，所述缓存系统为分布式缓存服务器。\n[0016] 本发明所述实现所述异步更新数据的方法的系统，所述系统包括：发出目标数据请求的请求服务器、缓存系统、第一判断模块、第二判断模块、更新模块和发送模块；\n[0017] 所述第一判断模块，判断缓存系统中是否存储目标数据，如果是，则将缓存系统中存储的缓存目标数据发送给发送模块；如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，然后继续判断下一条请求中的目标数据在缓存系统中是否存在，直至向发出请求的服务器发送缓存的目标数据为止；\n[0018] 所述第二判断模块，判断缓存系统中存储的缓存目标数据的缓存是否过期，如果是，则发送消息到更新模块，更新缓存系统中的缓存数据，如果否，则继续判断下一条消息中的缓存数据是否过期；\n[0019] 更新模块，对缓存系统中的缓存数据进行更新；\n[0020] 发送模块，将缓存系统中存储的目标缓存数据发送给请求服务器。\n[0021] 本发明的有益效果是：\n[0022] 本发明所述方法保证目标缓存数据一直存在于缓存系统中，通过另一个应用程序来更新缓存，这样缓存系统会一直有效并及时更新。\n[0023] 通过消息队列来保证消息的同步，使缓存及时更新并能解耦业务和数据的更新，使web服务器和处理缓存的服务隔离，减少web服务器的压力。其中Rabbit MQ是一种高可用的消息队列，并且支持集群部署的中间件。\n附图说明\n[0024] 图1是异步更新数据的方法流程示意图；\n[0025] 图2是缓存更新服务器更新缓存数据的流程图。\n具体实施方式\n[0026] 为了使本发明的目的、技术方案及优点更加清楚明白，以下结合附图，对本发明进行进一步详细说明。应当理解，此处所描述的具体实施方式仅仅用以解释本发明，并不用于限定本发明。\n[0027] 实施例\n[0028] 本实施例所述异步更新数据的方法，该方法包括：\n[0029] S1，接收到服务器发出获取目标数据的请求，判断缓存系统中是否存储目标数据，如果是，则进入S2；如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，然后返回S1，直至向发出请求的服务器发送缓存的目标数据为止；\n[0030] S2，从缓存系统中获取缓存目标数据，向发出请求的服务器发送缓存的目标数据；\n同时，判断缓存的目标数据的缓存是否过期，如果是，则发送消息到缓存更新服务器，更新缓存系统中的缓存数据，如果否，则返回S2继续判断；其中，所述缓存系统为分布式缓存服务器。\n[0031] 更详细的解释说明：\n[0032] (一)步骤S1中，判断缓存系统中是否存储目标数据，具体按照下述方法：从发出请求目标数据的服务器接收目标数据，分析所述目标数据，并获得所述目标数据的关键代码，判断缓存系统中是否存在与所述关键代码存在一一映射的数据，如果是，则缓存系统中存储目标数据，如果否，则缓存系统未存储目标数据。\n[0033] 在步骤S1之前，所述缓存系统中至少存储一个有效期长的数据。\n[0034] (二)步骤S2中，判断缓存的目标数据的缓存是否过期，具体按照下述方法实现：获取缓存系统中存储的缓存目标数据的有效期，判断当前时间是否在所述有效期内，如果是，则所述缓存目标的缓存有效期没有过期，如果否，则所述缓存目标的缓存过期。\n[0035] 步骤S2，所述缓存更新服务器，更新缓存系统中的缓存数据，具体按照下述步骤实现：缓存系统将过期的缓存目标数据以消息的形式发送到缓存更新服务器，所述缓存更新服务器判断接收到的缓存目标数据中携带的key是否已经被缓存，如果是，则将该缓存目标数据存储到缓存系统中，并继续判断下一个消息；如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，完成缓存系统中数据的更新。\n[0036] 一种实现如实施例1所述异步更新数据的方法的系统，所述系统包括：发出目标数据请求的请求服务器、缓存系统、第一判断模块、第二判断模块、更新模块和发送模块；\n[0037] 所述第一判断模块，判断缓存系统中是否存储目标数据，如果是，则将缓存系统中存储的缓存目标数据发送给发送模块；如果否，则从源数据中读取需要的目标数据并缓存到缓存系统中，然后继续判断下一条请求中的目标数据在缓存系统中是否存在，直至向发出请求的服务器发送缓存的目标数据为止；\n[0038] 所述第二判断模块，判断缓存系统中存储的缓存目标数据的缓存是否过期，如果是，则发送消息到更新模块，更新缓存系统中的缓存数据，如果否，则继续判断下一条消息中的缓存数据是否过期；\n[0039] 更新模块，对缓存系统中的缓存数据进行更新；\n[0040] 发送模块，将缓存系统中存储的目标缓存数据发送给请求服务器。\n[0041] 通过采用本发明公开的上述技术方案，得到了如下有益的效果：\n[0042] 本发明所述方法保证目标缓存数据一直存在于缓存系统中，通过另一个应用程序来更新缓存，这样缓存系统会一直有效并及时更新。\n[0043] 通过消息队列来保证消息的同步，使缓存及时更新并能解耦业务和数据的更新，使web服务器和处理缓存的服务隔离，减少web服务器的压力。其中Rabbit MQ是一种高可用的消息队列，并且支持集群部署的中间件。\n[0044] 以上所述仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视本发明的保护范围。