\u5728redis\u6e90\u7801\u4ecemain\u5f00\u59cb7\u4e2d\u770b\u5b8c\u4e86\u4e00\u4e2a\u547d\u4ee4\u7684\u6267\u884c\u8fc7\u7a0b\uff0c\u672c\u7ae0\u6211\u4eec\u6765\u770bredis\u5c06\u547d\u4ee4\u6267\u884c\u7684\u7ed3\u679c\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef\u7684\u8fc7\u7a0b<\/p>\n\n\n\n
\n\/\/ \u4ecemain\u5f00\u59cb\u4e4b\u56de\u590d\u6d88\u606f\n\n\/*\n * \u628aredis\u5bf9\u8c61\u521b\u5efa\u56de\u590d\u7ed9\u5ba2\u6237\u7aef\n *\/\nvoid addReplyBulk(redisClient *c, robj *obj)\n{\n addReplyBulkLen(c, obj); \/\/ \u56de\u590d\u524d\u7f00\u65e2 \u56de\u590d\u957f\u5ea6\\r\\n\n addReply(c, obj); \/\/ \u56de\u590d\u7684\u5177\u4f53\u5185\u5bb9\n addReply(c, shared.crlf); \/\/ \u589e\u52a0\u5e38\u89c1\u56de\u590d\\r\\n\n}\n\n\/* \u521b\u5efa\u4e00\u4e2a\u56de\u590d\u524d\u7f00 *\/\nvoid addReplyBulkLen(redisClient *c, robj *obj)\n{\n size_t len;\n\n if (sdsEncodedObject(obj))\n {\n len = sdslen(obj->ptr);\n }\n else\n {\n long n = (long)obj->ptr;\n\n \/* \u56de\u590d\u7684\u957f\u5ea6 *\/\n len = 1;\n if (n<0)\n {\n len++;\n n = -n;\n }\n while ((n = n \/ 10) != 0)\n {\n len++;\n }\n }\n\n if (len'); \/\/ \u6784\u5efa\u5b57\u7b26\u4e32\n}\n\n\/\/ \u7ed9\u5ba2\u6237\u7aef\u53d1\u6d88\u606f\nvoid addReply(redisClient *c, robj *obj)\n{\n\n \/\/ \u7ed9\u80fd\u53d1\u9001\u6d88\u606f\u7684\u7f51\u7edc\u5ba2\u6237\u7aef\u589e\u52a0\u5199\u6d88\u606f\u7684\u5904\u7406\u5668\n if (prepareClientToWrite(c) != REDIS_OK)\n return;\n\n \/* \n * \u4e00\u4e9b\u4f18\u5316\u5224\u65ad\u7c7b\u578b\u770b\u8981\u4e0d\u8981\u62f7\u8d1d\u5565\u7684\n *\/\n if (sdsEncodedObject(obj))\n {\n \/\/ \u8bd5\u8bd5\u770b\u80fd\u4e0d\u80fd\u76f4\u63a5\u590d\u5236\u8fdbc->buf\u4e2d\n if (_addReplyToBuffer(c, obj->ptr, sdslen(obj->ptr)) != REDIS_OK)\n \/\/ \u4e0d\u80fd\u590d\u5236 c->buf \u4e2d,\u5c31\u52a0\u5230 c->reply \u94fe\u8868\u4e2d\n _addReplyObjectToList(c, obj);\n }\n else if (obj->encoding == REDIS_ENCODING_INT)\n {\n \/* \u4f18\u5316 \u8bd5\u8bd5\u770b\u80fd\u4e0d\u80fd\u957f\u6574\u6570\u4f18\u5316\u6210\u5b57\u7b26\u4e32*\/\n if (listLength(c->reply) == 0 && (sizeof(c->buf) - c->bufpos) >= 32)\n {\n char buf[32];\n int len;\n\n len = ll2string(buf, sizeof(buf), (long)obj->ptr);\n if (_addReplyToBuffer(c, buf, len) == REDIS_OK)\n return;\n }\n obj = getDecodedObject(obj);\n \/\/ \u666e\u901a\u7684\u53d1\u9001redis\u5bf9\u8c61\u7684\u65b9\u5f0f\n if (_addReplyToBuffer(c, obj->ptr, sdslen(obj->ptr)) != REDIS_OK)\n _addReplyObjectToList(c, obj);\n decrRefCount(obj);\n }\n else\n {\n redisPanic(\"Wrong obj->encoding in addReply()\");\n }\n}\n\n\/* \n\u521b\u5efa\u65b0\u7684\u4e8b\u4ef6\u5faa\u73af\u5199\u7684\u5904\u7406\u65b9\u6cd5\n *\/\nint prepareClientToWrite(redisClient *c)\n{\n\n \/\/ LUA \u811a\u672c\u73af\u5883\u6240\u4f7f\u7528\u7684\u4f2a\u5ba2\u6237\u7aef\u603b\u662f\u53ef\u5199\u7684\n if (c->flags & REDIS_LUA_CLIENT)\n return REDIS_OK;\n\n \/\/ \u5ba2\u6237\u7aef\u662f\u4e3b\u670d\u52a1\u5668\u5e76\u4e14\u4e0d\u63a5\u53d7\u67e5\u8be2\uff0c\n \/\/ \u90a3\u4e48\u5b83\u662f\u4e0d\u53ef\u5199\u7684\uff0c\u51fa\u9519\n if ((c->flags & REDIS_MASTER) &&\n !(c->flags & REDIS_MASTER_FORCE_REPLY))\n return REDIS_ERR;\n\n \/\/ \u65e0\u8fde\u63a5\u7684\u4f2a\u5ba2\u6237\u7aef\u603b\u662f\u4e0d\u53ef\u5199\u7684\n if (c->fd <= 0)\n return REDIS_ERR; \/* Fake client *\/\n\n \/\/ \u4e00\u822c\u60c5\u51b5\uff0c\u4e3a\u5ba2\u6237\u7aef\u5957\u63a5\u5b57\u5b89\u88c5\u5199\u5904\u7406\u5668\u5230\u4e8b\u4ef6\u5faa\u73af\n if (c->bufpos == 0 && listLength(c->reply) == 0 &&\n (c->replstate == REDIS_REPL_NONE ||\n c->replstate == REDIS_REPL_ONLINE) &&\n aeCreateFileEvent(server.el, c->fd, AE_WRITABLE,\n sendReplyToClient, c) == AE_ERR)\n return REDIS_ERR;\n\n return REDIS_OK;\n}\n\n\/*\n * \u4e8b\u4ef6\u89e6\u53d1 \u7ed9\u5957\u63a5\u5b57\u5199\u5185\u5bb9\u7684\u65b9\u6cd5\n *\/\nvoid sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask)\n{\n redisClient *c = privdata;\n int nwritten = 0, totwritten = 0, objlen;\n size_t objmem;\n robj *o;\n REDIS_NOTUSED(el);\n REDIS_NOTUSED(mask);\n\n \/\/ \u6709\u5185\u5bb9\u5c31\u53d1\n while (c->bufpos > 0 || listLength(c->reply))\n {\n\n if (c->bufpos > 0)\n {\n \/\/ \u5199\u5165\u5185\u5bb9\u5230\u5957\u63a5\u5b57\n nwritten = write(fd, c->buf + c->sentlen, c->bufpos - c->sentlen);\n if (nwritten <= 0)\n break;\n c->sentlen += nwritten;\n totwritten += nwritten;\n\n \/* \u53d1\u5149\u4e86\u5c31\u6e05\u7a7a*\/\n if (c->sentlen == c->bufpos)\n {\n c->bufpos = 0;\n c->sentlen = 0;\n }\n }\n else\n {\n\n \/\/ \u53d1\u9001\u94fe\u8868\u7684\u7b49\u5f85\u53d1\u9001\u5185\u5bb9\n o = listNodeValue(listFirst(c->reply));\n objlen = sdslen(o->ptr);\n objmem = getStringObjectSdsUsedMemory(o);\n\n \/\/ \u7565\u8fc7\u7a7a\u5bf9\u8c61\n if (objlen == 0)\n {\n listDelNode(c->reply, listFirst(c->reply));\n c->reply_bytes -= objmem;\n continue;\n }\n\n \/\/ \u5199\u5165\u5185\u5bb9\u5230\u5957\u63a5\u5b57\n nwritten = write(fd, ((char *)o->ptr) + c->sentlen, objlen - c->sentlen);\n if (nwritten <= 0)\n break;\n c->sentlen += nwritten;\n totwritten += nwritten;\n\n \/\/ \u5220\u9664\u5199\u5b8c\u7684\u8282\u70b9\n if (c->sentlen == objlen)\n {\n listDelNode(c->reply, listFirst(c->reply));\n c->sentlen = 0;\n c->reply_bytes -= objmem;\n }\n }\n \/* \n \/\/ \u8fbe\u5230\u4e00\u5b9a\u5199\u5165\u957f\u5ea6\u5c31\u4e2d\u65ad,\u7b49\u5f85\u4e0b\u6b21\u5728\u5199\n *\/\n if (totwritten > REDIS_MAX_WRITE_PER_EVENT &&\n (server.maxmemory == 0 ||\n zmalloc_used_memory() < server.maxmemory))\n break;\n }\n\n \/\/ \u5199\u5165\u51fa\u9519\u68c0\u67e5\n if (nwritten == -1)\n {\n if (errno == EAGAIN)\n {\n nwritten = 0;\n }\n else\n {\n redisLog(REDIS_VERBOSE,\n \"Error writing to client: %s\", strerror(errno));\n freeClient(c);\n return;\n }\n }\n\n if (totwritten > 0)\n {\n \/* \u68c0\u67e5\u53d1\u9001\u8d85\u65f6\u7684\u4e1c\u897f *\/\n if (!(c->flags & REDIS_MASTER))\n c->lastinteraction = server.unixtime;\n }\n if (c->bufpos == 0 && listLength(c->reply) == 0)\n {\n c->sentlen = 0;\n\n \/\/ \u5220\u9664 \u5199\u4e8b\u4ef6\n aeDeleteFileEvent(server.el, c->fd, AE_WRITABLE);\n\n \/\/ \u5224\u65ad\u8981\u4e0d\u8981\u5173\u95ed\u5ba2\u6237\u7aef\n if (c->flags & REDIS_CLOSE_AFTER_REPLY)\n freeClient(c);\n }\n}\n<\/code><\/pre>\n\n\n\n\u57fa\u4e8e\u7248\u672c3.0.0\u7248\u672c,<\/a>\u70b9\u51fb\u4e0b\u8f7dhttps:\/\/download.redis.io\/releases\/redis-3.0.0.tar.gz<\/p>\n\n\n\n\u672c\u6587\u5730\u5740<\/a>\uff0chttps:\/\/www.ccagml.com\/?p=395<\/p>\n","protected":false},"excerpt":{"rendered":"\u5728redis\u6e90\u7801\u4ecemain\u5f00\u59cb7\u4e2d\u770b\u5b8c\u4e86\u4e00\u4e2a\u547d\u4ee4\u7684\u6267\u884c\u8fc7\u7a0b\uff0c\u672c\u7ae0\u6211\u4eec\u6765\u770bredis\u5c06\u547d\u4ee4\u6267\u884c\u7684\u7ed3\u679c\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aefContinue reading redis\u6e90\u7801\u4ecemain\u5f00\u59cb8<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":[],"categories":[31,22],"tags":[],"_links":{"self":[{"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/posts\/395"}],"collection":[{"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=395"}],"version-history":[{"count":2,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/posts\/395\/revisions"}],"predecessor-version":[{"id":397,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=\/wp\/v2\/posts\/395\/revisions\/397"}],"wp:attachment":[{"href":"https:\/\/www.ccagml.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=395"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=395"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.ccagml.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=395"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}