swoole_redis->__call
ħ����������������ӳ��ΪRedisָ�������ΪRedisָ��IJ�����
����ԭ��
function swoole_redis->__call(string $command, array $params);
- $command������Ϊ�Ϸ���Redisָ���ϸ�μ�Redisָ���б�
- $params�����һ����������Ϊ��ִ�еĺ�����������������Ϊ�ַ���
����/������Ϣ
Redis������������Ϊ�ڴ�洢֮�⣬��������Ϊһ����Ϣͨ����������SwooleRedis�ͻ���Ҳ֧����Redis�Ķ���/������Ϣָ�
����ͨ�Ĵ洢ָ�ͬ����Ϣ����/����ָ���������Ӧʽ�ġ�
- ����/����ָ��û�лص�����������Ҫ�����һ����������callback
- ʹ�ö���/������Ϣ��������������
onMessage�¼��ص����� - �ͻ��˷�����
subscribe�����ֻ��ִ��subscribe��subscribe��unsubscribe��punsubscribe��4������
$client = new swoole_redis;
$client->on('message', function (swoole_redis $client, $result) {
var_dump($result);
static $more = false;
if (!$more and $result[0] == 'message')
{
echo "subscribe new channel\n";
$client->subscribe('msg_1', 'msg_2');
$client->unsubscribe('msg_0');
$more = true;
}
});
$client->connect('127.0.0.1', 6379, function (swoole_redis $client, $result) {
echo "connect\n";
$client->subscribe('msg_0');
});
�ص�����
function onReceive(swoole_redis $redis, bool $result);
- $redis: redis���Ӷ���
- ִ��ʧ�ܣ�$resultΪfalse, ���Զ�ȡ
$redis->errCode��ô����룬��ȡ$redis->errMsg��ô�����Ϣ - ִ�гɹ����������ݽ�����������ַ����������true
ʹ��ʾ��
$client->get('key', function (swoole_redis $client, $result) {
var_dump($result);
});