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请求,如此反复.

时间: 2024-10-03 23:09:06

kendynet构建异步redis访问服务的相关文章

使用kendynet构建异步redis访问服务

最近开始在kendynet上开发手游服务端,游戏类型是生存挑战类的,要存储的数据结构和类型都比较简单,于是选择了用redis做存储,数据类型使用string基本就足够了.于是在kendynet上写了一个简单的redis异步访问接口. 设计理念 1.项目时间紧迫,不打算提供一个大而全的访问接口,只提供一个request接口用以发出redis请求. 2.数据在redis中key和value都存储为string,由使用者负责将数据序列化成string,从string反序列化回数据. 3.服务支持本地访

WPF异步调用WCF服务

wpf调用wcf时,第一次访问总耗时到达几秒,影响界面的用户体验,因此在wpf加载界面和加载数据时采用异步加载,即异步访问wcf服务, 由于是否采用异步加载和服务端无关,仅仅由客户端自己根据需要来选择,则我们只需要在客户端(WPF)程序中采用异步的方法.如下: //1.创建一个异步对象,访问wcfFunc<string, string, List<NodeItem>> GetDataFromWCF = new Func<string, string, List<Node

[译]Spring Boot 构建一个RESTful Web服务

翻译地址:https://spring.io/guides/gs/rest-service/ 构建一个RESTful Web服务 本指南将指导您完成使用spring创建一个“hello world”RESTful Web服务的过程. 你将会构建什么 您将构建一个将接受HTTP GET请求的服务: 您将构建一个将接受HTTP GET请求的服务: http://localhost:8080/greeting 1 1 并且使用JSON的形式进行响应: {"id":1,"conten

分布式数据访问服务之2—数据实时分析篇

上篇博文中,我们横向对比了业界主流的分布式数据访问服务,可以说是各有所长: 分布式数据访问服务之1—华山论剑篇 在数据库分库分表实现横向伸缩后,数据的综合查询.分析,业界都有哪些解决方案?这是一个值得研究和讨论的主题. 所以,本篇文章中继续研究分库分表后的数据库综合查询和实时分析技术. 去年我们参加了阿里的云栖大会,参会期间咨询了阿里中间件团队的专家,总结了一下,业界有以下三种技术方案: 1. 大数据:大数据中更多的是Hadoop离线分析.Hive. Spark .JStorm等实时分析技术 2

用Docker构建分布式Redis集群

[编者的话]本文介绍了如何使用Docker搭建Redis集群,很多读者都在问Docker能带来哪些实质性的好处,我想本文就是一个很好的例子.不使用Docker你也可以搭建Redis集群,那使用Docker后会有怎么样的优势了?我想可以用两个词总结:快速和复用. 海量技术文章:http://tieba.yunxunmi.com/ 云搜 http://so.yunxunmi.com/ 让搜索更简单 采用html5完全支持手机和PC 我们经常会遇到这样一个问题:当我们想进行一个完整的测试的时候,往往缺

mvc路由引起异步调用web服务的问题

从一篇blog得知使用脚本可以异步调用Web服务,觉得很新鲜,因为自己很少用到Web服务,所以决定写一写看看什么效果. 首先在UI项目(我使用的是MVC4.0)里创建一个Web服务. 添加Web服务后,默认有一个HelloWorld方法.调用该方法有两种形式,一是服务端通过实例化对象调用,二是前端脚本异步 调用.代码分别是: 1.服务端调用 public ActionResult Index() { WebService1 ws = new WebService1(); var str = ws

为什么要用缓存服务器以及在 Java 中实现一个 redis 缓存服务

缓存服务的意义 为什么要使用缓存?说到底是为了提高系统的运行速度.将用户频繁访问的内容存放在离用户最近,访问速度最快的地方,提高用户的响应速度.一个 web 应用的简单结构如下图. web 应用典型架构 在这个结构中,用户的请求通过用户层来到业务层,业务层在从数据层获取数据,返回给用户层.在用户量小,数据量不太大的情况下,这个系统运行得很顺畅.但是随着用户量越来越大,数据库中的数据越来越多,系统的用户响应速度就越来越慢.系统的瓶颈一般都在数据库访问上.这个时候可能会将上面的架构改成下面的来缓解数

从无到有构建亿级微服务秒杀系统

从无到有构建亿级微服务秒杀系统(真实工业界案例) 题取马:zuoz 课成滴志::https://pan.baidu.com/s/1yiNyYTbqMG4PWC4XBoYmJg 录制本套教程的初衷,通过从业10年接触过很多的技术开发人员,尤其在面试一些技术人员的时候,发现他们的技术知识更新较慢,很多人渴望接触到高并发系统和一些高级技术架构,为了帮助更多人能够提升自己和接触到这类技术架构,并满足企业的人才需求,利用业余时间开启了我录制这套教程.通过业余录制的课程有很多学员给我反馈信息,给了我很大的鼓

Redis缓存服务部署

redis缓存服务部署