{"id":48092,"date":"2023-09-22T02:20:35","date_gmt":"2023-12-08T11:47:52","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/"},"modified":"2024-05-04T00:57:54","modified_gmt":"2024-05-03T16:57:54","slug":"%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/","title":{"rendered":"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd"},"content":{"rendered":"

\u9996\u5148<\/h1>\n

\u8fd9\u7bc7\u6587\u7ae0\u662f\u4e0a\u4e00\u7bc7\u5173\u4e8e\u4ecb\u7ecdGraphQL\u6982\u8ff0\uff0c\u5e76\u786e\u8ba4Query\u548cMutation\u7684\u64cd\u4f5c\u7684\u7eed\u7bc7\u3002\u672c\u6587\u5c06\u8ba8\u8bbaGraphQL\u7684\u8ba2\u9605\u529f\u80fd\u3002<\/p>\n

“Subscription(\u8ba2\u9605)\u662f\u4e00\u4e2a\u719f\u6089\u7684\u8bcd\u6c47\uff0c\u76f4\u8bd1\u4e3a\u201c\u8d2d\u4e70\u201d\uff0c\u5728GraphQL\u4e2d\u6307\u7684\u662f\u5728Mutation\u64cd\u4f5c\u6570\u636e\u65f6\uff0c\u5ba2\u6237\u7aef\u6536\u5230\u6765\u81ea\u670d\u52a1\u5668\u53d1\u51fa\u7684\u53d8\u66f4\u4fe1\u606f\uff0c\u53ef\u7528\u4e8e\u804a\u5929\u5e94\u7528\u7a0b\u5e8f\u3001\u901a\u77e5\u529f\u80fd\u3001\u767b\u5f55\u8ba4\u8bc1\u7b49\u3002\u63a8\u8350\u8fd9\u91cc\u7684\u89e3\u91ca\uff0c\u975e\u5e38\u6613\u61c2\u3002”<\/p>\n

\u8fd9\u4e00\u6b21\uff0c\u6211\u4eec\u5c06\u4f7f\u7528Apollo\u6765\u66ff\u4ee3\u4e4b\u524d\u5efa\u7acb\u7684Express-GraphQL\u670d\u52a1\u5668\uff0c\u642d\u5efaGraphQL\u670d\u52a1\u5668\uff0c\u5e76\u68c0\u67e5Subscription\u7684\u8fd0\u4f5c\u60c5\u51b5\u3002<\/p>\n

“Apollo\u662f\u4ec0\u4e48\u610f\u601d\uff1f”<\/h2>\n

Apollo\u662f\u4e00\u4e2a\u7528\u4e8e\u6784\u5efa\u6570\u636e\u56fe\u7684\u5e73\u53f0\uff0c\u5b83\u662f\u4e00\u4e2a\u8fde\u63a5\u524d\u7aef\u5e94\u7528\u7a0b\u5e8f\u5ba2\u6237\u7aef\uff08\u5982React\u6216iOS\u5e94\u7528\u7a0b\u5e8f\uff09\u4e0e\u540e\u7aef\u670d\u52a1\u65e0\u7f1d\u901a\u4fe1\u7684\u901a\u4fe1\u5c42\u3002<\/p><\/blockquote>\n

\u901a\u8fc7\u4f4d\u4e8e\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u4e4b\u95f4\u7684Apollo\u670d\u52a1\u5668\uff0cGraphQL\u6570\u636e\u4ea4\u4e92\u53d8\u5f97\u66f4\u52a0\u6d41\u7545\u3002<\/p>\n

\"download.png\"<\/div>\n

\u516c\u5f0f\u6587\u4ef6<\/p>\n

\u51c6\u5907\u597d<\/h2>\n

\u521b\u5efa\u9879\u76ee\u540e\uff0c\u901a\u8fc7npm\u5b89\u88c5apollo-server\u3002<\/p>\n

mkdir graphql-server\r\ncd graphql-server\r\nmkdir resolver\r\ntouch index.js db.js resolver\/{Query.js,Mutation.js,Subscription.js}\r\nnpm init\r\nnpm install apollo-server apollo-server-express --save\r\n<\/code><\/pre>\n
\u4e3a\u4e86\u4f7f\u793a\u4f8b\u4ee3\u7801\u66f4\u6613\u8bfb<\/h2>\n
\u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f<\/h3>\n
PubSub\u5c31\u50cf\u4e00\u4e2a\u5de5\u5382\uff0c\u901a\u8fc7Subscription\u521b\u5efa\u901a\u77e5\u4e8b\u4ef6\u3002<\/p>\n
const<\/span> {<\/span> PubSub<\/span> }<\/span> =<\/span> require<\/span>(<\/span>'<\/span>apollo-server<\/span>'<\/span>);<\/span>\r\n\r\nconst<\/span> pubsub<\/span> =<\/span> new<\/span> PubSub<\/span>();<\/span>\r\n<\/code><\/pre>\n
\u9ad8\u7fd8\u4e86\u3002<\/h3>\n
\u4f7f\u7528\u79f0\u4e3agql\u7684\u6807\u8bb0\u6a21\u677f\u6587\u5b57\u9762\u91cf\u51fd\u6570\uff0c\u53ef\u4ee5\u5c06\u4e0eGraphQL\u76f8\u5173\u7684\u5b9a\u4e49\u8868\u793a\u4e3aJavaScript\u5b57\u7b26\u4e32\u3002<\/p>\n
const<\/span> typeDefs<\/span> =<\/span> gql<\/span>`\r\n  type Subscription {\r\n    postAdded: Post\r\n  }\r\n\r\n  type Query {\r\n    posts: [Post]\r\n  }\r\n\r\n  type Mutation {\r\n    addPost(author: String, comment: String): Post\r\n  }\r\n\r\n  type Post {\r\n    author: String\r\n    comment: String\r\n  }\r\n`<\/span>\r\n<\/code><\/pre>\n
Resolver\u53c2\u6570<\/h3>\n
\u5728\u89e3\u6790\u51fd\u6570\u4e2d\uff0c\u6709\u56db\u4e2a\u56fa\u5b9a\u53c2\u6570\u626e\u6f14\u7740\u7279\u5b9a\u7684\u89d2\u8272\u3002<\/p>\n
\n
\u5f15\u6570\uff08\u6607\u9806\uff09\u8aac\u660eparent\u89aa\u30ea\u30be\u30eb\u30d0\u304b\u3089\u306e\u623b\u308a\u5024\u3002args\u30d5\u30a3\u30fc\u30eb\u30c9\u306b\u63d0\u4f9b\u3055\u308c\u305f\u3059\u3079\u3066\u306eGraphQL\u5f15\u6570\u3092\u542b\u3080\u30aa\u30d6\u30b8\u30a7\u30af\u30c8context\u7279\u5b9a\u306e\u64cd\u4f5c\u306b\u5bfe\u3057\u3066\u5b9f\u884c\u3055\u308c\u308b\u3059\u3079\u3066\u306e\u30ea\u30be\u30eb\u30d0\u9593\u3067\u5171\u6709\u3055\u308c\u307e\u3059\u3002\u3053\u308c\u3092\u4f7f\u7528\u3057\u3066\u3001\u8a8d\u8a3c\u60c5\u5831\u3084\u30c7\u30fc\u30bf\u30bd\u30fc\u30b9\u3078\u306e\u30a2\u30af\u30bb\u30b9\u306a\u3069\u306e\u64cd\u4f5c\u3054\u3068\u306e\u72b6\u614b\u3092\u5171\u6709\u3057\u307e\u3059\u3002info\u30d5\u30a3\u30fc\u30eb\u30c9\u540d\u3001\u30eb\u30fc\u30c8\u304b\u3089\u30d5\u30a3\u30fc\u30eb\u30c9\u3078\u306e\u30d1\u30b9\u306a\u3069\u3001\u64cd\u4f5c\u306e\u5b9f\u884c\u72b6\u614b\u306b\u95a2\u3059\u308b\u60c5\u5831<\/div>\n<\/div>\n
\u4ee3\u7801\u4ecb\u7ecd\u548c\u89e3\u91ca<\/h2>\n
\u8bf7\u5199\u4e0b\u4ee3\u7801\u5230\u5df2\u521b\u5efa\u7684\u6587\u4ef6\u4e2d\u3002
\n\u7531\u4e8e\u7bc7\u5e45\u539f\u56e0\uff0c\u6211\u4eec\u4f1a\u7701\u7565\u5bf9\u4e8eQuery\u548cMutation\u7684\u6982\u8ff0\uff0c\u521d\u6b21\u63a5\u89e6GraphQL\u7684\u670b\u53cb\u4eec\u53ef\u4ee5\u4ece\u8fd9\u7bc7\u6587\u7ae0\u5f00\u59cb\u9605\u8bfb\uff01?<\/p>\n
\u9996\u5148\uff0c\u51c6\u5907\u4e00\u4e2a\u7528\u4f5c\u6570\u636e\u5e93\u66ff\u4ee3\u7684JavaScript\u6587\u4ef6\u3002<\/p>\n
const<\/span> posts<\/span> =<\/span> [{<\/span>\r\n    id<\/span>:<\/span> '<\/span>1<\/span>'<\/span>,<\/span>\r\n    title<\/span>:<\/span> '<\/span>\u3053\u3053\u308d<\/span>'<\/span>,<\/span>\r\n    author<\/span>:<\/span> '<\/span>\u590f\u76ee\u6f31\u77f3<\/span>'<\/span>\r\n},<\/span> {<\/span>\r\n    id<\/span>:<\/span> '<\/span>2<\/span>'<\/span>,<\/span>\r\n    title<\/span>:<\/span> '<\/span>\u821e\u59eb<\/span>'<\/span>,<\/span>\r\n    author<\/span>:<\/span> '<\/span>\u68ee\u9d0e\u5916<\/span>'<\/span>\r\n},<\/span> {<\/span>\r\n    id<\/span>:<\/span> '<\/span>3<\/span>'<\/span>,<\/span>\r\n    title<\/span>:<\/span> '<\/span>\u7f85\u751f\u9580<\/span>'<\/span>,<\/span>\r\n    author<\/span>:<\/span> '<\/span>\u82a5\u5ddd\u9f8d\u4e4b\u4ecb<\/span>'<\/span>\r\n}]<\/span>\r\n\r\nconst<\/span> db<\/span> =<\/span> {<\/span>\r\n    posts<\/span>,<\/span>\r\n}<\/span>\r\n\r\nmodule<\/span>.<\/span>exports<\/span>  =<\/span> db<\/span>;<\/span>\r\n<\/code><\/pre>\n
\u63a5\u4e0b\u6765\uff0c\u6211\u4eec\u5c06\u4f9d\u6b21\u51c6\u5907\u5305\u542bQuery\u3001Mutation\u548c\u672c\u6b21\u4e3b\u9898\u7684Subscription\u7684\u89e3\u6790\u5668\u51fd\u6570\u6240\u5728\u7684\u6587\u4ef6\u3002<\/p>\n
const<\/span> Query<\/span> =<\/span> {<\/span>\r\n    posts<\/span>(<\/span>parent<\/span>,<\/span> args<\/span>,<\/span> {<\/span> db<\/span> },<\/span> info<\/span>)<\/span> {<\/span>\r\n       \/\/\u30af\u30a8\u30ea\u3092\u66f8\u3044\u305f\u6642\u306b\u5f15\u6570\u304c\u300c\u306a\u3044\u300d\u6642<\/span>\r\n       \/\/\u6a21\u64ec\u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u306e\u5185\u5bb9\u3092\u5168\u3066\u8868\u793a<\/span>\r\n        if<\/span> (<\/span>!<\/span>args<\/span>.<\/span>query<\/span>)<\/span> {<\/span>\r\n            return<\/span> db<\/span>.<\/span>posts<\/span>\r\n       \/\/\u30af\u30a8\u30ea\u3092\u66f8\u3044\u305f\u6642\u306b\u5f15\u6570\u304c\u300c\u3042\u308b\u300d\u6642<\/span>\r\n       \/\/\u5f15\u6570\u3068title or author\u304c\u4e00\u81f4\u3057\u305f\u3082\u306e\u3060\u3051\u3092\u8868\u793a<\/span>\r\n        }<\/span>else<\/span>{<\/span>\r\n            return<\/span> db<\/span>.<\/span>posts<\/span>.<\/span>filter<\/span>((<\/span>post<\/span>)<\/span> =><\/span> {<\/span>\r\n            const<\/span> isTitleMatch<\/span> =<\/span> post<\/span>.<\/span>title<\/span>.<\/span>toLowerCase<\/span>().<\/span>includes<\/span>(<\/span>args<\/span>.<\/span>query<\/span>.<\/span>toLowerCase<\/span>())<\/span>\r\n            const<\/span> isAuthorMatch<\/span> =<\/span> post<\/span>.<\/span>author<\/span>.<\/span>toLowerCase<\/span>().<\/span>includes<\/span>(<\/span>args<\/span>.<\/span>query<\/span>.<\/span>toLowerCase<\/span>())<\/span>\r\n            return<\/span> isTitleMatch<\/span> ||<\/span> isAuthorMatch<\/span>\r\n        })<\/span>\r\n    }<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\nmodule<\/span>.<\/span>exports<\/span>  =<\/span> Query<\/span>\r\n<\/code><\/pre>\n
\u8fd9\u662f\u4e00\u4e2a\u67e5\u8be2\u89e3\u6790\u51fd\u6570\u3002\u6839\u636e\u53c2\u6570\u7684\u6709\u65e0\u8fdb\u884c\u6761\u4ef6\u5206\u652f\u3002\u901a\u8fc7JavaScript\u7684\u8be6\u7ec6\u6761\u4ef6\u7f16\u5199\uff0cGraphQL\u7684\u4f18\u52bf\u4e4b\u4e00\u662f\u80fd\u591f\u53ea\u83b7\u53d6\u6240\u9700\u7684\u5fc5\u8981\u4fe1\u606f\u3002<\/p>\n
const<\/span> Mutation<\/span> =<\/span> {<\/span>\r\n    createPost<\/span>(<\/span>parent<\/span>,<\/span> args<\/span>,<\/span> {<\/span> db<\/span>,<\/span> pubsub<\/span> },<\/span> info<\/span>)<\/span> {<\/span>\r\n        const<\/span> postNumTotal<\/span> =<\/span> String<\/span>(<\/span>db<\/span>.<\/span>posts<\/span>.<\/span>length<\/span> +<\/span> 1<\/span>)<\/span>\r\n        const<\/span> post<\/span> =<\/span> {<\/span>\r\n            id<\/span>:<\/span> postNumTotal<\/span>,<\/span>\r\n            ...<\/span>args<\/span>.<\/span>data<\/span>\r\n        }<\/span>\r\n\r\n        \/\/\u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u66f4\u65b0<\/span>\r\n        db<\/span>.<\/span>posts<\/span>.<\/span>push<\/span>(<\/span>post<\/span>)<\/span>\r\n        \/\/Subscription\u7740\u706b<\/span>\r\n        pubsub<\/span>.<\/span>publish<\/span>(<\/span>'<\/span>post<\/span>'<\/span>,<\/span> {<\/span> \r\n                post<\/span>:<\/span> {<\/span>\r\n                    mutation<\/span>:<\/span> '<\/span>CREATED<\/span>'<\/span>,<\/span>\r\n                    data<\/span>:<\/span> post<\/span>\r\n                }<\/span>\r\n             })<\/span>\r\n        return<\/span> post<\/span>\r\n    },<\/span>\r\n    updatePost<\/span>(<\/span>parent<\/span>,<\/span> args<\/span>,<\/span> {<\/span> db<\/span>,<\/span> pubsub<\/span> },<\/span> info<\/span>)<\/span> {<\/span>\r\n        const<\/span> {<\/span> id<\/span>,<\/span> data<\/span> }<\/span> =<\/span> args<\/span>\r\n        const<\/span> post<\/span> =<\/span> db<\/span>.<\/span>posts<\/span>.<\/span>find<\/span>((<\/span>post<\/span>)<\/span> =><\/span> post<\/span>.<\/span>id<\/span> ===<\/span> id<\/span>)<\/span>\r\n        if<\/span> (<\/span>!<\/span>post<\/span>)<\/span> {<\/span>\r\n            throw<\/span> new<\/span> Error<\/span>(<\/span>'<\/span>Post not found<\/span>'<\/span>)<\/span>\r\n        }<\/span>\r\n\r\n        if<\/span> (<\/span>typeof<\/span> data<\/span>.<\/span>title<\/span> ===<\/span> '<\/span>string<\/span>'<\/span> &&<\/span> typeof<\/span> data<\/span>.<\/span>author<\/span> ===<\/span> '<\/span>string<\/span>'<\/span>)<\/span> {<\/span>\r\n            \/\/\u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u66f4\u65b0<\/span>\r\n            post<\/span>.<\/span>title<\/span> =<\/span> data<\/span>.<\/span>title<\/span>\r\n            post<\/span>.<\/span>author<\/span> =<\/span> data<\/span>.<\/span>author<\/span>\r\n            console<\/span>.<\/span>log<\/span>(<\/span>post<\/span>)<\/span>\r\n            \/\/Subscription\u7740\u706b<\/span>\r\n            pubsub<\/span>.<\/span>publish<\/span>(<\/span>'<\/span>post<\/span>'<\/span>,<\/span> {<\/span>\r\n            post<\/span>:<\/span> {<\/span>\r\n                mutation<\/span>:<\/span> '<\/span>UPDATED<\/span>'<\/span>,<\/span>\r\n                data<\/span>:<\/span> post<\/span>\r\n            }<\/span>\r\n        })<\/span>\r\n        }<\/span>\r\n\r\n        return<\/span> post<\/span>\r\n    },<\/span>\r\n    deletePost<\/span>(<\/span>parent<\/span>,<\/span> args<\/span>,<\/span> {<\/span> db<\/span>,<\/span> pubsub<\/span> },<\/span> info<\/span>)<\/span> {<\/span>\r\n        const<\/span> post<\/span> =<\/span> db<\/span>.<\/span>posts<\/span>.<\/span>find<\/span>((<\/span>post<\/span>)<\/span> =><\/span> post<\/span>.<\/span>id<\/span> ===<\/span> args<\/span>.<\/span>id<\/span>)<\/span>\r\n        const<\/span> postIndex<\/span> =<\/span> db<\/span>.<\/span>posts<\/span>.<\/span>findIndex<\/span>((<\/span>post<\/span>)<\/span> =><\/span> post<\/span>.<\/span>id<\/span> ===<\/span> args<\/span>.<\/span>id<\/span>)<\/span>\r\n\r\n        if<\/span> (<\/span>postIndex<\/span> ===<\/span> -<\/span>1<\/span>)<\/span> {<\/span>\r\n            throw<\/span> new<\/span> Error<\/span>(<\/span>'<\/span>Post not found<\/span>'<\/span>)<\/span>\r\n        }<\/span>\r\n        \/\/\u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u66f4\u65b0<\/span>\r\n        db<\/span>.<\/span>posts<\/span>.<\/span>splice<\/span>(<\/span>postIndex<\/span>,<\/span> 1<\/span>)<\/span>\r\n        \/\/Subscription\u7740\u706b<\/span>\r\n        pubsub<\/span>.<\/span>publish<\/span>(<\/span>'<\/span>post<\/span>'<\/span>,<\/span> {<\/span>\r\n                post<\/span>:<\/span> {<\/span>\r\n                    mutation<\/span>:<\/span> '<\/span>DELETED<\/span>'<\/span>,<\/span>\r\n                    data<\/span>:<\/span> post<\/span>\r\n                }<\/span>\r\n            })<\/span>\r\n        return<\/span> post<\/span>\r\n    },<\/span>\r\n}<\/span>\r\n\r\nmodule<\/span>.<\/span>exports<\/span>  =<\/span> Mutation<\/span>\r\n<\/code><\/pre>\n
\u5728Mutation\u7684\u89e3\u6790\u5668\u51fd\u6570\u4e2d\uff0c\u540c\u65f6\u8fdb\u884c\u4e86\u6570\u636e\u5e93\u7684\u66f4\u65b0\u548c\u542f\u52a8Subscription\u3002<\/p>\n
const<\/span> Subscription<\/span> =<\/span> {<\/span>\r\n    post<\/span>:<\/span> {<\/span>\r\n        subscribe<\/span>(<\/span>parent<\/span>,<\/span> args<\/span>,<\/span> {<\/span> pubsub<\/span> },<\/span> info<\/span>)<\/span> {<\/span>\r\n            return<\/span> pubsub<\/span>.<\/span>asyncIterator<\/span>(<\/span>'<\/span>post<\/span>'<\/span>)<\/span>\r\n        }<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\nmodule<\/span>.<\/span>exports<\/span> =<\/span> Subscription<\/span>\r\n<\/code><\/pre>\n
\u8fd9\u662f\u4e00\u4e2a\u8ba2\u9605\u7684\u89e3\u6790\u5668\u51fd\u6570\u3002
\n\u5b83\u4f7f\u7528pubsub.asyncIterator\u6765\u5f02\u6b65\u76d1\u542c\u8ba2\u9605\u7684\u4e8b\u4ef6\u3002<\/p>\n
\u56e0\u4e3a\u8bf4\u660e\u7684\u5173\u7cfb\uff0c\u8fd9\u662f\u6700\u540e\u7684\u90e8\u5206\uff0c\u5305\u62ec\u4e86\u6a21\u5f0f\u5b9a\u4e49\u548c\u670d\u52a1\u5668\u542f\u52a8\u6587\u4ef6\u3002<\/p>\n
const<\/span>  {<\/span>ApolloServer<\/span>,<\/span>PubSub<\/span>,<\/span>gql<\/span>}<\/span> =<\/span> require<\/span>(<\/span>'<\/span>apollo-server<\/span>'<\/span>);<\/span>\r\nconst<\/span> db<\/span> =<\/span> require<\/span>(<\/span>'<\/span>.\/db<\/span>'<\/span>)<\/span>\r\nconst<\/span> Query<\/span> =<\/span> require<\/span>(<\/span>'<\/span>.\/resolver\/Query<\/span>'<\/span>)<\/span>\r\nconst<\/span> Mutation<\/span> =<\/span> require<\/span>(<\/span>'<\/span>.\/resolver\/Mutation<\/span>'<\/span>)<\/span>\r\nconst<\/span> Subscription<\/span> =<\/span> require<\/span>(<\/span>'<\/span>.\/resolver\/Subscription<\/span>'<\/span>)<\/span>\r\n\r\n\/\/\u30b9\u30ad\u30fc\u30de\u5b9a\u7fa9<\/span>\r\nconst<\/span> typeDefs<\/span> =<\/span> gql<\/span>`\r\ntype Query {\r\n  posts(query: String): [Post!]!\r\n}\r\n\r\ntype Mutation {\r\n  createPost(data: CreatePostInput!): Post!\r\n  deletePost(id: ID!): Post!\r\n  updatePost(id: ID!, data: UpdatePostInput!): Post!\r\n}\r\n\r\n# Subscription\r\ntype Subscription {\r\n  post: PostSubscriptionPayload!\r\n}\r\n\r\ninput CreatePostInput {\r\n  title: String!\r\n  author: String!\r\n}\r\n\r\ninput UpdatePostInput {\r\n  title: String\r\n  author: String!\r\n}\r\n\r\ntype Post {\r\n  id: ID!\r\n  title: String!\r\n  author: String!\r\n}\r\n\r\n######################\r\n# Subscription\u3067\u5229\u7528\r\n######################\r\n\r\nenum MutationType {\r\n  CREATED\r\n  UPDATED\r\n  DELETED\r\n}\r\n\r\n# Subscription\u306e\u30d5\u30a3\u30fc\u30eb\u30c9\r\ntype PostSubscriptionPayload {\r\n  mutation: MutationType!\r\n  data: Post!\r\n}\r\n\r\n`<\/span>\r\n\/\/PubSub\u306e\u30a4\u30f3\u30b9\u30bf\u30f3\u30b9\u3092\u4f5c\u6210,Subscription\u304c\u5229\u7528\u53ef\u80fd\u306b\uff01<\/span>\r\nconst<\/span> pubsub<\/span> =<\/span> new<\/span> PubSub<\/span>()<\/span>\r\n\r\nconst<\/span> server<\/span> =<\/span> new<\/span> ApolloServer<\/span>({<\/span>\r\n    typeDefs<\/span>:<\/span> typeDefs<\/span>,<\/span>\r\n    resolvers<\/span>:<\/span> {<\/span>\r\n        Query<\/span>,<\/span>\r\n        Mutation<\/span>,<\/span>\r\n        Subscription<\/span>,<\/span>\r\n    },<\/span>\r\n    context<\/span>:<\/span> {<\/span>\r\n        db<\/span>,<\/span>\r\n        pubsub<\/span>\r\n    }<\/span>\r\n})<\/span>\r\n\r\nserver<\/span>.<\/span>listen<\/span>().<\/span>then<\/span>(({<\/span> url<\/span>,<\/span> subscriptionsUrl<\/span> })<\/span> =><\/span> {<\/span>\r\n    console<\/span>.<\/span>log<\/span>(<\/span>`? Server ready at <\/span>${<\/span>url<\/span>}<\/span>`<\/span>);<\/span>\r\n    console<\/span>.<\/span>log<\/span>(<\/span>`? Subscriptions ready at <\/span>${<\/span>subscriptionsUrl<\/span>}<\/span>`<\/span>);<\/span>\r\n  });<\/span>\r\n<\/code><\/pre>\n
\u5728\u642d\u5efa\u670d\u52a1\u5668\u65f6\uff0c\u6307\u5b9a\u4e86\u6a21\u5f0f\uff08schema\uff09\uff0c\u89e3\u6790\u5668\uff08resolver\uff09\uff0c\u6d88\u606f\u53d1\u5e03\u4e0e\u8ba2\u9605\uff08PubSub\uff09\u7b49\u4f5c\u4e3a\u53c2\u6570\u3002
\n\u6307\u5b9a\u7684\u53c2\u6570\u5728\u67e5\u8be2\uff08Query\uff09\uff0c\u53d8\u66f4\uff08Mutation\uff09\u548c\u8ba2\u9605\uff08Subscription\uff09\u7684\u5404\u4e2a\u5904\u7406\u4e2d\u88ab\u4f7f\u7528\u3002<\/p>\n
\u5f53\u51c6\u5907\u597d\u4e4b\u540e\uff0c\u901a\u8fc7\u7ec8\u7aef\u542f\u52a8\u3002<\/p>\n
node index.js\r\n? Server ready at http:\/\/localhost:4000\/\r\n? Subscriptions ready at ws:\/\/localhost:4000\/graphql\r\n<\/code><\/pre>\n
\u6211\u4f1a\u50cf\u4e0a\u6b21\u4e00\u6837\u5728GraphQL IDE\u4e2d\u8fdb\u884c\u6d4b\u8bd5\u3002<\/p>\n
\u8981\u4f7f\u7528Subscription\uff0c\u60a8\u9700\u8981\u5728\u7f16\u5199\u67e5\u8be2\u4e4b\u540e\uff0c\u70b9\u51fb\u4e00\u4e2a\u7c7b\u4f3cYouTube\u64ad\u653e\u6309\u94ae\u7684\u7bad\u5934\u3002
\n\u5f53\u5b83\u53d8\u6210\u50cf\u7167\u7247\u4e2d\u7684\u7ea2\u8272\u6682\u505c\u6309\u94ae\u4e00\u6837\u7684\u65f6\u5019\uff0c\u8868\u793aSubscription\u6210\u529f\u542f\u52a8\u3002<\/p>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\u6211\u4f1a\u786e\u8ba4\u6570\u636e\u7684\u66f4\u65b0\u548c\u5220\u9664\u3002<\/p>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\u6b63\u5728\u8fdb\u884c\u8ba2\u9605\uff0c\u786e\u8ba4\u6570\u636e\u5220\u9664\u7684\u64cd\u4f5c\uff08\u6b63\u5728\u8fde\u7eed\u8fdb\u884c\u66f4\u65b0\u548c\u5220\u9664\uff09\u3002<\/p>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\u6211\u4eec\u901a\u8fc7\u8ba2\u9605\u6210\u529f\u786e\u8ba4\u4e86\u901a\u8fc7\u7a81\u53d8\u8fdb\u884c\u6570\u636e\u66f4\u65b0\uff01\uff01??<\/p>\n
\u7528\u4e2d\u6587\u8fdb\u884c\u81ea\u7136\u6539\u5199:
\n\u6700\u540e<\/h3>\n
\u5c3d\u7ba1\u76f8\u5bf9\u4e8eQuery\u548cMutation\u6765\u8bf4\uff0cSubscription\u7406\u89e3\u8d77\u6765\u9700\u8981\u82b1\u8d39\u66f4\u591a\u7684\u65f6\u95f4\uff0c\u4f46\u901a\u8fc7\u7f16\u5199\u5b9e\u9645\u7684\u4ee3\u7801\u5e76\u5728GraphQL IDE\u4e2d\u8fdb\u884c\u6d4b\u8bd5\uff0c\u6211\u6210\u529f\u5730\u5c06\u5176\u878d\u5165\u81ea\u5df1\u7684\u7406\u89e3\u4e2d\u3002
\n\u5728\u4e0b\u4e00\u7bc7\u6587\u7ae0\u4e2d\uff0c\u6211\u5c06\u4f7f\u7528Vue\u4f5c\u4e3a\u524d\u7aef\uff0c\u5e76\u5728\u5b9e\u9645\u5e94\u7528\u7a0b\u5e8f\u4e2d\u4f7f\u7528GraphQL\uff01<\/p>\n
\u597d\u7684\uff0c\u518d\u89c1\uff01?<\/p>\n","protected":false},"excerpt":{"rendered":"
\u9996\u5148 \u8fd9\u7bc7\u6587\u7ae0\u662f\u4e0a\u4e00\u7bc7\u5173\u4e8e\u4ecb\u7ecdGraphQL\u6982\u8ff0\uff0c\u5e76\u786e\u8ba4Query\u548cMutation\u7684\u64cd\u4f5c\u7684\u7eed\u7bc7\u3002\u672c\u6587\u5c06\u8ba8\u8bbaG […]<\/p>\n","protected":false},"author":6,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-48092","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apolloserver\u63a2\u7d22graphql\u7684subscription\u529f\u80fd\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd\" \/>\n<meta property=\"og:description\" content=\"\u9996\u5148 \u8fd9\u7bc7\u6587\u7ae0\u662f\u4e0a\u4e00\u7bc7\u5173\u4e8e\u4ecb\u7ecdGraphQL\u6982\u8ff0\uff0c\u5e76\u786e\u8ba4Query\u548cMutation\u7684\u64cd\u4f5c\u7684\u7eed\u7bc7\u3002\u672c\u6587\u5c06\u8ba8\u8bbaG […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apolloserver\u63a2\u7d22graphql\u7684subscription\u529f\u80fd\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-12-08T11:47:52+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-05-03T16:57:54+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d830c913a08637a6b27fa\/7-0.png\" \/>\n<meta name=\"author\" content=\"\u6587, \u7fd4\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6587, \u7fd4\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"3 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/\",\"name\":\"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-12-08T11:47:52+00:00\",\"dateModified\":\"2024-05-03T16:57:54+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c\",\"name\":\"\u6587, \u7fd4\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g\",\"caption\":\"\u6587, \u7fd4\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/wenxiang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apolloserver\u63a2\u7d22graphql\u7684subscription\u529f\u80fd\/","og_locale":"zh_CN","og_type":"article","og_title":"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd","og_description":"\u9996\u5148 \u8fd9\u7bc7\u6587\u7ae0\u662f\u4e0a\u4e00\u7bc7\u5173\u4e8e\u4ecb\u7ecdGraphQL\u6982\u8ff0\uff0c\u5e76\u786e\u8ba4Query\u548cMutation\u7684\u64cd\u4f5c\u7684\u7eed\u7bc7\u3002\u672c\u6587\u5c06\u8ba8\u8bbaG […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apolloserver\u63a2\u7d22graphql\u7684subscription\u529f\u80fd\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-12-08T11:47:52+00:00","article_modified_time":"2024-05-03T16:57:54+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d830c913a08637a6b27fa\/7-0.png"}],"author":"\u6587, \u7fd4","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6587, \u7fd4","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"3 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/","name":"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-12-08T11:47:52+00:00","dateModified":"2024-05-03T16:57:54+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u4f7f\u7528ApolloServer\u63a2\u7d22GraphQL\u7684Subscription\u529f\u80fd"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c","name":"\u6587, \u7fd4","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g","caption":"\u6587, \u7fd4"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/wenxiang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apolloserver%e6%8e%a2%e7%b4%a2graphql%e7%9a%84subscription%e5%8a%9f%e8%83%bd\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48092","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/6"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=48092"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48092\/revisions"}],"predecessor-version":[{"id":95151,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48092\/revisions\/95151"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=48092"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=48092"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=48092"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}