الصفحة الرئيسية>المتعلقة بالبرمجة>شفرة المصدر الأخرى
تنزيل

أمثلة زيلا

يحتوي هذا الريبو على مجموعة من أمثلة المجلدات التي يمكن استخدامها بشكل فردي لتوضيح ميزات Zilla الرئيسية. إذا كانت هذه هي خطوتك الأولى في رحلتك مع Zilla، فنحن نشجعك على تجربة Quickstart.

المتطلبات الأساسية

ستحتاج إلى بيئة مثبتة عليها Docker أو Helm وKubernetes. تحقق من مجموعات Postman الخاصة بنا لمزيد من الطرق للتفاعل مع مثال.

ابدء

يهدف البرنامج النصي startup.sh إلى المساعدة في إعداد وتفكيك المكونات الضرورية لكل مثال من الأمثلة. استخدامه هو أسهل طريقة للتفاعل مع كل مثال.

تجريبي

قم بتثبيت وتشغيل أي من الأمثلة باستخدام البرنامج النصي startup.sh : 

./startup.sh -m example.name

يمكنك تحديد مضيف ومنفذ كافكا الخاص بك أو دليل العمل الذي تريد تنزيل الأمثلة عليه. not تتم الكتابة فوق أدلة الأمثلة الموجودة. 

./startup.sh -m -k kafka:9092 -d /tmp example.name

وبدلاً من ذلك، يمكنك تشغيل هذا البرنامج النصي بنفس الطريقة دون استنساخ الريبو. 

wget -qO- https://raw.githubusercontent.com/aklivity/zilla-examples/main/startup.sh | sh -s -- -m example.name

الاستخدام 

./startup.sh --help
 Usage: startup.sh [-hm][-k KAFKA_BOOTSTRAP_SERVER][-d WORKDIR][-v ZILLA_VERSION][-e EX_VERSION][--no-kafka-init][--redpanda] example.name

Operand:
    example.name          The name of the example to use                                 [default: quickstart][string]

Options:
    -d | --workdir        Sets the directory used to download and run the example                             [string]
    -e | --ex-version     Sets the examples version to download                              [default: latest][string]
    -h | --use-helm       Use the helm install, if available, instead of compose                             [boolean]
    -k | --kafka-server   Sets the Kafka Boostrap Server to use                                               [string]
    -m | --use-main       Download the head of the main branch                                               [boolean]
    -v | --zilla-version  Sets the zilla version to use                                      [default: latest][string]
         --auto-teardown  Executes the teardown script immediately after setup                               [boolean]
         --no-kafka-init  The script wont try to bootstrap the kafka broker                                  [boolean]
         --redpanda       Makes the included kafka broker and scripts use Redpanda                           [boolean]
         --help           Print help                                                                         [boolean]

أمثلة

اسم وصف
asyncapi.mqtt.proxy يتم إعادة توجيه رسائل MQTT التي تم التحقق من صحتها ونشر الرسائل والوكلاء الذين يشتركون في وسيط MQTT
asyncapi.mqtt.kafka.proxy تقوم إعادة توجيه MQTT بنشر الرسائل إلى Kafka، والبث إلى جميع عملاء MQTT المشتركين
asyncapi.http.kafka.proxy يربط طلبات HTTP والاستجابات عبر موضوعات كافكا المنفصلة
asyncapi.sse.proxy يتم التحقق من صحة الرسائل التي يتم تسليمها بواسطة خادم SSE
asyncapi.sse.kafka.proxy تيارات الرسائل المنشورة على موضوع كافكا عبر SSE
tcp.echo أصداء البايتات المرسلة إلى خادم TCP
tcp.reflect صدى البايتات المرسلة إلى خادم TCP، والبث إلى كافة عملاء TCP
tls.echo يردد أصداء البايتات المشفرة المرسلة إلى خادم TLS
tls.reflect صدى البايتات المشفرة المرسلة إلى خادم TLS، والبث إلى جميع عملاء TLS
http.filesystem يخدم الملفات من دليل على نظام الملفات المحلي
http.filesystem.config.server يخدم الملفات من دليل على نظام الملفات المحلي، ويحصل على التكوين من خادم http
http.echo صدى الطلب المرسل إلى خادم HTTP من عميل HTTP
http.echo.jwt طلب أصداء تم إرساله إلى خادم HTTP من عميل HTTP معتمد من JWT
http.proxy تم إرسال طلب الوكيل إلى خادم HTTP من عميل HTTP
http.proxy.schema.inline تم إرسال طلب الوكيل إلى خادم HTTP من عميل HTTP مع فرض المخطط
http.kafka.sync يربط طلبات HTTP والاستجابات عبر موضوعات كافكا المنفصلة
http.kafka.async يربط طلبات HTTP والاستجابات عبر موضوعات كافكا المنفصلة بشكل غير متزامن
http.kafka.cache يقدم الاستجابات المخزنة مؤقتًا من موضوع كافكا، ويتم اكتشافها عند التحديث
http.kafka.oneway يرسل رسائل إلى موضوع كافكا، أطلق وانسى
http.kafka.crud يعرض REST API مع عمليات CRUD حيث يعمل موضوع كافكا المضغوط كجدول
http.kafka.sasl.scram يرسل رسائل إلى كافكا الذي تم تمكين SASL/SCRAM فيه
http.kafka.karapace التحقق من صحة الرسائل أثناء إنتاجها وإحضارها إلى موضوع كافكا
http.redpanda.sasl.scram يرسل رسائل إلى مجموعة Redpanda التي تم تمكين SASL/SCRAM بها
kubernetes.prometheus.autoscale ميزة Demo Kubernetes Horizontal Pod Autoscaling تعتمد على مقياس مخصص مع Prometheus
grpc.echo يردد صدى الرسائل المرسلة إلى خادم gRPC من عميل gRPC
grpc.kafka.echo صدى الرسائل المرسلة إلى موضوع كافكا عبر gRPC من عميل gRPC
grpc.kafka.fanout تدفق الرسائل المنشورة إلى موضوع كافكا، مع تطبيق الدمج بناءً على ضغط السجل
grpc.kafka.proxy يربط طلبات واستجابات gRPC بموضوعات كافكا المنفصلة
grpc.proxy يتم إرسال طلبات واستجابات gRPC للوكلاء إلى خادم gRPC من عميل gRPC
amqp.reflect يردد صدى الرسائل المنشورة على خادم AMQP، ويتم بثها إلى كافة عملاء AMQP المتلقيين
mqtt.kafka.broker تقوم إعادة توجيه MQTT بنشر الرسائل إلى Kafka، والبث إلى جميع عملاء MQTT المشتركين
mqtt.kafka.broker.jwt إعادة توجيه رسائل MQTT إلى Kafka، والبث إلى جميع عملاء MQTT المشتركين المعتمدين من JWT
بداية سريعة بدء نقاط النهاية لجميع البروتوكولات (HTTP، SSE، gRPC، MQTT)
sse.kafka.fanout تدفق الرسائل المنشورة إلى موضوع كافكا، مع تطبيق الدمج بناءً على ضغط السجل
sse.proxy.jwt رسائل الوكلاء التي يتم تسليمها بواسطة خادم SSE، مما يفرض قيود أمان التدفق
ws.echo يردد الرسائل المرسلة إلى خادم WebSocket
ws.reflect صدى الرسائل المرسلة إلى خادم WebSocket، والبث إلى جميع عملاء WebSocket

اقرأ المستندات. جرب الأمثلة. انضم إلى مجتمع سلاك.

يوسع
معلومات إضافية
تطبيقات ذات صلة
نوصي لك
أخبار ذات صلة الكل