基于Hiredis异步API的聊天系统实现
基于Hiredis异步API的聊天系统实现 上一篇文章http://blog.csdn.net/qq_34788352/article/details/51313027使用Hiredis的同步API实现了发送消息的客户端，当我使用同步API实现订阅频道客户端时，一旦订阅频道，就会出现无法操作的情况，这是就是同步和异步的
基于Hiredis异步API的聊天系统实现
上一篇文章http://blog.csdn.net/qq_34788352/article/details/51313027使用Hiredis的同步API实现了发送消息的客户端，当我使用同步API实现订阅频道客户端时，一旦订阅频道，就会出现无法操作的情况，这是就是同步和异步的问题。使用同步API，订阅频道后，客户端会进入阻塞状态，等待订阅频道发布的消息，不能实现既订阅频道，又能发布消息的功能。为了实现一个客户端既能订阅频道，又能发布消息的功能，就需要使用Hiredis的异步API。
首先特别感谢黄天霸、tickTick、vah101，当我遇到各种各样奇怪问题的时候，你们的帖子给与了我解答，谢谢。
开始正题，hiredis异步的实现主要是依靠redis自带的ae事件库或者libev事件库或者libevent的事件库或者libuv事件库。网上一些人是通过libevent事件库来实现，本系统则使用Redis自带ae事件库来实现，Redis不用libevent事件库而选择重写一个ae事件库，必定有其道理。
首先介绍使用到的异步API，位于async.h中：
<code class=" hljs perl">redisAsyncContext <span class="hljs-variable">*redisAsyncConnect</span>(const char <span class="hljs-variable">*ip</span>, <span class="hljs-keyword">int</span> port); <span class="hljs-regexp">//</span>用于建立异步连接 <span class="hljs-keyword">int</span> redisAsyncSetConnectCallback(redisAsyncContext <span class="hljs-variable">*ac</span>, redisConnectCallback <span class="hljs-variable">*fn</span>); <span class="hljs-regexp">//</span>设置连接回调函数，回调函数形式：void callback(const redisAsyncContext <span class="hljs-variable">*c</span>, <span class="hljs-keyword">int</span> status); <span class="hljs-keyword">int</span> redisAsyncSetDisconnectCallback(redisAsyncContext <span class="hljs-variable">*ac</span>, redisDisconnectCallback <span class="hljs-variable">*fn</span>); <span class="hljs-regexp">//</span>设置断开连接回调函数,回调函数形式：void callback(const redisAsyncContext <span class="hljs-variable">*c</span>, <span class="hljs-keyword">int</span> status); void redisAsyncDisconnect(redisAsyncContext <span class="hljs-variable">*ac</span>); <span class="hljs-regexp">//</span>断开异步连接 void redisAsyncFree(redisAsyncContext <span class="hljs-variable">*ac</span>); <span class="hljs-regexp">//</span>释放建立连接时，创建的redisAsyncContext结构 <span class="hljs-keyword">int</span> redisAsyncCommand(redisAsyncContext <span class="hljs-variable">*ac</span>, redisCallbackFn <span class="hljs-variable">*fn</span>, void <span class="hljs-variable">*privdata</span>, const char <span class="hljs-variable">*format</span>, ...); <span class="hljs-regexp">//</span>发送Redis命令，需要实现一个回调函数来出来命令的返回，fn是回调函数的地址,回调函数形式：void callback(redisAsyncContext <span class="hljs-variable">*c</span>, void <span class="hljs-variable">*reply</span>, void <span class="hljs-variable">*pridata</span>); </code>
有了上面的异步API，就可以开始客户端的撰写。
首先封装订阅端
<code class=" hljs cpp"><span class="hljs-comment">//sub_client.h</span>
<span class="hljs-preprocessor">#ifndef REDIS_SUB_CLIENT_H </span>
<span class="hljs-preprocessor">#define REDIS_SUB_CLIENT_H </span>
<span class="hljs-keyword">extern</span> <span class="hljs-string">"C"</span>
{
<span class="hljs-preprocessor">#include <stdlib.h> </span>
<span class="hljs-preprocessor">#include <async.h> </span>
<span class="hljs-preprocessor">#include <adapters/ae.h> </span>
<span class="hljs-preprocessor">#include <unistd.h> </span>
<span class="hljs-preprocessor">#include <pthread.h> </span>
<span class="hljs-preprocessor">#include <semaphore.h> </span>
}
<span class="hljs-preprocessor">#include <string> </span>
<span class="hljs-preprocessor">#include <vector> </span>
<span class="hljs-keyword">using</span> <span class="hljs-keyword">namespace</span> <span class="hljs-built_in">std</span>;
<span class="hljs-keyword">class</span> CRedisSubClient
{
<span class="hljs-keyword">public</span>:
CRedisSubClient();
~CRedisSubClient();
<span class="hljs-keyword">bool</span> init(); <span class="hljs-comment">//初始化，事件对象，信号量 </span>
<span class="hljs-keyword">bool</span> uninit(); <span class="hljs-comment">//释放对象</span>
<span class="hljs-keyword">bool</span> connect(); <span class="hljs-comment">//连接服务器</span>
<span class="hljs-keyword">bool</span> disconnect(); <span class="hljs-comment">//断开服务器</span>
<span class="hljs-comment">//订阅频道 </span>
<span class="hljs-keyword">bool</span> subscribe(<span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &channel_name);
<span class="hljs-keyword">private</span>:
<span class="hljs-comment">// 下面三个回调函数供redis服务调用 </span>
<span class="hljs-comment">// 连接回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> connect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status);
<span class="hljs-comment">// 断开连接的回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> disconnect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status);
<span class="hljs-comment">// 执行命令回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> command_callback(redisAsyncContext *redis_context,
<span class="hljs-keyword">void</span> *reply, <span class="hljs-keyword">void</span> *privdata);
<span class="hljs-comment">// 事件分发线程函数 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> *event_thread(<span class="hljs-keyword">void</span> *data);
<span class="hljs-keyword">void</span> *event_proc();
<span class="hljs-keyword">private</span>:
<span class="hljs-comment">// ae事件对象 </span>
aeEventLoop *loop;
<span class="hljs-comment">// 事件线程ID </span>
pthread_t _event_thread;
<span class="hljs-comment">// 事件线程的信号量 </span>
sem_t _event_sem;
<span class="hljs-comment">// hiredis异步对象 </span>
redisAsyncContext *_redis_context;
};
<span class="hljs-preprocessor">#endif </span>
</code>使用extern “C”是因为redis和hiredis都是c写的，当使用c++链接c代码生成的库中的函数时，会出现undefined reference的问题。
订阅端的实现
<code class=" hljs cpp"><span class="hljs-comment">//sub_client.cpp</span>
<span class="hljs-preprocessor">#include <stddef.h> </span>
<span class="hljs-preprocessor">#include <assert.h> </span>
<span class="hljs-preprocessor">#include <string.h> </span>
<span class="hljs-preprocessor">#include "sub_client.h" </span>
<span class="hljs-keyword">using</span> <span class="hljs-keyword">namespace</span> <span class="hljs-built_in">std</span>;
CRedisSubClient::CRedisSubClient():loop(<span class="hljs-number">0</span>), _event_thread(<span class="hljs-number">0</span>),
_redis_context(<span class="hljs-number">0</span>)
{
}
CRedisSubClient::~CRedisSubClient()
{
}
<span class="hljs-keyword">bool</span> CRedisSubClient::init()
{
loop = aeCreateEventLoop(<span class="hljs-number">64</span>); <span class="hljs-comment">// 创建ae对象</span>
<span class="hljs-keyword">if</span> (NULL == loop)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Create redis event failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-built_in">memset</span>(&_event_sem, <span class="hljs-number">0</span>, <span class="hljs-keyword">sizeof</span>(_event_sem));
<span class="hljs-keyword">int</span> ret = sem_init(&_event_sem, <span class="hljs-number">0</span>, <span class="hljs-number">0</span>); <span class="hljs-comment">//初始化线程信号量</span>
<span class="hljs-keyword">if</span> (ret != <span class="hljs-number">0</span>)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Init sem failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisSubClient::uninit()
{
loop = NULL;
sem_destroy(&_event_sem);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisSubClient::connect()
{
_redis_context = redisAsyncConnect(<span class="hljs-string">"127.0.0.1"</span>, <span class="hljs-number">6379</span>); <span class="hljs-comment">// 异步连接到redis服务器上，使用6380端口</span>
<span class="hljs-keyword">if</span> (NULL == _redis_context)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Connect redis failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-keyword">if</span> (_redis_context->err)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Connect redis error: %d, %s\n"</span>,
_redis_context->err, _redis_context->errstr); <span class="hljs-comment">// 输出错误信息 </span>
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
redisAeAttach(loop,_redis_context); <span class="hljs-comment">// 将事件绑定到redis context上，使redis的回调跟事件关联 </span>
<span class="hljs-comment">// 创建事件处理线程 </span>
<span class="hljs-keyword">int</span> ret = pthread_create(&_event_thread, <span class="hljs-number">0</span>, &CRedisSubscriber::event_thread, <span class="hljs-keyword">this</span>);
<span class="hljs-keyword">if</span> (ret != <span class="hljs-number">0</span>)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Create event thread failed.\n"</span>);
disconnect();
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-comment">// 设置连接回调，当异步调用连接后，服务器处理连接请求结束后调用，通知调用者连接的状态 </span>
redisAsyncSetConnectCallback(_redis_context,
&CRedisSubClient::connect_callback);
<span class="hljs-comment">// 设置断开连接回调，当服务器断开连接后，通知调用者连接断开，调用者可以利用这个函数实现重连 </span>
redisAsyncSetDisconnectCallback(_redis_context,
&CRedisSubClient::disconnect_callback);
<span class="hljs-comment">// 启动事件线程 </span>
sem_post(&_event_sem);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisSubClient::disconnect()
{
<span class="hljs-keyword">if</span> (_redis_context)
{
redisAsyncDisconnect(_redis_context);
redisAsyncFree(_redis_context);
_redis_context = NULL;
}
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisSubClient::subscribe(<span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &channel_name)
{
<span class="hljs-keyword">int</span> ret = redisAsyncCommand(_redis_context,
&CRedisSubscriber::command_callback, <span class="hljs-keyword">this</span>, <span class="hljs-string">"SUBSCRIBE %s"</span>,
channel_name.c_str()); <span class="hljs-comment">//订阅一个频道</span>
<span class="hljs-keyword">if</span> (REDIS_ERR == ret)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Subscribe command failed: %d\n"</span>, ret);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Subscribe success: %s\n"</span>, channel_name.c_str());
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">void</span> CRedisSubClient::connect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status)
{
<span class="hljs-keyword">if</span> (status != REDIS_OK)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Error: %s\n"</span>, redis_context->errstr);
}
<span class="hljs-keyword">else</span>
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Redis connected!"</span>);
}
}
<span class="hljs-keyword">void</span> CRedisSubClient::disconnect_callback(
<span class="hljs-keyword">const</span> redisAsyncContext *redis_context, <span class="hljs-keyword">int</span> status)
{
<span class="hljs-keyword">if</span> (status != REDIS_OK)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Error: %s\n"</span>, redis_context->errstr);
}
}
<span class="hljs-comment">// 消息接收回调函数 </span>
<span class="hljs-keyword">void</span> CRedisSubClient::command_callback(redisAsyncContext *redis_context,
<span class="hljs-keyword">void</span> *reply, <span class="hljs-keyword">void</span> *privdata)
{
<span class="hljs-keyword">if</span> (NULL == reply || NULL == privdata) {
<span class="hljs-keyword">return</span> ;
}
redisReply *redis_reply = <span class="hljs-keyword">reinterpret_cast</span><redisReply *>(reply);
<span class="hljs-comment">// 订阅接收到的消息是一个带三元素的数组 </span>
<span class="hljs-keyword">if</span> (redis_reply->type == REDIS_REPLY_ARRAY &&
redis_reply->elements == <span class="hljs-number">3</span>)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Recieve message:%s %s %s\n"</span>,
redis_reply->element[<span class="hljs-number">0</span>]->str
redis_reply->element[<span class="hljs-number">1</span>]->str
redis_reply->element[<span class="hljs-number">2</span>]->str);
}
}
<span class="hljs-keyword">void</span> *CRedisSubClient::event_thread(<span class="hljs-keyword">void</span> *data)
{
<span class="hljs-keyword">if</span> (NULL == data)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Error!\n"</span>);
assert(<span class="hljs-keyword">false</span>);
<span class="hljs-keyword">return</span> NULL;
}
CRedisSubClient *self_this = <span class="hljs-keyword">reinterpret_cast</span><CRedisSubClient *>(data);
<span class="hljs-keyword">return</span> self_this->event_proc();
}
<span class="hljs-keyword">void</span> *CRedisSubClient::event_proc()
{
sem_wait(&_event_sem);
<span class="hljs-comment">//进行事件处理循环 </span>
aeMain(loop);
<span class="hljs-keyword">return</span> NULL;
} </code>发布端的封装：
<code class=" hljs cpp"><span class="hljs-comment">//pub_client.h</span>
<span class="hljs-preprocessor">#ifndef REDIS_PUB_CLIENT_H </span>
<span class="hljs-preprocessor">#define REDIS_PUB_CLIENT_H </span>
<span class="hljs-keyword">extern</span> <span class="hljs-string">"C"</span>
{
<span class="hljs-preprocessor">#include <stdlib.h> </span>
<span class="hljs-preprocessor">#include <async.h> </span>
<span class="hljs-preprocessor">#include <adapters/ae.h> </span>
<span class="hljs-preprocessor">#include <unistd.h> </span>
<span class="hljs-preprocessor">#include <pthread.h> </span>
<span class="hljs-preprocessor">#include <semaphore.h> </span>
}
<span class="hljs-preprocessor">#include <string> </span>
<span class="hljs-preprocessor">#include <vector> </span>
<span class="hljs-keyword">using</span> <span class="hljs-keyword">namespace</span> <span class="hljs-built_in">std</span>;
<span class="hljs-keyword">class</span> CRedisPubClient
{
<span class="hljs-keyword">public</span>:
CRedisPubClient();
~CRedisPubClient();
<span class="hljs-keyword">bool</span> init(); <span class="hljs-comment">//初始化，事件对象，信号量 </span>
<span class="hljs-keyword">bool</span> uninit(); <span class="hljs-comment">//释放对象</span>
<span class="hljs-keyword">bool</span> connect(); <span class="hljs-comment">//连接服务器</span>
<span class="hljs-keyword">bool</span> disconnect(); <span class="hljs-comment">//断开服务器</span>
<span class="hljs-comment">//订阅频道 </span>
<span class="hljs-keyword">bool</span> publish(<span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &channel_name, <span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &message);
<span class="hljs-keyword">private</span>:
<span class="hljs-comment">// 下面三个回调函数供redis服务调用 </span>
<span class="hljs-comment">// 连接回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> connect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status);
<span class="hljs-comment">// 断开连接的回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> disconnect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status);
<span class="hljs-comment">// 执行命令回调 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> command_callback(redisAsyncContext *redis_context,
<span class="hljs-keyword">void</span> *reply, <span class="hljs-keyword">void</span> *privdata);
<span class="hljs-comment">// 事件分发线程函数 </span>
<span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> *event_thread(<span class="hljs-keyword">void</span> *data);
<span class="hljs-keyword">void</span> *event_proc();
<span class="hljs-keyword">private</span>:
<span class="hljs-comment">// ae事件对象 </span>
aeEventLoop *loop;
<span class="hljs-comment">// 事件线程ID </span>
pthread_t _event_thread;
<span class="hljs-comment">// 事件线程的信号量 </span>
sem_t _event_sem;
<span class="hljs-comment">// hiredis异步对象 </span>
redisAsyncContext *_redis_context;
};
<span class="hljs-preprocessor">#endif </span></code>发布端的实现：
<code class=" hljs cpp"><span class="hljs-comment">//pub_client.cpp</span>
<span class="hljs-preprocessor">#include <stddef.h> </span>
<span class="hljs-preprocessor">#include <assert.h> </span>
<span class="hljs-preprocessor">#include <string.h> </span>
<span class="hljs-preprocessor">#include "pub_client.h" </span>
<span class="hljs-keyword">using</span> <span class="hljs-keyword">namespace</span> <span class="hljs-built_in">std</span>;
CRedisPubClient::CRedisPubClient():loop(<span class="hljs-number">0</span>), _event_thread(<span class="hljs-number">0</span>),
_redis_context(<span class="hljs-number">0</span>)
{
}
CRedisPubClient::~CRedisPubClient()
{
}
<span class="hljs-keyword">bool</span> CRedisPubClient::init()
{
loop = aeCreateEventLoop(<span class="hljs-number">64</span>); <span class="hljs-comment">// 创建ae对象</span>
<span class="hljs-keyword">if</span> (NULL == loop)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Create redis event failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-built_in">memset</span>(&_event_sem, <span class="hljs-number">0</span>, <span class="hljs-keyword">sizeof</span>(_event_sem));
<span class="hljs-keyword">int</span> ret = sem_init(&_event_sem, <span class="hljs-number">0</span>, <span class="hljs-number">0</span>); <span class="hljs-comment">//初始化线程信号量</span>
<span class="hljs-keyword">if</span> (ret != <span class="hljs-number">0</span>)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Init sem failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisPubClient::uninit()
{
loop = NULL;
sem_destroy(&_event_sem);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisPubClient::connect()
{
_redis_context = redisAsyncConnect(<span class="hljs-string">"127.0.0.1"</span>, <span class="hljs-number">6379</span>); <span class="hljs-comment">// 异步连接到redis服务器上，使用6380端口</span>
<span class="hljs-keyword">if</span> (NULL == _redis_context)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Connect redis failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-keyword">if</span> (_redis_context->err)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Connect redis error: %d, %s\n"</span>,
_redis_context->err, _redis_context->errstr); <span class="hljs-comment">// 输出错误信息 </span>
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
redisAeAttach(loop,_redis_context); <span class="hljs-comment">// 将事件绑定到redis context上，使redis的回调跟事件关联 </span>
<span class="hljs-comment">// 创建事件处理线程 </span>
<span class="hljs-keyword">int</span> ret = pthread_create(&_event_thread, <span class="hljs-number">0</span>, &CRedisSubscriber::event_thread, <span class="hljs-keyword">this</span>);
<span class="hljs-keyword">if</span> (ret != <span class="hljs-number">0</span>)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Create event thread failed.\n"</span>);
disconnect();
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-comment">// 设置连接回调，当异步调用连接后，服务器处理连接请求结束后调用，通知调用者连接的状态 </span>
redisAsyncSetConnectCallback(_redis_context,
&CRedisSubClient::connect_callback);
<span class="hljs-comment">// 设置断开连接回调，当服务器断开连接后，通知调用者连接断开，调用者可以利用这个函数实现重连 </span>
redisAsyncSetDisconnectCallback(_redis_context,
&CRedisSubClient::disconnect_callback);
<span class="hljs-comment">// 启动事件线程 </span>
sem_post(&_event_sem);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisPubClient::disconnect()
{
<span class="hljs-keyword">if</span> (_redis_context)
{
redisAsyncDisconnect(_redis_context);
redisAsyncFree(_redis_context);
_redis_context = NULL;
}
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">bool</span> CRedisPubClient::publish(<span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &channel_name, <span class="hljs-keyword">const</span> <span class="hljs-built_in">string</span> &message)
{
<span class="hljs-keyword">int</span> ret = redisAsyncCommand(_redis_context,
&CRedisPublisher::command_callback, <span class="hljs-keyword">this</span>, <span class="hljs-string">"PUBLISH %s %s"</span>,
channel_name.c_str(), message.c_str()); <span class="hljs-comment">//发布消息 </span>
<span class="hljs-keyword">if</span> (REDIS_ERR == ret)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Publish command failed: %d\n"</span>, ret);
<span class="hljs-keyword">return</span> <span class="hljs-keyword">false</span>;
}
<span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}
<span class="hljs-keyword">void</span> CRedisPubClient::connect_callback(<span class="hljs-keyword">const</span> redisAsyncContext *redis_context,
<span class="hljs-keyword">int</span> status)
{
<span class="hljs-keyword">if</span> (status != REDIS_OK)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Error: %s\n"</span>, redis_context->errstr);
}
<span class="hljs-keyword">else</span>
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Redis connected!"</span>);
}
}
<span class="hljs-keyword">void</span> CRedisPubClient::disconnect_callback(
<span class="hljs-keyword">const</span> redisAsyncContext *redis_context, <span class="hljs-keyword">int</span> status)
{
<span class="hljs-keyword">if</span> (status != REDIS_OK)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Error: %s\n"</span>, redis_context->errstr);
}
}
<span class="hljs-comment">// 消息接收回调函数 </span>
<span class="hljs-keyword">void</span> CRedisPubClient::command_callback(redisAsyncContext *redis_context,
<span class="hljs-keyword">void</span> *reply, <span class="hljs-keyword">void</span> *privdata)
{
<span class="hljs-keyword">if</span> (NULL == reply || NULL == privdata)
{
<span class="hljs-keyword">return</span> ;
}
redisReply *redis_reply = <span class="hljs-keyword">reinterpret_cast</span><redisReply *>(reply);
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Publish: %s"</span>,redis_reply.str);
}
<span class="hljs-keyword">void</span> *CRedisPubClient::event_thread(<span class="hljs-keyword">void</span> *data)
{
<span class="hljs-keyword">if</span> (NULL == data)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">": Error!\n"</span>);
assert(<span class="hljs-keyword">false</span>);
<span class="hljs-keyword">return</span> NULL;
}
CRedisPubClient *self_this = <span class="hljs-keyword">reinterpret_cast</span><CRedisPubClient *>(data);
<span class="hljs-keyword">return</span> self_this->event_proc();
}
<span class="hljs-keyword">void</span> *CRedisPubClient::event_proc()
{
sem_wait(&_event_sem);
<span class="hljs-comment">//进行事件处理循环 </span>
aeMain(loop);
<span class="hljs-keyword">return</span> NULL;
} </code>测试封装的sub_client和pub_client类:
<code class=" hljs cpp"><span class="hljs-comment">//test_subpub.cpp</span>
<span class="hljs-preprocessor">#include "pub_client.h"</span>
<span class="hljs-preprocessor">#include "sub_client.h" </span>
<span class="hljs-keyword">int</span> main(<span class="hljs-keyword">int</span> argc, <span class="hljs-keyword">char</span> *argv[])
{
CRedisPubClient publisher;
CRedisSubClient subcriber;
<span class="hljs-keyword">bool</span> ret_pub = publisher.init();
<span class="hljs-keyword">bool</span> ret_sub = subcriber.init();
<span class="hljs-keyword">if</span> (!ret_sub&&!ret_pub)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"Init failed.\n"</span>);
<span class="hljs-keyword">return</span> <span class="hljs-number">0</span>;
}
ret_pub = publisher.connect();
ret_sub = subcriber.connect();
<span class="hljs-keyword">if</span> (!ret_sub&&!ret_pub)
{
<span class="hljs-built_in">printf</span>(<span class="hljs-string">"connect failed."</span>);
<span class="hljs-keyword">return</span> <span class="hljs-number">0</span>;
}
subscriber.subcribe(<span class="hljs-string">"sports"</span>);
<span class="hljs-keyword">while</span> (<span class="hljs-keyword">true</span>)
{
publisher.publish(<span class="hljs-string">"sports"</span>, <span class="hljs-string">"ball"</span>);
sleep(<span class="hljs-number">1</span>);
}
publisher.disconnect();
publisher.uninit();
subscriber.disconnect();
subscriber.disconnect();
<span class="hljs-keyword">return</span> <span class="hljs-number">0</span>;
} </code>终于到了编译链接运行的阶段，我在这个地方卡了快一天，期间各种编译、链接的错误。直接编译链接会出现找到不aeCreateFileEvent，aeDeleteFileEvent，aeMain等等错误。
- 先将redis/src文件夹中的ae.c，ae.h，ae_epoll.c，config.h，zmalloc.c，zmalloc.h拷贝至hiredis目录下
- 用gcc -c ae.c gcc -c zmalloc.c生成ae.o和zmalloc.o，利用这两个文件生成静态库 ar -r libar.a ae.o zmalloc.o
- 然后编译g++ -o test_subpub test_subpub.cpp pub_client.cpp sub_client.cpp -pthread -I ../ -I./ -I ../adapters ../libhiredis.a ../libae.a
- 运行./test_subpub
可以看到，客户端中消息在不断地滚动，即同时实现了订阅频道和发送消息的功能。
Outils d'IA chauds
Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes
AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.
Undress AI Tool
Images de déshabillage gratuites
Clothoff.io
Dissolvant de vêtements AI
Video Face Swap
Échangez les visages dans n'importe quelle vidéo sans effort grâce à notre outil d'échange de visage AI entièrement gratuit !
Article chaud
Outils chauds
Bloc-notes++7.3.1
Éditeur de code facile à utiliser et gratuit
SublimeText3 version chinoise
Version chinoise, très simple à utiliser
Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP
Dreamweaver CS6
Outils de développement Web visuel
SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)
Sujets chauds
1393
52
1205
24
La multiplication matricielle universelle de CUDA : de l'entrée à la maîtrise !
Mar 25, 2024 pm 12:30 PM
La multiplication matricielle générale (GEMM) est un élément essentiel de nombreuses applications et algorithmes, et constitue également l'un des indicateurs importants pour évaluer les performances du matériel informatique. Une recherche approfondie et l'optimisation de la mise en œuvre de GEMM peuvent nous aider à mieux comprendre le calcul haute performance et la relation entre les systèmes logiciels et matériels. En informatique, une optimisation efficace de GEMM peut augmenter la vitesse de calcul et économiser des ressources, ce qui est crucial pour améliorer les performances globales d’un système informatique. Une compréhension approfondie du principe de fonctionnement et de la méthode d'optimisation de GEMM nous aidera à mieux utiliser le potentiel du matériel informatique moderne et à fournir des solutions plus efficaces pour diverses tâches informatiques complexes. En optimisant les performances de GEMM
Le système de conduite intelligent Qiankun ADS3.0 de Huawei sera lancé en août et sera lancé pour la première fois sur Xiangjie S9
Jul 30, 2024 pm 02:17 PM
Le 29 juillet, lors de la cérémonie de lancement de la 400 000e nouvelle voiture d'AITO Wenjie, Yu Chengdong, directeur général de Huawei, président de Terminal BG et président de la BU Smart Car Solutions, a assisté et prononcé un discours et a annoncé que les modèles de la série Wenjie seraient sera lancé cette année En août, la version Huawei Qiankun ADS 3.0 a été lancée et il est prévu de pousser successivement les mises à niveau d'août à septembre. Le Xiangjie S9, qui sortira le 6 août, lancera le système de conduite intelligent ADS3.0 de Huawei. Avec l'aide du lidar, la version Huawei Qiankun ADS3.0 améliorera considérablement ses capacités de conduite intelligente, disposera de capacités intégrées de bout en bout et adoptera une nouvelle architecture de bout en bout de GOD (identification générale des obstacles)/PDP (prédictive prise de décision et contrôle), fournissant la fonction NCA de conduite intelligente d'une place de stationnement à l'autre et mettant à niveau CAS3.0
Comment mettre en œuvre la double connexion WeChat sur les téléphones mobiles Huawei ?
Mar 24, 2024 am 11:27 AM
Comment mettre en œuvre la double connexion WeChat sur les téléphones mobiles Huawei ? Avec l’essor des réseaux sociaux, WeChat est devenu l’un des outils de communication indispensables dans la vie quotidienne des gens. Cependant, de nombreuses personnes peuvent rencontrer un problème : se connecter à plusieurs comptes WeChat en même temps sur le même téléphone mobile. Pour les utilisateurs de téléphones mobiles Huawei, il n'est pas difficile d'obtenir une double connexion WeChat. Cet article explique comment obtenir une double connexion WeChat sur les téléphones mobiles Huawei. Tout d'abord, le système EMUI fourni avec les téléphones mobiles Huawei offre une fonction très pratique : l'ouverture d'une double application. Grâce à la fonction de double ouverture de l'application, les utilisateurs peuvent simultanément
Comment restaurer le chat si WeChat ne l'affiche pas ? WeChat n'affiche pas la méthode de récupération de chat
Mar 13, 2024 pm 01:50 PM
WeChat, en tant que l'un des logiciels sociaux les plus populaires de nos jours, offre de riches fonctions de chat. Mais parfois, nous pouvons rencontrer la situation « Ne pas afficher ce chat », ce qui entraîne le masquage de certaines conversations importantes. Pour restaurer ces discussions, c’est en réalité très simple. Tant que vous suivez ces étapes, vous pouvez facilement restaurer les discussions cachées et continuer à profiter de l'expérience de communication pratique apportée par WeChat. Comment restaurer le chat si WeChat ne l'affiche pas ? WeChat n'affiche pas la méthode de récupération de chat Méthode 1 : Essayez de rechercher directement le nom ou le mot-clé du partenaire de discussion dans la liste des messages WeChat. Si la recherche est trouvée, cliquez pour accéder à l'interface de chat, afin que le chat puisse être restauré et affiché. Deuxième méthode, restauration via le chat entre amis : ouvrez WeChat, cliquez sur le carnet d'adresses, recherchez l'ami qui est affiché dans le chat caché et cliquez pour envoyer un message
Quelle version du système Apple 16 est la meilleure ?
Mar 08, 2024 pm 05:16 PM
La meilleure version du système Apple 16 est iOS16.1.4. La meilleure version du système iOS16 peut varier d'une personne à l'autre. Les ajouts et améliorations de l'expérience d'utilisation quotidienne ont également été salués par de nombreux utilisateurs. Quelle version du système Apple 16 est la meilleure ? Réponse : iOS16.1.4 La meilleure version du système iOS 16 peut varier d'une personne à l'autre. Selon les informations publiques, iOS16, lancé en 2022, est considéré comme une version très stable et performante, et les utilisateurs sont plutôt satisfaits de son expérience globale. De plus, l'ajout de nouvelles fonctionnalités et les améliorations de l'expérience d'utilisation quotidienne dans iOS16 ont également été bien accueillies par de nombreux utilisateurs. Surtout en termes de durée de vie de la batterie mise à jour, de performances du signal et de contrôle du chauffage, les retours des utilisateurs ont été relativement positifs. Cependant, compte tenu de l'iPhone14
Guide de programmation PHP : méthodes pour implémenter la séquence de Fibonacci
Mar 20, 2024 pm 04:54 PM
Le langage de programmation PHP est un outil puissant pour le développement Web, capable de prendre en charge une variété de logiques et d'algorithmes de programmation différents. Parmi eux, l’implémentation de la séquence de Fibonacci est un problème de programmation courant et classique. Dans cet article, nous présenterons comment utiliser le langage de programmation PHP pour implémenter la séquence de Fibonacci et joindrons des exemples de code spécifiques. La suite de Fibonacci est une suite mathématique définie comme suit : le premier et le deuxième élément de la suite valent 1, et à partir du troisième élément, la valeur de chaque élément est égale à la somme des deux éléments précédents. Les premiers éléments de la séquence
Toujours nouveau ! Mises à niveau de la série Huawei Mate60 vers HarmonyOS 4.2 : amélioration du cloud AI, le dialecte Xiaoyi est si facile à utiliser
Jun 02, 2024 pm 02:58 PM
Le 11 avril, Huawei a officiellement annoncé pour la première fois le plan de mise à niveau de 100 machines HarmonyOS 4.2. Cette fois, plus de 180 appareils participeront à la mise à niveau, couvrant les téléphones mobiles, les tablettes, les montres, les écouteurs, les écrans intelligents et d'autres appareils. Au cours du mois dernier, avec la progression constante du plan de mise à niveau de 100 machines HarmonyOS4.2, de nombreux modèles populaires, notamment Huawei Pocket2, la série Huawei MateX5, la série nova12, la série Huawei Pura, etc., ont également commencé à être mis à niveau et à s'adapter, ce qui signifie qu'il y aura davantage d'utilisateurs de modèles Huawei pourront profiter de l'expérience commune et souvent nouvelle apportée par HarmonyOS. À en juger par les commentaires des utilisateurs, l'expérience des modèles de la série Huawei Mate60 s'est améliorée à tous égards après la mise à niveau d'HarmonyOS4.2. Surtout Huawei M
Comment implémenter la fonction de clonage WeChat sur les téléphones mobiles Huawei
Mar 24, 2024 pm 06:03 PM
Comment mettre en œuvre la fonction de clonage WeChat sur les téléphones mobiles Huawei Avec la popularité des logiciels sociaux et l'importance croissante accordée à la confidentialité et à la sécurité, la fonction de clonage WeChat est progressivement devenue le centre d'attention. La fonction de clonage WeChat peut aider les utilisateurs à se connecter simultanément à plusieurs comptes WeChat sur le même téléphone mobile, ce qui facilite la gestion et l'utilisation. Il n'est pas difficile de mettre en œuvre la fonction de clonage WeChat sur les téléphones mobiles Huawei. Il vous suffit de suivre les étapes suivantes. Étape 1 : Assurez-vous que la version du système de téléphonie mobile et la version de WeChat répondent aux exigences. Tout d'abord, assurez-vous que la version de votre système de téléphonie mobile Huawei a été mise à jour vers la dernière version, ainsi que l'application WeChat.
