नाटक "मल्टीप्लेयर ऑनलाइन गेम का विकास।" भाग 2: यह भयानक शब्द है "प्रोटोकॉल"

भाग 1: वास्तुकला
भाग 3: क्लाइंट-सर्वर इंटरैक्शन
भाग 4: 3 डी में जा रहा है

इसलिए, हम एक मल्टीप्लेयर गेम बनाना जारी रखेंगे।
आज हम एक डेटा ट्रांसफर प्रोटोकॉल बनाने पर विचार करेंगे।
और टीसीपी सर्वर रिक्तता भी बनाएं और, तदनुसार, क्लाइंट।

भाग दो एक कदम: डेटा ट्रांसफर प्रोटोकॉल।

बस के मामले में, मैं विशेष रूप से उबाऊ पाठकों को याद दिलाता हूं कि हम भूकंप, एससी या ऐसा कुछ विकसित नहीं कर रहे हैं। मुख्य कार्य सामान्य सिद्धांतों और दृष्टिकोण को एक कार्यशील अनुप्रयोग के उदाहरण का उपयोग करना है।

उपस्थिति में, यह बहुत डरावना और जटिल लगता है "डेटा ट्रांसफर प्रोटोकॉल बनाना", लेकिन जैसा कि पेंट किया गया है, शैतान उतना भयानक नहीं है ...

सामान्य तौर पर गेम देव में एक प्रोटोकॉल के रूप में क्या समझा जाता है? नहीं, यह बाइक सॉकेट का अपना कार्यान्वयन नहीं है ... और इसका स्वयं का http प्रोटोकॉल नहीं है ... सामान्य तौर पर, यह सर्वर और क्लाइंट के बीच संचरण के लिए डेटा पैकिंग का एक तरीका है। उदाहरण के लिए, आपके पास एक डेटा ऑब्जेक्ट है जो मानचित्र पर आपके टैंक की स्थिति के बारे में जानकारी संग्रहीत करता है। इस जानकारी को सर्वर पर कैसे ट्रांसफर किया जाए? एक मानक क्रमांकन विकल्प है। कई प्रोग्रामिंग भाषाएं क्रमबद्धता / deserialization प्रक्रिया को बहुत सरल बनाती हैं। कोड की कुछ पंक्तियाँ। और यह काम करेगा ... लेकिन हमेशा की तरह नुकसान होते हैं। उदाहरण के लिए, क्रमांकन / डिसेरिएलाइज़ेशन की गति, प्राप्त वस्तु का आकार ... और यदि गति अभी भी क्लाइंट के लिए उपेक्षित हो सकती है, तो सर्वर को कड़ा होना पड़ेगा, क्योंकि इसमें प्रत्येक क्लाइंट से संदेशों को पार्स करना होगा ... और किसी को नेटवर्क पर अतिरिक्त लोड की आवश्यकता नहीं है। एक और बिंदु है, यह क्रॉस-प्लेटफॉर्म है। यहां हमारे मामले में सर्वर स्केला पर है, और क्लाइंट फ्लैश पर है। तो यह सिर्फ इतना है कि वे सीधे वस्तुओं का आदान-प्रदान नहीं कर सकते हैं।

इसलिए, इस प्रक्रिया के विभिन्न कार्यान्वयन हैं। विश्व स्तर पर, उन्हें दो प्रकारों में विभाजित किया जा सकता है: बाइनरी और टेक्स्ट। XML और JSON जैसे टेक्स्ट वाले। उनके साथ काम करना बहुत आसान है। XML शायद सबसे लोकप्रिय विकल्प है। लेकिन वास्तविक समय के खेल के लिए, वे उपयुक्त नहीं हैं। पार्सिंग XML के उच्च ओवरहेड और स्थानांतरित किए गए डेटा की बहुत बड़ी मात्रा (xml मार्कअप में बहुत अधिक स्थान लेता है) वास्तव में इसके उपयोग के लिए एक अंत डाल देता है। JSON अधिक हल्का है, मार्कअप XML की तुलना में बहुत कम जगह लेता है, लेकिन फिर भी इसकी तुलना बाइनरी प्रोटोकॉल से नहीं की जा सकती है। हालांकि टर्न-आधारित खेलों के लिए, वे काफी उपयुक्त हैं।

बाइनरी प्रोटोकॉल के लिए, एक्सएमएल या जेएसएनएस के रूप में उनके पास कोई मार्कअप नहीं है, जिसके कारण प्रेषित डेटा की मात्रा और एक संदेश को पार्स करने का समय काफी कम हो जाता है। बाइनरी प्रोटोकॉल के उदाहरण एएमएफ, प्रोटोबॉफ़ हैं। प्रोटोबॉफ़ आम तौर पर बहुत अच्छा है। यह Google द्वारा अपनी सेवाओं में विकसित और उपयोग किया गया था। कई भाषाओं में इसका कार्यान्वयन है। और सामान्य मामले में, मैं इसे या इसके एनालॉग्स का उपयोग करने की सलाह दूंगा।

लेकिन हम यहां अध्ययन कर रहे हैं और हमारे पास अपेक्षाकृत सरल परियोजना है। इसलिए, हम अपनी खुद की आरामदायक साइकिल बनाएंगे।

आइए कल्पना करें कि हमें आम तौर पर सर्वर और क्लाइंट के बीच स्थानांतरण करने की आवश्यकता है?

क्लाइंट से सर्वर तक संदेश
1. प्राधिकरण (लॉगिन)
2. चलते समय टैंक के निर्देशांक (x, y)
3. शॉट (x, y), उस स्थान का निर्देशांक जहां खिलाड़ी ने गोलीबारी की, सर्वर पर गणना करने के लिए कि क्या कोई हिट था
4. टीम सर्वर पर खिलाड़ियों की संख्या का अनुरोध करती है
5. टीम से बाहर निकलें

सर्वर से क्लाइंट तक संदेश
1. पुष्टि प्राधिकरण
2. दुश्मन टैंक और इसकी स्थिति (जीवित / मारा), (x, y, s) के निर्देशांक
3. टीम "हमें मारा"
4. खिलाड़ियों की संख्या
5. ग्राहक के अनुरोध पर वियोग

संक्षेप में, हम सभी प्रेषित डेटा को 7 बाइट्स में फिट कर सकते हैं।



यह मुख्य संचरित पैकेट है जब टैंक के निर्देशांक के साथ चलती है और जब फायरिंग होती है। मामले में जब हमें अन्य डेटा स्थानांतरित करने की आवश्यकता होती है, तो हम उन्हें इन 7 बाइट्स में जगह देंगे। उदाहरण के लिए, हम X, Y निर्देशांक के बजाय सक्रिय उपयोगकर्ताओं की संख्या को स्थानांतरित करेंगे।

नतीजतन, हमें एक बहुत ही कॉम्पैक्ट, तेज, यद्यपि बहुत सरल संस्करण मिला, लेकिन हमारे उद्देश्यों के लिए यह काफी उपयुक्त है। आखिरकार, हमारे पास बहुत कम प्रेषित डेटा हैं।

भविष्य में, हम अपने प्रोटोकॉल में सुधार करेंगे। लेकिन यह निम्नलिखित भागों में होगा।

भाग दो कार्रवाई दो: टीसीपी सर्वर।

फिलहाल, हमें एक सर्वर स्टब बनाने की आवश्यकता है। कार्य इस प्रकार हैं:
1. ग्राहकों को जोड़ना
2. कनेक्टेड क्लाइंट को एक आईडी असाइन करना

बस इतना ही, इस स्तर पर हमें किसी और चीज की जरूरत नहीं है, इसलिए कोड बहुत सरल है।
यहां हमने एक स्कैला एप्लिकेशन बनाया

def main(args: Array[ String ]): Unit =
{
val port = 7777

try
{
val listener = new ServerSocket(port)
var numClients = 1

println( "Listening on port " + port)

while ( true )
{
new ClientHandler(listener.accept(), numClients).start()
numClients += 1
}

listener.close()
}
catch
{
case e: IOException =>
System.err.println( "Could not listen on port: " + port + "." )
System.exit(-1)
}
}

* This source code was highlighted with Source Code Highlighter .

def main(args: Array[ String ]): Unit =
{
val port = 7777

try
{
val listener = new ServerSocket(port)
var numClients = 1

println( "Listening on port " + port)

while ( true )
{
new ClientHandler(listener.accept(), numClients).start()
numClients += 1
}

listener.close()
}
catch
{
case e: IOException =>
System.err.println( "Could not listen on port: " + port + "." )
System.exit(-1)
}
}

* This source code was highlighted with Source Code Highlighter .

और एक कनेक्शन हैंडलर।

class ClientHandler (socket : Socket, clientId : Int) extends Actor
{
def act
{
try
{
val out = new PrintWriter( socket.getOutputStream(), true )
val in = new BufferedReader( new InputStreamReader(socket.getInputStream()) )

print( "Client connected from " + socket.getInetAddress() + ":" + socket.getPort )
println( " assigning id " + clientId)

var inputLine = in .readLine()
while (inputLine != null )
{
println(clientId + ") " + inputLine)

inputLine = in .readLine()
}

socket.close()

println( "Client " + clientId + " exit" )
}
catch
{
case e: SocketException => System.err.println(e)

case e: IOException => System.err.println(e.getMessage)

case e => System.err.println( "Unknown error " + e)
}
}
}

* This source code was highlighted with Source Code Highlighter .

class ClientHandler (socket : Socket, clientId : Int) extends Actor
{
def act
{
try
{
val out = new PrintWriter( socket.getOutputStream(), true )
val in = new BufferedReader( new InputStreamReader(socket.getInputStream()) )

print( "Client connected from " + socket.getInetAddress() + ":" + socket.getPort )
println( " assigning id " + clientId)

var inputLine = in .readLine()
while (inputLine != null )
{
println(clientId + ") " + inputLine)

inputLine = in .readLine()
}

socket.close()

println( "Client " + clientId + " exit" )
}
catch
{
case e: SocketException => System.err.println(e)

case e: IOException => System.err.println(e.getMessage)

case e => System.err.println( "Unknown error " + e)
}
}
}

* This source code was highlighted with Source Code Highlighter .

कोड अंतिम सत्य नहीं है। मैं बिना किसी अनुकूलन के, सभी के लिए इसे सबसे अधिक समझने योग्य तरीके से लिखने की कोशिश करूँगा। इसलिए, ज्यादा किक न करें, और यदि रचनात्मक आलोचना हो, तो वे कहते हैं कि आपका स्वागत है।

मुझे आशा है कि कोड अनुचित तरीके से समझाया गया है? वह बहुत सरल है।

यह केवल एक रिक्त है, इसलिए हार्डकोड के लिए पोर्ट नंबर जैसी चीजें। अगले भाग में, हम अपने सर्वर का मुकाबला करते हुए, रिफैक्टरिंग करेंगे।

भाग दो कार्रवाई तीन: ग्राहक।

प्रोटोकॉल को लागू करने और सत्यापित करने के लिए, हमें ग्राहक की खरीद की भी आवश्यकता होगी।
इस स्तर पर आवश्यक कार्य बहुत सरल हैं:
1. सर्वर से कनेक्ट करें।
2. अपनी स्थिति प्रदर्शित करें।
और यह बात है ... हमें अब और कुछ नहीं चाहिए।

क्लाइंट कोड भी बहुत सरल है और मैं इस पर टिप्पणी नहीं करूंगा।

public class Main extends Sprite
{
public var socket:Socket = new Socket();

public var host: String = "127.0.0.1" ;
public var port: int = 7777;

public var status:TextField = new TextField();

public function Main(): void
{
if (stage) init();
else addEventListener(Event.ADDED_TO_STAGE, init);
}

private function init(e:Event = null ): void
{
removeEventListener(Event.ADDED_TO_STAGE, init);
// entry point

status.text = "Player" ;
addChild( status );

socket.addEventListener(Event.CONNECT, socketConnectHandler);
socket.addEventListener(IOErrorEvent.IO_ERROR, ioErrorHandler);
socket.addEventListener(DataEvent.DATA, dataHandler);

socket.connect(host, port);
}


//
private function socketConnectHandler(e:Event): void
{
status.text = "Player - connectrd" ;
}

//
private function ioErrorHandler(e:IOErrorEvent): void
{
status.text = "Player - error" ;
}

//
private function dataHandler(e:DataEvent): void
{
switch (e.data)
{
//
}
}

//
public function sendMessage(val: String ): void {
if (val != "" && socket.connected)
{
//socket.writeBytes( val);
}
}

public function exitGame(): void
{
if (socket.connected)
{
socket.close();
}
}

}

* This source code was highlighted with Source Code Highlighter .

public class Main extends Sprite
{
public var socket:Socket = new Socket();

public var host: String = "127.0.0.1" ;
public var port: int = 7777;

public var status:TextField = new TextField();

public function Main(): void
{
if (stage) init();
else addEventListener(Event.ADDED_TO_STAGE, init);
}

private function init(e:Event = null ): void
{
removeEventListener(Event.ADDED_TO_STAGE, init);
// entry point

status.text = "Player" ;
addChild( status );

socket.addEventListener(Event.CONNECT, socketConnectHandler);
socket.addEventListener(IOErrorEvent.IO_ERROR, ioErrorHandler);
socket.addEventListener(DataEvent.DATA, dataHandler);

socket.connect(host, port);
}


//
private function socketConnectHandler(e:Event): void
{
status.text = "Player - connectrd" ;
}

//
private function ioErrorHandler(e:IOErrorEvent): void
{
status.text = "Player - error" ;
}

//
private function dataHandler(e:DataEvent): void
{
switch (e.data)
{
//
}
}

//
public function sendMessage(val: String ): void {
if (val != "" && socket.connected)
{
//socket.writeBytes( val);
}
}

public function exitGame(): void
{
if (socket.connected)
{
socket.close();
}
}

}

* This source code was highlighted with Source Code Highlighter .

तो सर्वर और क्लाइंट के बीच पहला संबंध बनाने के लिए सब कुछ तैयार है।
हम सर्वर शुरू करते हैं, हम क्लाइंट शुरू करते हैं ... और वॉयला ...

ग्राहक का परिणाम



हम देखते हैं कि क्लाइंट सर्वर से सफलतापूर्वक जुड़ा हुआ है।

सर्वर परिणाम



हम देखते हैं कि सर्वर पोर्ट 7777 पर शुरू हुआ, क्लाइंट से कनेक्शन प्राप्त किया और इसे एक आईडी दिया।

आज के लिए बस इतना ही।
अगले भाग में, हम प्रोटोकॉल को लागू करते हैं, और वास्तव में परिणामी क्लाइंट सर्वर इंटरैक्शन की जांच करते हैं।

हमेशा की तरह, सभी स्रोतों को जीथब पर देखा जा सकता है

युपीडी। टिप्पणी करते समय, कृपया ध्यान दें कि यह एक ट्यूटोरियल नहीं है "5 मिनट में अपना भूकंप कैसे लिखें" ... यह एक अनुक्रमिक है, सरल से जटिल तक, नेटवर्क गेम के विकास की प्रस्तुति। प्रारंभिक कार्य स्काला सर्वर और फ्लैश क्लाइंट के बीच नेटवर्क संचार करना है। और फिर इस बातचीत के आधार पर एक खेल बनाते हैं।