Go ব্যবহার করে শিল্পের জন্য ব্লকচেইন উন্নয়ন। অংশ 1

আমি এখন চার মাস ধরে "ব্লকচেইনের উপর ভিত্তি করে সরকারী এবং শিল্প খাতে ডেটা সুরক্ষা এবং ব্যবস্থাপনা সরঞ্জামগুলির বিকাশ" নামে একটি প্রকল্পে কাজ করছি।
এখন আমি আপনাকে বলতে চাই কিভাবে আমি এই প্রকল্পটি শুরু করেছি, এবং এখন আমি বিস্তারিতভাবে প্রোগ্রাম কোড বর্ণনা করব।

এটি একটি ধারাবাহিক নিবন্ধের প্রথম নিবন্ধ। এখানে আমি সার্ভার এবং প্রোটোকল বর্ণনা করি। আসলে, পাঠক এমনকি এই ব্লকচেইন উপাদানগুলির নিজস্ব সংস্করণ লিখতে পারে।

এবং এখানে দ্বিতীয় অংশ — ব্লকচেইন এবং লেনদেন ডেটা স্ট্রাকচার সম্পর্কে, সেইসাথে ডাটাবেসের সাথে মিথস্ক্রিয়া কার্যকর করে এমন প্যাকেজ সম্পর্কে।

গত বছর, ডিজিটাল ব্রেকথ্রু হ্যাকাথনে, তারা ডিস্ট্রিবিউটেড লেজার প্রযুক্তি ব্যবহার করে শিল্প এবং ডিজিটাল অর্থনীতির জন্য একটি দরকারী সিস্টেম তৈরি করার একটি ধারণা নিয়ে এসেছিল; উদ্ভাবন সহায়তা তহবিল দ্বারা উন্নয়নের জন্য একটি অনুদানও জারি করা হয়েছিল (আমার একটি আলাদা লিখতে হবে অনুদান সম্পর্কে নিবন্ধ, যারা সবেমাত্র স্টার্টআপ করতে শুরু করছেন তাদের জন্য ), এবং এখন ক্রমানুসারে।

ডেভেলপমেন্ট গো ল্যাঙ্গুয়েজে সঞ্চালিত হয়, এবং যে ডাটাবেসে ব্লকগুলো সংরক্ষিত থাকে সেটি হল লেভেলডিবি।
প্রধান অংশগুলি হল প্রোটোকল, সার্ভার (যা টিসিপি এবং ওয়েবসকেট চালায় - প্রথমটি ব্লকচেইন সিঙ্ক্রোনাইজ করার জন্য, দ্বিতীয়টি ক্লায়েন্টদের সংযোগ করার জন্য, জাভাস্ক্রিপ্ট থেকে লেনদেন এবং কমান্ড পাঠানোর জন্য, উদাহরণস্বরূপ।

যেমন উল্লেখ করা হয়েছে, এই ব্লকচেইনের প্রয়োজন হয় প্রাথমিকভাবে সরবরাহকারী এবং গ্রাহকদের মধ্যে পণ্যের বিনিময় স্বয়ংক্রিয় এবং সুরক্ষার জন্য, অথবা উভয়ই এক ব্যক্তির মধ্যে। এই লোকেরা একে অপরকে বিশ্বাস করার জন্য তাড়াহুড়ো করে না। কিন্তু কাজটি শুধুমাত্র একটি বিল্ট-ইন ক্যালকুলেটর দিয়ে একটি "চেকবুক" তৈরি করা নয়, একটি সিস্টেম যা পণ্যের জীবনচক্রের সাথে কাজ করার সময় উদ্ভূত বেশিরভাগ রুটিন কাজগুলিকে স্বয়ংক্রিয় করে। এই বিষয়টির জন্য দায়ী বাইটকোড, যেমন ব্লকচেইনের সাথে প্রথাগত, লেনদেনের ইনপুট এবং আউটপুটগুলিতে সংরক্ষিত থাকে (লেনদেনগুলি নিজেই ব্লকগুলিতে সংরক্ষিত থাকে, লেভেলডিবি-তে ব্লকগুলি GOB ফর্ম্যাটে প্রাক-এনকোড করা হয়)। প্রথমে, আসুন প্রোটোকল এবং সার্ভার (ওরফে নোড) সম্পর্কে কথা বলি।

প্রোটোকলটি জটিল নয়, এর পুরো পয়েন্টটি হল কিছু ডেটা লোড করার মোডে স্যুইচ করা, সাধারণত একটি ব্লক বা লেনদেন, একটি বিশেষ কমান্ড লাইনের প্রতিক্রিয়া হিসাবে, এবং এটি ইনভেন্টরি বিনিময়ের জন্যও প্রয়োজন, যাতে নোডটি জানে যে এটি কে এর সাথে সংযুক্ত এবং কীভাবে তাদের ব্যবসা করতে হয় (সিঙ্ক্রোনাইজেশন সেশনের জন্য সংযুক্ত নোডগুলিকে "প্রতিবেশী"ও বলা হয় কারণ তাদের আইপি পরিচিত এবং তাদের রাজ্যের ডেটা মেমরিতে সংরক্ষণ করা হয়)।

গো প্রোগ্রামারদের বোঝার জন্য ফোল্ডারগুলি (ডিরেক্টরিগুলিকে লিনাক্স বলে) প্যাকেজ বলা হয়, তাই এই ডিরেক্টরি থেকে Go কোড সহ প্রতিটি ফাইলের শুরুতে তারা লিখে প্যাকেজ ফোল্ডার_নাম_where_this_file অবস্থিত। অন্যথায়, আপনি কম্পাইলারকে প্যাকেজটি খাওয়াতে সক্ষম হবেন না। ঠিক আছে, যারা এই ভাষা জানেন তাদের জন্য এটি কোনও গোপন বিষয় নয়। এই প্যাকেজগুলি হল:

• নেটওয়ার্ক যোগাযোগ (সার্ভার, ক্লায়েন্ট, প্রোটোকল)
• সংরক্ষিত এবং প্রেরিত ডেটার কাঠামো (ব্লক, লেনদেন)
• ডাটাবেস (ব্লকচেন)
• ঐক্যমত
• স্ট্যাকড ভার্চুয়াল মেশিন (xvm)
• অক্সিলিয়ারি (ক্রিপ্টো, প্রকার) আপাতত এতটুকুই।

এখানে github লিঙ্ক

এটি একটি শিক্ষামূলক সংস্করণ, এতে আন্তঃপ্রক্রিয়া মিথস্ক্রিয়া এবং বেশ কয়েকটি পরীক্ষামূলক উপাদানের অভাব রয়েছে, তবে কাঠামোটি যার উপর উন্নয়ন করা হচ্ছে তার সাথে মিলে যায়। আপনার যদি মন্তব্যে পরামর্শ দেওয়ার কিছু থাকে তবে আমি আরও বিকাশে এটি বিবেচনায় নিয়ে খুশি হব। এবং এখন সার্ভার এবং একটি ব্যাখ্যা জন্য প্রোটোকল.

প্রথমে সার্ভারের দিকে তাকাই।

সার্ভার সাবরুটিন একটি ডেটা সার্ভার হিসাবে কাজ করে যা প্রোটোকল প্যাকেজ থেকে ডেটা স্ট্রাকচার ব্যবহার করে TCP প্রোটোকলের উপরে চলে।

রুটিন নিম্নলিখিত প্যাকেজ ব্যবহার করে: সার্ভার, প্রোটোকল, ধরনের. প্যাকেজে নিজেই tcp_server.go ডেটা স্ট্রাকচার রয়েছে পরিবেশন করা.

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

এটি নিম্নলিখিত পরামিতিগুলি গ্রহণ করতে পারে:

• নেটওয়ার্ক পোর্ট যার মাধ্যমে ডেটা আদান-প্রদান করা হবে
• JSON ফর্ম্যাটে সার্ভার কনফিগারেশন ফাইল
• ডিবাগ মোডে চলার জন্য পতাকা (ব্যক্তিগত ব্লকচেইন)

অগ্রগতি:

• JSON ফাইল থেকে কনফিগারেশন পড়ে
• ডিবাগ মোড ফ্ল্যাগ চেক করা হয়েছে: এটি সেট করা থাকলে, নেটওয়ার্ক সিঙ্ক্রোনাইজেশন শিডিয়ুলার চালু হয় না এবং ব্লকচেইন লোড হয় না
• কনফিগারেশন ডেটা স্ট্রাকচার শুরু করা এবং সার্ভার শুরু করা

সার্ভার

• প্রোটোকল অনুযায়ী TCP সার্ভার এবং নেটওয়ার্ক মিথস্ক্রিয়া চালু করে।
• এটিতে একটি সার্ভ ডেটা স্ট্রাকচার রয়েছে যার মধ্যে একটি পোর্ট নম্বর, একটি বাফার আকার এবং কাঠামোর একটি পয়েন্টার রয়েছে প্রকার।সেটিংস
• রান পদ্ধতি নেটওয়ার্ক ইন্টারঅ্যাকশন শুরু করে (একটি প্রদত্ত পোর্টে ইনকামিং সংযোগের জন্য শোনা, যখন একটি নতুন সংযোগ পাওয়া যায়, তখন এটির প্রক্রিয়াকরণ একটি নতুন থ্রেডে ব্যক্তিগত হ্যান্ডেল পদ্ধতিতে স্থানান্তরিত হয়)
• В হাতল সংযোগ থেকে ডেটা একটি বাফারে পড়া হয়, একটি স্ট্রিং উপস্থাপনায় রূপান্তরিত হয় এবং পাস করা হয় প্রোটোকল। পছন্দ
• প্রোটোকল। পছন্দ প্রত্যাবর্তন ফল বা একটি ত্রুটি ঘটায়। ফল তারপরে স্থানান্তরিত হয় protocol. ব্যাখ্যাযা ফিরে আসে intrpr - ধরনের বস্তু ব্যাখ্যা করা ডেটা, অথবা নির্বাচন ফলাফল প্রক্রিয়াকরণে একটি ত্রুটি ঘটায়
• তারপর সুইচটি কার্যকর করা হয় intrpr.commands[0] যা একটি চেক করে: ফলাফল, ইনভি, ত্রুটি এবং একটি বিভাগ আছে ডিফল্ট
• বিভাগে ফল সুইচ মান দ্বারা পাওয়া যায় intrpr.commands[1] যা মান পরীক্ষা করে বাফার দৈর্ঘ্য и সংস্করণ (প্রতিটি ক্ষেত্রে সংশ্লিষ্ট ফাংশন বলা হয়)

ক্রিয়াকলাপ GetVersion и বাফার দৈর্ঘ্য ফাইলে আছে srvlib.go সার্ভার প্যাকেজ

GetVersion(conn net.Conn, version string)

এটি কেবল কনসোলে প্রিন্ট করে এবং প্যারামিটারে পাস করা সংস্করণটি ক্লায়েন্টের কাছে পাঠায়:

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

.
ক্রিয়া

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

একটি ব্লক, লেনদেন, বা অন্যান্য নির্দিষ্ট ডেটা নিম্নরূপ লোড করে:

• কনসোলে প্রোটোকলে নির্দিষ্ট করা ডেটার ধরন প্রিন্ট করে যা গ্রহণ করা প্রয়োজন:

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

• মান পড়ে intrpr.Body একটি সংখ্যাগত পরিবর্তনশীল 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"))

সার্ভার প্যাকেজ থেকে পদ্ধতিগুলি প্যাকেজ থেকে ফাংশন ব্যবহার করে প্রাপ্ত ডেটা প্রক্রিয়া করার জন্য কনফিগার করা হয় প্রোটোকল.

প্রোটোকল

একটি প্রোটোকল একটি মাধ্যম হিসাবে কাজ করে যা নেটওয়ার্ক বিনিময়ে ডেটা উপস্থাপন করে।

পছন্দ (str স্ট্রিং) (স্ট্রিং, ত্রুটি) সার্ভার দ্বারা প্রাপ্ত ডেটার প্রাথমিক প্রক্রিয়াকরণ করে, ইনপুট হিসাবে ডেটার একটি স্ট্রিং উপস্থাপনা পায় এবং এর জন্য প্রস্তুত একটি স্ট্রিং প্রদান করে দোভাষী:

• ইনপুট স্ট্রিং ব্যবহার করে মাথা এবং শরীরের মধ্যে বিভক্ত করা হয় ReqParseN2(str)
• হেড উপাদানে বিভক্ত করা হয় এবং ReqParseHead(head) ব্যবহার করে একটি কমান্ড স্লাইসে স্থাপন করা হয়
• В সুইচ (কমান্ড[0]) প্রাপ্ত কমান্ড নির্বাচন করুন (cmd, কী, ঠিকানা অথবা বিভাগটি ট্রিগার করা হয় ডিফল্ট)
• 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)

একটি স্ট্রিং গ্রহণ করে ফল এবং বস্তুর একটি রেফারেন্স তৈরি করে এবং ফেরত দেয় ব্যাখ্যা করা ডেটা.

অগ্রগতি:

• একভাবে পছন্দ মাথা এবং শরীর ব্যবহার করে নিষ্কাশন করা হয় ReqParseN2(str)
• প্রধান উপাদান ব্যবহার করে বিভক্ত করা হয় ReqParseHead(মাথা)
• বস্তুটি আরম্ভ করা হয় ব্যাখ্যা করা ডেটা এবং এটিতে একটি পয়েন্টার ফেরত দেওয়া হয়:

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

এই বস্তু ব্যবহার করা হয় server.go প্যাকেজ প্রধান।

মক্কেল

ক্লায়েন্ট প্যাকেজে ফাংশন রয়েছে TCPConnect и TCPresponseData.

ক্রিয়া

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)

নির্দিষ্ট আকারের একটি বাফার তৈরি করে, সেখানে সার্ভারের প্রতিক্রিয়া পড়ে এবং এই বাফারটি এবং পঠিত বাইটের সংখ্যা, সেইসাথে একটি ত্রুটি বস্তু ফেরত দেয়।

ক্লায়েন্ট সাবরুটিন

নোড সার্ভারে কমান্ড পাঠাতে, সেইসাথে সংক্ষিপ্ত পরিসংখ্যান এবং পরীক্ষার জন্য কাজ করে।

নিম্নলিখিত পরামিতিগুলি গ্রহণ করতে পারে: JSON ফর্ম্যাটে কনফিগারেশন ফাইল, স্ট্রিং হিসাবে সার্ভারে পাঠানো ডেটা, পেলোডে পাঠানো ফাইলের পাথ, নোড শিডিউলার এমুলেশন ফ্ল্যাগ, সাংখ্যিক মান হিসাবে স্থানান্তরিত ডেটার প্রকার।

• কনফিগারেশন হচ্ছে

  st := types.ParseConfig(*config)

• ইমু পতাকা পাস হলে, এটি শুরু হয় sheduler
• যদি ফাইলের পথ নির্দেশ করে f পতাকা সরবরাহ করা হয়, তাহলে আমরা এর ডেটা লোড করি fdb এবং বিষয়বস্তু সার্ভারে পাঠানো হয়

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

• যদি ফাইলটি নির্দিষ্ট করা না থাকে, তাহলে পতাকা থেকে ডেটা সহজভাবে পাঠানো হয় -d:

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

এই সমস্ত প্রোটোকলের গঠন দেখানো একটি সরলীকৃত উপস্থাপনা. বিকাশের সময়, প্রয়োজনীয় কার্যকারিতা এর কাঠামোতে যুক্ত করা হয়।

দ্বিতীয় অংশে আমি ব্লক এবং লেনদেনের জন্য ডেটা স্ট্রাকচার সম্পর্কে কথা বলব, 3-এ জাভাস্ক্রিপ্ট থেকে সংযোগের জন্য ওয়েবসকেট সার্ভার সম্পর্কে, 4-এ আমি সিঙ্ক্রোনাইজেশন শিডিউলার দেখব, তারপরে একটি স্ট্যাক মেশিন যা ইনপুট এবং আউটপুট থেকে বাইটকোড প্রক্রিয়া করে, ক্রিপ্টোগ্রাফি এবং আউটপুট জন্য পুল.

উত্স: www.habr.com