Ticketing Javascript / Typescript مكتبة
GitHub npmالمستودع
bash
bash
bash
مثال
مثال أساسي
أنشئ broker واحدًا عند بدء التطبيق وشاركه. wait=0 محاولة فورية واحدة بلا queue، والحد 255 ثانية؛ lease بين 1 و250 ثانية. آخر minimum-work budget إلزامي وقد يكون صفرًا. تُقرب كسور الثانية إلى الأعلى، وتُرفض القيم خارج المجال أو budget أكبر من lease بعد التطبيع قبل الإرسال، بلا clamp.
ts
import { TicketBroker } from 'saro-ticketing'
const broker = TicketBroker.connect('127.0.0.1:5225')
await broker.waitReady(5)
const ticket = await broker.acquire('key', 5, 30, 2)
const token = ticket.token
// In the same DB transaction: verify/update token high-water and perform the business write.
await ticket.release()الـclose/drop التلقائي release محدود best-effort. استخدم explicit release API إذا كانت النتيجة مهمة. يجب أن يعمل token كـfencing للـDB write المحمي في transaction نفسها.
سلوك يجدر معرفته
- إذا أمكن إرسال request byte واحد، فضياع الاستجابة النهائية ينتج Indeterminate. لا إعادة تلقائية لـ
Aبالـowner نفسه؛ ولا يدخل caller الـcritical section. - Cancel قبل send هو unsent؛ وبعد possible-send يغلق session. إن parsed grant token بالتزامن، يحاول compensating exact-token release محدودًا.
MوكلEوالاستجابة malformed/oversized/unknown هي session-fatal. يصبح acquire possible-send غير المحسوم Indeterminate.Bرفض capacity مؤكد ويعود فورًا. لا retry داخلي؛ يستطيع caller بدء acquire جديد بـowner جديد بعد application backoff.- يحاول explicit/compensating release الـexact token فقط خلال 5 ثوان مطلقة من call/enqueue.
Rنجاح،Nabsent/not current؛ غياب استجابة نهائية error لا نجاح مفترض. - لا يُعاد Ticket إلا مع زمن محافظ موجب يكفي work budget. العمل فوق 250 ثانية unsupported قبل الإرسال.
- Token DB fencing إلزامي: في transaction نفسها ارفض
token <= stored_high_water، وحدّث high-water ونفذ business write قبل commit/rollback ثم release.
خيارات الأمان (رمز · TLS)
جميع الخيارات اختيارية. يجب أن يطابق token قيمة client_tokens في الخادم، ولـ TLS أربعة أنماط: إيقاف / مخزن الثقة الافتراضي للنظام / CA محدد / تخطي التحقق (للاختبار فقط).
ts
const broker = new TicketBroker({
addrs: ['10.0.0.1:5225', '10.0.0.2:5225', '10.0.0.3:5225'],
token: '123',
tls: 'system-roots', // 'off' | 'system-roots' | 'insecure-skip-verify' | { ca: 'ca.crt' }
})يمكنك إنشاء إعدادات الرمز وTLS والعنقود على صفحة نشر خادم Ticketing.