หน้าแรก>การเขียนโปรแกรมที่เกี่ยวข้อง>ซอร์สโค้ดอื่น ๆ
ดาวน์โหลด

ตัวอย่างของ Zilla

Repo นี้ประกอบด้วยคอลเลกชันโฟลเดอร์ตัวอย่างที่สามารถใช้แยกกันเพื่อสาธิตคุณสมบัติหลักของ Zilla หากนี่คือก้าวแรกของคุณในการเดินทางกับ Zilla เราขอแนะนำให้คุณลองใช้ Quickstart ของเรา

ข้อกำหนดเบื้องต้น

คุณจะต้องมีสภาพแวดล้อมที่ติดตั้ง Docker หรือ Helm และ Kubernetes ลองดูคอลเลกชันบุรุษไปรษณีย์ของเราเพื่อดูวิธีอื่นๆ ในการโต้ตอบกับตัวอย่าง

เริ่มต้นใช้งาน

สคริปต์ startup.sh มีไว้เพื่อช่วยในการตั้งค่าและแยกส่วนประกอบที่จำเป็นสำหรับแต่ละตัวอย่าง การใช้เป็นวิธีที่ง่ายที่สุดในการโต้ตอบกับแต่ละตัวอย่าง

การสาธิต

ติดตั้งและรันตัวอย่างใดๆ โดยใช้สคริปต์ startup.sh : 

./startup.sh -m example.name

คุณสามารถระบุโฮสต์และพอร์ต Kafka ของคุณเองหรือไดเร็กทอรีการทำงานที่คุณต้องการดาวน์โหลดตัวอย่างได้ ไดเร็กทอรีตัวอย่างที่มีอยู่จะ not ถูกเขียนทับ 

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

หรือคุณสามารถเรียกใช้สคริปต์นี้ในลักษณะเดียวกันโดยไม่ต้องโคลน repo 

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 และการตอบกลับในหัวข้อ Kafka ที่แยกจากกัน
asyncapi.sse.proxy ข้อความที่ตรวจสอบพร็อกซีที่ส่งโดยเซิร์ฟเวอร์ SSE
asyncapi.sse.kafka.proxy สตรีมข้อความที่เผยแพร่ไปยังหัวข้อ Kafka ผ่าน SSE
tcp.เอคโค่ ไบต์ Echoes ที่ส่งไปยังเซิร์ฟเวอร์ TCP
tcp.reflect ไบต์ Echoes ที่ส่งไปยังเซิร์ฟเวอร์ TCP ซึ่งออกอากาศไปยังไคลเอนต์ TCP ทั้งหมด
tls.เอคโค่ ไบต์ที่เข้ารหัส Echoes ส่งไปยังเซิร์ฟเวอร์ TLS
tls.สะท้อน ไบต์ที่เข้ารหัส Echoes ส่งไปยังเซิร์ฟเวอร์ TLS ซึ่งออกอากาศไปยังไคลเอนต์ TLS ทั้งหมด
http.ระบบไฟล์ ให้บริการไฟล์จากไดเร็กทอรีบนระบบไฟล์โลคัล
http.filesystem.config.server ให้บริการไฟล์จากไดเร็กทอรีบนระบบไฟล์ในเครื่อง โดยรับการกำหนดค่าจากเซิร์ฟเวอร์ http
http.เอคโค่ คำขอ Echoes ส่งไปยังเซิร์ฟเวอร์ HTTP จากไคลเอนต์ HTTP
http.echo.jwt คำขอ Echoes ส่งไปยังเซิร์ฟเวอร์ HTTP จากไคลเอ็นต์ HTTP ที่ได้รับอนุญาตจาก JWT
http.พร็อกซี คำขอพร็อกซีส่งไปยังเซิร์ฟเวอร์ HTTP จากไคลเอ็นต์ HTTP
http.proxy.schema.inline คำขอพร็อกซีส่งไปยังเซิร์ฟเวอร์ HTTP จากไคลเอนต์ HTTP ที่มีการบังคับใช้สคีมา
http.kafka.sync เชื่อมโยงคำขอ HTTP และการตอบกลับในหัวข้อ Kafka ที่แยกจากกัน
http.kafka.async เชื่อมโยงคำขอ HTTP และการตอบกลับในหัวข้อ Kafka ที่แยกจากกันแบบอะซิงโครนัส
http.kafka.cache ให้บริการการตอบกลับที่แคชไว้จากหัวข้อ Kafka ตรวจจับเมื่อมีการอัปเดต
http.kafka.oneway ส่งข้อความถึงหัวข้อคาฟคา ยิงแล้วลืม
http.kafka.crud เปิดเผย REST API ด้วยการดำเนินการ CRUD โดยที่หัวข้อ Kafka ที่บีบอัดบันทึกทำหน้าที่เป็นตาราง
http.kafka.sasl.scram ส่งข้อความไปยัง Kafka ที่เปิดใช้งาน SASL/SCRAM
http.kafka.karapace ตรวจสอบข้อความขณะผลิตและดึงข้อมูลไปยังหัวข้อ Kafka
http.redpanda.sasl.scram ส่งข้อความไปยังคลัสเตอร์ Redpanda ที่เปิดใช้งาน SASL/SCRAM
kubernetes.prometheus.autoscale คุณลักษณะการปรับขนาดอัตโนมัติ Pod แนวนอนของ Kubernetes สาธิตโดยอิงตามตัววัดที่กำหนดเองด้วย Prometheus
grpc.echo สะท้อนข้อความที่ส่งไปยังเซิร์ฟเวอร์ gRPC จากไคลเอ็นต์ gRPC
grpc.kafka.echo ข้อความสะท้อนที่ส่งไปยังหัวข้อ Kafka ผ่าน gRPC จากไคลเอนต์ gRPC
grpc.kafka.fanout สตรีมข้อความที่เผยแพร่ในหัวข้อ Kafka โดยใช้การรวมตามการบีบอัดบันทึก
grpc.kafka.proxy เชื่อมโยงคำขอและการตอบกลับ gRPC ในหัวข้อ Kafka ที่แยกจากกัน
grpc.proxy คำขอและการตอบกลับ gRPC ของพร็อกซีที่ส่งไปยังเซิร์ฟเวอร์ gRPC จากไคลเอ็นต์ gRPC
amqp.reflect Echoes ข้อความที่เผยแพร่ไปยังเซิร์ฟเวอร์ AMQP ซึ่งออกอากาศไปยังไคลเอนต์ AMQP ที่ได้รับทั้งหมด
mqtt.kafka.broker ส่งต่อ MQTT เผยแพร่ข้อความไปยัง Kafka โดยออกอากาศไปยังไคลเอนต์ MQTT ที่สมัครเป็นสมาชิกทั้งหมด
mqtt.kafka.broker.jwt ส่งต่อ MQTT เผยแพร่ข้อความไปยัง Kafka ออกอากาศไปยังไคลเอนต์ MQTT ที่ได้รับอนุญาตจาก JWT ที่สมัครเป็นสมาชิกทั้งหมด
เริ่มต้นอย่างรวดเร็ว เริ่มจุดสิ้นสุดสำหรับโปรโตคอลทั้งหมด (HTTP, SSE, gRPC, MQTT)
sse.kafka.fanout สตรีมข้อความที่เผยแพร่ในหัวข้อ Kafka โดยใช้การรวมตามการบีบอัดบันทึก
sse.proxy.jwt ข้อความพร็อกซีที่ส่งโดยเซิร์ฟเวอร์ SSE บังคับใช้ข้อจำกัดด้านความปลอดภัยในการสตรีม
ws.เอคโค่ ข้อความสะท้อนที่ส่งไปยังเซิร์ฟเวอร์ WebSocket
ws.สะท้อน ข้อความสะท้อนที่ส่งไปยังเซิร์ฟเวอร์ WebSocket ซึ่งเผยแพร่ไปยังไคลเอนต์ WebSocket ทั้งหมด

อ่านเอกสาร ลองตัวอย่าง เข้าร่วมชุมชน Slack

ขยาย
ข้อมูลเพิ่มเติม
แอปที่เกี่ยวข้อง
แนะนำสำหรับคุณ
ข้อมูลที่เกี่ยวข้อง ทั้งหมด