تطوير Blockchain للصناعة على Go. الجزء الأول

• الشبكات (الخادم ، العميل ، البروتوكول)
• هياكل البيانات المخزنة والمرسلة (الكتلة ، المعاملة)
• (blockchain)
• (consensus)
• (xvm)
• (crypto, types) .

type Serve struct {
	Port string
	BufSize int
	ST *types.Settings
}

• منفذ شبكة يتم من خلاله تبادل البيانات
• ملف تهيئة خادم JSON
• تشغيل العلم في وضع التصحيح (blockchain خاص)

• قراءة التكوين من ملف JSON
• يتم فحص علامة وضع التصحيح: إذا تم تعيينها ، فلن يتم تشغيل برنامج جدولة مزامنة الشبكة ولا يتم تحميل سلسلة الكتل
• تهيئة هيكل بيانات التكوين وبدء الخادم

الخادم

• يبدأ اتصال خادم TCP والشبكة وفقًا للبروتوكول.
• يحتوي على بنية بيانات Serve تتكون من رقم المنفذ وحجم المخزن المؤقت ومؤشر للأنواع.
• Run ( , handle )
• handle , protocol.Choice
• protocol.Choice result . result protocol.Interprete, intrpr — InterpreteData,
• ثم يتم تنفيذ التبديل عن طريق أوامر مقدمة [0] يتم فيها تحديد أحد الخيارات التالية: النتيجة ، رقم الفاتورة ، الخطأ ، وهناك قسم افتراضي
• في نتيجة القسم، هناك مفتاح من قيمة intrpr.Commands [1] الذي يتحقق قيم bufferlength و نسخة (في كل حالة يتم استدعاء الدالة المقابلة)

GetVersion(conn net.Conn, version string)

conn.Write([]byte("result:" + version))

BufferLength(conn net.Conn, intrpr *protocol.InterpreteData)

• يطبع على وحدة التحكم نوع البيانات المحددة في البروتوكول الذي يجب قبوله:
  
  

  fmt.Println("DataType:", intrpr.Commands[2])

• يقرأ الجسم المقدّم في المتغير الرقمي buf_len
• إنشاء مخزن مؤقت newbuf بالحجم المحدد:
  
  

  make([]byte, buf_len)

• يرسل استجابة جيدة:
  
  

  conn.Write([]byte("result:ok"))

• ينتج مخزن مؤقت كامل من دفق القراءة:
  
  

  io.ReadFull(conn, newbuf)

  .
• يطبع محتويات المخزن المؤقت على وحدة التحكم
  
  

  fmt.Println(string(newbuf))

  
  وعدد وحدات البايت المقروءة
  
  

  fmt.Println("Bytes length:", n)

• يرسل استجابة جيدة:
  
  

  conn.Write([]byte("result:ok"))

بروتوكول

• يتم تقسيم سلسلة الإدخال إلى الرأس والجسم باستخدام ReqParseN2 (str)
• يتم تقسيم الرأس إلى عناصر ويوضع في شريحة الأوامر باستخدام ReqParseHead (الرأس)
• في التبديل (أوامر [0]) ، نختار الأمر المستلم (يتم تشغيل cmd أو المفتاح أو العنوان أو القسم الافتراضي )
• في كمد ، يتم التحقق من أوامر التبديل 2 (أوامر [1]) - الطول و getversion .
• يقوم الطول بفحص نوع البيانات في الأوامر [2] وتخزينه في نوع البيانات
• الشيكات التي الجسم يحتوي على قيمة السلسلة
  
  

  len(body) < 1

• إرجاع سلسلة استجابة:
  
  

  "result:bufferlength:" + datatype + "/" + body

• إرجاع getversion سلسلة
  
  

  return "result:version/auto"

تفسير

type InterpreteData struct {
	Head string
	Commands []string
	Body string
	IsErr bool
	ErrCode int 
	ErrMessage string
}

Interprete(str string) (*InterpreteData, error)

• وبالمثل ، يستعيد Choice الرأس والجسم باستخدام ReqParseN2 (str)
• يتم تقسيم الرأس إلى عناصر باستخدام ReqParseHead (الرأس)
• تتم تهيئة كائن InterpreteData ويتم إرجاع مؤشر إليه:

res := &InterpreteData{
	Head: head,
	Commands: commands,
	Body: body,
}
return res, nil

عميل

TCPConnect(s *types.Settings, data []byte, payload []byte)

• يتم إجراء اتصال بالاتصال المحدد في كائن الإعدادات المنقولة
  
  

  net.Dial("tcp", s.Host + ":" + s.Port)

• يتم نقل البيانات التي تم تمريرها في معلمة البيانات:
  
  

  conn.Write(data)

• اقرأ الجواب
  
  

  resp, n, _ := TCPResponseData(conn, s.BufSize)

  
  وطباعتها على وحدة التحكم
  
  

  fmt.Println(string(resp[:n]))

• إذا تم إرسال الحمولة ، يتم إرسالها
  
  

  conn.Write(payload)

  
  ويقرأ أيضًا استجابة الخادم ، ويطبعها على وحدة التحكم

 TCPResponseData(conn net.Conn, bufsiz int) ([]byte, int, error)

روتين العميل

• احصل على التكوين
  
  

  st := types.ParseConfig(*config)

• إذا تم إعطاؤك علم emu يبدأ sheduler
• إذا تم تحديد العلامة f للإشارة إلى المسار إلى الملف ، فقم بتحميل بياناته في fdb وإرسال المحتويات إلى الخادم
  
  

  client.TCPConnect(st, []byte(CMD_BUFFER_LENGTH + ":" + strconv.Itoa(*t) + "/" + strconv.Itoa(fdblen)), fdb)

• إذا لم يتم تحديد الملف ، فسيتم ببساطة إرسال البيانات من العلامة -d :
  
  

  client.TCPConnect(st, []byte(*data), nil)