ভিয়েনানেট: ব্যাকএন্ডের জন্য লাইব্রেরির একটি সেট। অংশ ২

Raiffeisenbank .NET বিকাশকারী সম্প্রদায় ViennaNET-এর বিষয়বস্তু সংক্ষিপ্তভাবে পর্যালোচনা করে চলেছে। কিভাবে এবং কেন আমরা এখানে এসেছি সে সম্পর্কে, আপনি প্রথম অংশ পড়তে পারেন.

এই নিবন্ধে, আমরা বিতরণ করা লেনদেন, সারি এবং ডেটাবেসগুলির সাথে কাজ করার জন্য এখনও বিবেচনা করা লাইব্রেরিগুলির মধ্য দিয়ে যাব, যা আমাদের GitHub সংগ্রহস্থলে পাওয়া যেতে পারে (সূত্র এখানে), এবং Nuget প্যাকেজ এখানে.

ভিয়েনানেট.সাগাস

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

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

আমাদের বাস্তবায়ন এখনও তার মৌলিক আকারে তৈরি করা হয়েছে এবং অন্যান্য পরিষেবাগুলির সাথে মিথস্ক্রিয়া করার কোনও পদ্ধতির ব্যবহারের সাথে আবদ্ধ নয়। এটি ব্যবহার করা কঠিন নয়: শুধুমাত্র বেস অ্যাবস্ট্রাক্ট ক্লাস SagaBase-এর একটি বংশধর তৈরি করুন, যেখানে T হল আপনার প্রসঙ্গ শ্রেণী যেখানে আপনি গাথাটি কাজ করার জন্য প্রয়োজনীয় প্রাথমিক ডেটা সংরক্ষণ করতে পারেন, সেইসাথে কিছু মধ্যবর্তী ফলাফল। প্রসঙ্গ দৃষ্টান্তটি সম্পাদনের সময় সমস্ত ধাপে পাস করা হবে। সাগা নিজেই একটি রাষ্ট্রহীন শ্রেণী, তাই প্রয়োজনীয় নির্ভরতা পেতে উদাহরণটিকে সিঙ্গলটন হিসাবে DI তে স্থাপন করা যেতে পারে।

উদাহরণ বিজ্ঞাপন:

public class ExampleSaga : SagaBase<ExampleContext>
{
  public ExampleSaga()
  {
    Step("Step 1")
      .WithAction(c => ...)
      .WithCompensation(c => ...);
	
    AsyncStep("Step 2")
      .WithAction(async c => ...);
  }
}

উদাহরণ কল:

var saga = new ExampleSaga();
var context = new ExampleContext();
await saga.Execute(context);

বিভিন্ন বাস্তবায়নের সম্পূর্ণ উদাহরণ দেখা যেতে পারে এখানে এবং সঙ্গে সমাবেশে পরীক্ষা.

ViennaNET.Orm.*

Nhibernate এর মাধ্যমে বিভিন্ন ডাটাবেসের সাথে কাজ করার জন্য লাইব্রেরির একটি সেট। আমরা Liquibase ব্যবহার করে DB-প্রথম পদ্ধতি ব্যবহার করি, তাই একটি রেডিমেড ডাটাবেসে ডেটা নিয়ে কাজ করার জন্য শুধুমাত্র কার্যকারিতা রয়েছে।

ViennaNET.Orm.Seedwork и ViennaNET.Orm - যথাক্রমে মৌলিক ইন্টারফেস এবং তাদের বাস্তবায়ন সমন্বিত প্রধান সমাবেশ। আসুন আরও বিস্তারিতভাবে তাদের বিষয়বস্তু দেখুন।

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

ডাটাবেস সরাসরি অ্যাক্সেস করতে, প্রদানকারী প্রক্রিয়া ব্যবহার করা হয়। আমরা আমাদের দলগুলিতে ব্যবহার করি এমন প্রতিটি DBMS এর নিজস্ব বাস্তবায়ন রয়েছে: ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

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

"db": [
  {
    "nick": "mssql_connection",
    "dbServerType": "MSSQL",
    "ConnectionString": "...",
    "useCallContext": true
  },
  {
    "nick": "oracle_connection",
    "dbServerType": "Oracle",
    "ConnectionString": "..."
  }
],

উদাহরণ অ্যাপ্লিকেশন প্রসঙ্গ:

internal sealed class DbContext : ApplicationContext
{
  public DbContext()
  {
    AddEntity<SomeEntity>("mssql_connection");
    AddEntity<MigratedSomeEntity>("oracle_connection");
    AddEntity<AnotherEntity>("oracle_connection");
  }
}

যদি সংযোগ আইডি নির্দিষ্ট করা না থাকে, তাহলে "ডিফল্ট" নামের সংযোগটি ব্যবহার করা হবে।

ডাটাবেস টেবিলে সত্তার সরাসরি ম্যাপিং স্ট্যান্ডার্ড NHibernate টুল ব্যবহার করে বাস্তবায়িত হয়। আপনি xml ফাইল এবং ক্লাসের মাধ্যমে বর্ণনাটি ব্যবহার করতে পারেন। ইউনিট পরীক্ষায় স্টাব রিপোজিটরিগুলির সুবিধাজনক লেখার জন্য, একটি লাইব্রেরি রয়েছে ViennaNET.TestUtils.Orm.

ViennaNET.Orm.* ব্যবহারের সম্পূর্ণ উদাহরণ পাওয়া যাবে এখানে.

ViennaNET.মেসেজিং।*

সারি দিয়ে কাজ করার জন্য লাইব্রেরির একটি সেট।

সারিগুলির সাথে কাজ করার জন্য, বিভিন্ন DBMS-এর মতো একই পদ্ধতি বেছে নেওয়া হয়েছিল, যথা, লাইব্রেরির সাথে কাজ করার ক্ষেত্রে সর্বাধিক সম্ভাব্য ইউনিফাইড পন্থা, কিউ ম্যানেজার ব্যবহার করা নির্বিশেষে। লাইব্রেরি ViennaNET.Messaging এই একীকরণের জন্য অবিকল দায়ী, এবং ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue и ViennaNET.Messaging.KafkaQueue IBM MQ, RabbitMQ এবং Kafka এর জন্য যথাক্রমে অ্যাডাপ্টার বাস্তবায়ন রয়েছে।

সারিগুলির সাথে কাজ করার সময়, দুটি প্রক্রিয়া রয়েছে: একটি বার্তা গ্রহণ করা এবং এটি প্রেরণ করা।

গ্রহণ বিবেচনা করুন. এখানে 2টি বিকল্প রয়েছে: ক্রমাগত শোনার জন্য এবং একটি একক বার্তা পাওয়ার জন্য৷ ক্রমাগত সারিতে শোনার জন্য, আপনাকে প্রথমে উত্তরাধিকার সূত্রে প্রাপ্ত প্রসেসর ক্লাস বর্ণনা করতে হবে IMessageProcessor, যা আগত বার্তা প্রক্রিয়াকরণের জন্য দায়ী থাকবে। এর পরে, এটি একটি নির্দিষ্ট সারির সাথে "লিঙ্ক" করা আবশ্যক; এটি নিবন্ধনের মাধ্যমে করা হয় IQueueReactorFactory কনফিগারেশন থেকে সারি শনাক্তকারীকে নির্দেশ করে:

"messaging": {
    "ApplicationName": "MyApplication"
},
"rabbitmq": {
    "queues": [
      {
        "id": "myQueue",
        "queuename": "lalala",
        ...
      }
    ]
},

শোনা শুরু করার উদাহরণ:

_queueReactorFactory.Register<MyMessageProcessor>("myQueue");
var queueReactor = queueReactorFactory.CreateQueueReactor("myQueue");
queueReactor.StartProcessing();

তারপর, যখন পরিষেবা শুরু হয় এবং পদ্ধতিটি শোনা শুরু করার জন্য বলা হয়, নির্দিষ্ট সারির সমস্ত বার্তা সংশ্লিষ্ট প্রসেসরে যাবে।

একটি ফ্যাক্টরি ইন্টারফেসে একটি একক বার্তা পেতে IMessagingComponentFactory একটি পদ্ধতি আছে CreateMessageReceiverযা একটি প্রাপক তৈরি করবে যা নির্দিষ্ট সারি থেকে একটি বার্তার জন্য অপেক্ষা করছে:

using (var receiver = _messagingComponentFactory.CreateMessageReceiver<TestMessage>("myQueue"))
{
    var message = receiver.Receive();
}

একটি বার্তা পাঠাতে আপনি একই ব্যবহার করতে হবে IMessagingComponentFactory এবং একটি বার্তা প্রেরক তৈরি করুন:

using (var sender = _messagingComponentFactory.CreateMessageSender<MyMessage>("myQueue"))
{
    sender.SendMessage(new MyMessage { Value = ...});
}

একটি বার্তাকে সিরিয়ালাইজ এবং ডিসিরিয়ালাইজ করার জন্য তিনটি রেডিমেড বিকল্প রয়েছে: শুধু পাঠ্য, XML এবং JSON, তবে যদি প্রয়োজন হয়, আপনি সহজেই আপনার নিজস্ব ইন্টারফেস বাস্তবায়ন করতে পারেন IMessageSerializer и IMessageDeserializer.

আমরা প্রতিটি কিউ ম্যানেজারের অনন্য ক্ষমতা সংরক্ষণ করার চেষ্টা করেছি, যেমন ViennaNET.Messaging.MQSeriesQueue আপনাকে কেবল পাঠ্যই নয়, বাইট বার্তাও পাঠাতে দেয় এবং ViennaNET.Messaging.RabbitMQQueue রাউটিং এবং অন-দ্য-ফ্লাই সারি সাপোর্ট করে। RabbitMQ-এর জন্য আমাদের অ্যাডাপ্টার র‍্যাপারও RPC-এর কিছু সাদৃশ্য প্রয়োগ করে: আমরা একটি বার্তা পাঠাই এবং একটি বিশেষ অস্থায়ী সারি থেকে প্রতিক্রিয়ার জন্য অপেক্ষা করি, যা শুধুমাত্র একটি প্রতিক্রিয়া বার্তার জন্য তৈরি করা হয়।

এখানে মৌলিক সংযোগের সূক্ষ্মতা সহ সারি ব্যবহার করার একটি উদাহরণ.

ViennaNET.CallContext

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

আপনার মনোযোগের জন্য আপনাকে ধন্যবাদ, আমরা আপনার মন্তব্য এবং অনুরোধ অনুরোধের জন্য উন্মুখ!

উত্স: www.habr.com