使用kendynet构建异步redis访问服务
2014-01-20 22:21
453 查看
使用kendynet构建异步redis访问服务
最近开始在kendynet上开发手游服务端,游戏类型是生存挑战类的,要存储的数据结构和类型都比较简单,于是选择了用redis做存储,数据类型使用string基本就足够了。于是在kendynet上写了一个简单的redis异步访问接口.设计理念
1.项目时间紧迫,不打算提供一个大而全的访问接口,只提供一个request接口用以发出redis请求.2.数据在redis中key和value都存储为string,由使用者负责将数据序列化成string,从string反序列化回数据.
3.服务支持本地访问和远程访问,服务自动根据请求发起的位置将结果返回给请求者.
4.数据库操作结果通过异步消息返回给调用者.
使用示例
下面先看一个使用示例:#include <stdio.h> #include <stdlib.h> #include "core/msgdisp.h" #include <stdint.h> #include "testcommon.h" #include "core/db/asyndb.h" asyndb_t asydb; int g = 0; int count = 0; void db_setcallback(struct db_result *result); void db_getcallback(struct db_result *result) { //printf("%s\n",result->result_str); count++; char req[256]; snprintf(req,256,"set key%d %d",g,g); if(0 != asydb->request(asydb,new_dbrequest(db_set,req,db_setcallback,result->ud,make_by_msgdisp((msgdisp_t)result->ud)))) printf("request error\n"); } void db_setcallback(struct db_result *result) { if(result->ud == NULL) printf("error\n"); char req[256]; snprintf(req,256,"get key%d",g); g = (g+1)%102400; asydb->request(asydb,new_dbrequest(db_get,req,db_getcallback,result->ud,make_by_msgdisp((msgdisp_t)result->ud))); } int32_t asynprocesspacket(msgdisp_t disp,msgsender sender,rpacket_t rpk) { uint16_t cmd = rpk_read_uint16(rpk); if(cmd == CMD_DB_RESULT) { struct db_result *result = rpk_read_dbresult(rpk); result->callback(result); free_dbresult(result); } return 1; } static void *service_main(void *ud){ msgdisp_t disp = (msgdisp_t)ud; while(!stop){ msg_loop(disp,50); } return NULL; } int main(int argc,char **argv) { setup_signal_handler(); msgdisp_t disp1 = new_msgdisp(NULL, NULL, NULL, NULL, asynprocesspacket, NULL); thread_t service1 = create_thread(THREAD_JOINABLE); msgdisp_t disp2 = new_msgdisp(NULL, NULL, NULL, NULL, asynprocesspacket, NULL); thread_t service2 = create_thread(THREAD_JOINABLE); asydb = new_asyndb(); asydb->connectdb(asydb,"127.0.0.1",6379); asydb->connectdb(asydb,"127.0.0.1",6379); //发出第一个请求uu char req[256]; snprintf(req,256,"set key%d %d",g,g); asydb->request(asydb,new_dbrequest(db_set,req,db_setcallback,disp1,make_by_msgdisp(disp1))); thread_start_run(service1,service_main,(void*)disp1); asydb->request(asydb,new_dbrequest(db_set,req,db_setcallback,disp2,make_by_msgdisp(disp2))); thread_start_run(service2,service_main,(void*)disp2); uint32_t tick,now; tick = now = GetSystemMs(); while(!stop){ sleepms(100); now = GetSystemMs(); if(now - tick > 1000) { printf("count:%d\n",count); tick = now; count = 0; } } thread_join(service1); thread_join(service2); return 0; }
上面的示例程序创建了一个redis异步处理器,然后建立了两个到同一个redis服务器的连接,在实现中,每个连接都会创建一个工作线程,用以完成数据库请求.这些工作线程会共享一个任务队列,使用者发出的请求被投递到任务队列中,由工作线程提取并执行.
之后创建两个消息分离器和两个线程,然后发起两个set请求和启动消息分离器线程.
当set返回后,由消息分离器回调db_setcallback,在db_setcallback中继续发起一个get请求,
在get的回调db_getcallback继续发起新的set请求,如此反复.
相关文章推荐
- 使用kendynet构建异步redis访问服务
- 使用kubernetes访问外部服务(mysql\redis)
- 使用 TiKV 构建分布式类 Redis 服务
- 使用ASP.NET Web Api构建基于REST风格的服务实战系列教程【二】——使用Repository模式构建数据库访问层
- 使用ASP.NET Web Api构建基于REST风格的服务实战系列教程【二】——使用Repository模式构建数据库访问层
- Linux环境使用Node.js构建访问静态网页的服务
- 如何使用RedisTemplate访问Redis数据结构
- 使用 Silverlight 2 和 WCF 构建服务驱动的应用程序
- iptables禁止外网访问redis server服务默认端口6379的命令
- 为什么 FleaPHP 使用 Table Data Gateway 代替 Active Record 来提供数据库访问服务
- 如何使用 Java 构建微服务?
- RHEL 5服务篇—使用Apache搭建web服务(三)构建web虚拟主机
- 使用ElasticSearch+LogStash+Kibana+Redis搭建日志管理服务
- 使用RestTemplate来构建远程调用服务
- (转)使用异步Python 3.6和Redis编写快速应用程序
- 使用ASP.NET Web Api构建基于REST风格的服务实战系列教程【五】——在Web Api中实现Http方法(Put,Post,Delete)
- Spring Boot 2.0.0.M7 使用异步消息服务-AMQP(RabbitMQ)
- windows下使用远程工具登录虚拟机上的Linux、访问虚拟机上的服务 、端口转发、win7 telnet登陆虚拟机
- Redis学习之构建数据服务详解
- 使用新花生壳搭建外网和手机访问内网web应用服务