خانه > توسعه نرم افزار > نحوه اتصال به کاساندرا با جاوا (قسمت دوم برنامه نمونه)

نحوه اتصال به کاساندرا با جاوا (قسمت دوم برنامه نمونه)

در قسمت اول با درایور یا راه اندازهای کاساندرا نسخه 3 برای اتصال به جاوا آشنا شدیم. در این بخش، نحوه اتصال به cassandra با java با استفاده از راه انداز DataStax بررسی خواهد شد و در ادامه یک مثال کاربردی از اتصال کاساندرا به زبان برنامه نویسی جاوا ارائه می شود. در انتهای مطلب هم فایل مثال ارائه شده که با IntelliJ IDEA  (یک IDE معروف برای جاوا) توسعه داده شده است برای استفاده خوانندگان محترم ضمیمه می شود.

توسط کتابخانه نوین و انعطاف­ پذیر راه ­انداز جاوا که توسط Datastax توسعه و پشتیبانی می­شود، می‌توان در برنامه جاوا، با زبان پرس­وجوی کاساندرا (CQL3) و پروتکل دودویی بومی کاساندرا، با خوشه پردازشی کاساندرا ارتباط برقرار کرد. معماری راه ­انداز لایه­ بندی می­باشد.

اتصال به cassandra با جاوا
اتصال به cassandra با جاوا

در لایه زیرین، هسته راه­ انداز قرار دارد که تمام مسایل مرتبط با اتصال با خوشه پردازشی کاساندرا (برای مثال، استخر اتصال، شناسایی گره جدید و غیره) را برعهده دارد.

 اتصال به سرورهای خوشه پردازشی کاساندرا

برای اتصال ابتدا باید شیءای از کلاس Cluster ایجاد و توسط زنجیره ­ی متدها، مشخصه ­های آن­ را مقدار دهی کرد:

با فرض شِمای زیر:

 

کد اتصال به خوشه کاساندرا و ایجاد جلسه ­ای بر فضای کلید contacts:

 

نکته 1: در برنامه کاربردی برای هر فضای کلید یا پایگاه داده، باید تنها یک نمونه از Cluster ایجاد کرد؛ این کلاس می­تواند، استخر اتصال، سیاست انتخاب گره (بطور پیش­فرض از رویکرد round robin استفاده می­کند)، فشرده ­سازی، بازگشت از خطا(failover) و سعی مجدد را کنترل کند. برای انجام کارهای اصلی (منطق کار) در فضای کلیدی در خوشه، نمونه­ای از کلاس Session باید ایجاد گردد. لازم به­ذکر است که Session، thread-safe است، بنابراین می­تواند در میان چند مشتری به اشتراک گذاشته شود.

نکته 2: اینکه برنامه راه انداز به کدام گره(ها)ی کاساندرا متصل شوند دو حالت متفاوت میتوان متصور شد که در راه انداز Datastax، با توجه به دو پیکربندی (الف) نقاط اتصال(Contact points) و (ب) سیاست­های تنظیم بار(Load balancing policies) تعیین می­شود که مشتری یا راه انداز،  به کدام گره(ها) وصل می‌شود:

اتصال به cassandra با جاوا
اتصال به cassandra با جاوا

 الحاق وابستگی ­ها برای اتصال به کاساندرا

برای افزودن وابستگی هسته راه­ انداز، به پروژه maven:

 

 

برای دانلود دایور Datastax میتوانیم از آدرس زیر راه انداز مطلوب خود را جستجو و دانلود کنید.

https://search.maven.org/

برای دانلود ورژن 3.4.0 میتوانید از لینک زیر استفاده کنید.

https://search.maven.org/remotecontent?filepath=com/datastax/cassandra/cassandra-driver-core/3.4.0/cassandra-driver-core-3.4.0.jar

ایجاد یک برنامه نمونه برای اتصال به cassandra با java

در مرحله، برنامه نمونه ی ما که شامل سه کلاس زیر به منظور ایجاد یک شی و ذخیره سازی آن در کاساندرا هست ارائه می شود.

کلاس EmployePOJO برای ایجاد شی employe که قرار است اطلاعات کارمندان در قالب این شی تولید و ذخیره شود.

 

کلاس CassandraDAO برای اتصال به cassandra با java

 

کلاس MainClass برای اجرای برنامه

 

 

فایل مثال ارائه شده که با IntelliJ IDEA  (یک IDE معروف برای جاوا) توسعه داده شده است برای دانلود و استفاده خوانندگان محترم در زیر ضمیمه شده است.

دانلود فایل برنامه اتصال به کاساندرا با جاوا cassandrajava.tar

منابع:

http://docs.datastax.com/en/developer/java-driver/3.1/

آدرس کانال تلگرام سایت بیگ دیتا:

t.me/bigdata_channel

آدرس کانال سروش ما:
https://sapp.ir/bigdata_channel

جهت دیدن سرفصل های دوره های آموزشی بر روی اینجا کلیک کنید.

 

دیدگاهتان را بنویسید

نشانی ایمیل شما منتشر نخواهد شد. بخش‌های موردنیاز علامت‌گذاری شده‌اند *