अपोलो ऑनलाइन चैट, Node.js के लिए बैकएंड एप्लिकेशन बनाना

कुछ समय पहले मैं एक मोबाइल एप्लिकेशन पर काम कर रहा था, जिसकी कार्यक्षमता में एक सुविधाजनक ऑनलाइन चैट शामिल था। और अब मैंने बैकेंड पर अपोलो सर्वर और नोड.जेएस का उपयोग करके चैट बनाने के बारे में संक्षिप्त निर्देशों के साथ एक लेख लिखने का फैसला किया, साथ ही साथ क्लाइंट की ओर से देशी और अपोलो क्लाइंट पर प्रतिक्रिया दी।

आसान पढ़ने के लिए लेख को दो भागों में विभाजित किया गया है। पहले भाग में एक एप्लिकेशन बैकएंड बनाने के लिए एक गाइड होता है, और दूसरे भाग में एप्लिकेशन फ्रंटएंड बनाने के लिए एक गाइड होता है।

यदि आप पढ़ने में बहुत आलसी हैं, तो आप तुरंत यहाँ और यहाँ Github'e में कोड देख सकते हैं ।

कार्यान्वयन के लिए मुख्य तकनीकों के रूप में, मैंने नोड.जेएस फ्रेमवर्क कोआ , पोस्टग्रैस्कल डेटाबेस, साथ ही ग्राफकॉल सर्वर - अपोलो-सर्वर-कोआ को चुना ।

सबसे पहले, एक खाली koa2 परियोजना उत्पन्न हुई थी, इसके लिए मैंने टर्मिनल में कमांड निष्पादित करके एक साधारण कोआ-जनरेटर का उपयोग किया:

$ koa <project name> 

फिर आवश्यक निर्भरताएं स्थापित की गईं, मैं इसे यार्न के साथ करता हूं, लेकिन आप एनपीएम का उपयोग कर सकते हैं।

 $ yarn add apollo-server-koa knex objection pg 

सभी आवश्यक लाइब्रेरी स्थापित हैं, अब आप कोड लिख सकते हैं

डेटाबेस से कनेक्ट करने के लिए, आपको दो फ़ाइलों का वर्णन करने की आवश्यकता है, पहले एक db.js है, जो knex क्लाइंट उदाहरण निर्यात करेगा और हमारे मॉडल को डेटाबेस से डेटा के साथ काम करने की अनुमति देगा, दूसरा है knexfile.js, जिसमें डेटाबेस कनेक्शन सेटिंग्स बनाने और रोलिंग पलायन।

Db.js कोड नीचे वर्णित है, ध्यान दें कि सभी सेटिंग्स पर्यावरण चर से ली गई हैं:

 const db = require('knex')({ client: 'pg', connection: {   host : process.env.POSTGRES_HOST,   port: process.env.POSTGRES_PORT,   user : process.env.POSTGRES_USER,   password : process.env.POSTGRES_PASSWORD,   database : process.env.POSTGRES_DATABASE } }); module.exports = db; 

कोड knexfile.js यहां उपलब्ध है ।

अब आप उन दो तालिकाओं को बनाने के लिए पलायन का वर्णन कर सकते हैं जिनकी हमें आवश्यकता है।

तालिकाएँ स्वयं यथासंभव सरल होंगी और इनमें केवल न्यूनतम आवश्यक क्षेत्र निर्धारित होंगे। उन्हें बनाने का आदेश नीचे है:

 $ knex migrate:make migration_name 

आप माइग्रेशन फ़ाइलों को यहाँ देख सकते हैं ।

अब इकाई मॉडल संदेश और उपयोगकर्ता बनाएँ

 class Message extends Model { static get tableName() {   return 'messages'; } $beforeInsert() {   this.created_at = new Date().toISOString(); } static get relationMappings() {   return {     user: {       relation: Model.BelongsToOneRelation,       modelClass: User,       join: {         from: 'messages.user_id',         to: 'users.id'       }     }   }; } } 

सबसे दिलचस्प बात बनी रही - अपोलो-सर्वर-कोआ को जोड़ना और कॉन्फ़िगर करना, ग्रेफ़ल योजनाओं और रिज़ॉल्वर का वर्णन।

अपोलो-सर्वर-कोआ को जोड़ने के लिए, बस कोड की निम्न पंक्तियों को जोड़ें

app.js:

 const { ApolloServer } = require('apollo-server-koa'); const graphqlSchema = require('./graphqlSchema'); … const apolloServer = new ApolloServer(graphqlSchema); apolloServer.applyMiddleware({ app }); 

www:

 var { app, apolloServer } = require('../app'); ... apolloServer.installSubscriptionHandlers(server); 

अपोलो-सर्वर-कोआ को जोड़ने के अलावा, हमने ग्राहकों को सूचित करने के लिए सदस्यता के साथ काम करने की क्षमता को शामिल किया है कि चैट में एक नया संदेश आया है।

अपोलो-सर्वर-कोआ जुड़ा हुआ है, अगला चरण चैट के लिए आवश्यक प्रकारों के साथ ग्राफिकल आरेख का वर्णन है

 input UserInput { username: String! } input MessageInput { text: String! user_id: ID! } type User { id: ID username: String } type Message { id: ID text: String created_at: String user: User } type Query { getLast100Messages: [Message] } type Mutation { findOrCreateUser(user: UserInput!): User createMessage(message: MessageInput!): Message } type Subscription { messageCreated: Message } 

सर्किट तैयार है, हम रिज़ॉल्वर का वर्णन करते हैं

एक नया संदेश भेजने के लिए एक रिज़ॉल्वर का एक उदाहरण:

 const Message = require('../../models/message'); const { pubsub, MESSAGE_CREATED } = require('../../utils'); module.exports = { createMessage: async (obj, { message }, context, info) => {   const createdMessage = await Message     .query()     .insert(message);   const resultMessage = await Message     .query()     .eager('user')     .findById(createdMessage.id);   pubsub.publish(MESSAGE_CREATED, { messageCreated: resultMessage });   return resultMessage; }, }; 

एक दिलचस्प बात यह है कि डेटाबेस में संदेश को सहेजने के अलावा, प्रकाशन () फ़ंक्शन को यहां कहा जाता है, जो सभी ग्राहकों को MESSAGE_CREATED ईवेंट के बारे में सूचित करता है, उन्हें एक नए संदेश का उद्देश्य भेजता है (चौकस पाठक यह नोटिस करेगा कि प्रेषक को उसके नए संदेश की सूचना भी मिल जाएगी, और हम इस पर आगे की प्रक्रिया करेंगे। ग्राहक, एक वास्तविक परियोजना में यह बैकेंड की ओर से इसे संसाधित करने के लिए समझ में आता है, ताकि विभिन्न ग्राहकों के बीच तर्क की नकल न करें)।

शेष रिज़ॉल्वर का कोड यहां पाया जा सकता है ।

चैट का सर्वर साइड तैयार है, मैं कैसे सत्यापित कर सकता हूं कि सब कुछ काम कर रहा है?

अपने ब्राउज़र में होस्ट खोलें और आपको इसमें ग्राफ़िकल खेल का मैदान दिखाई देगा।



अगले भाग में, हम एक मोबाइल एप्लिकेशन बनाएंगे।