Awesome GitHub RepositoriesTopic-Based Messaging

uWebSockets is a C++ networking framework that serves as a high-performance WebSocket server library, HTTP web server, and pub-sub messaging system. It provides the infrastructure necessary to handle standard web requests and maintain low-latency, bidirectional connections between clients and servers. The framework is distinguished by its use of template meta-programming for compile-time optimization and zero-copy buffer management to minimize memory latency. It utilizes a backend-agnostic event loop and static route resolution to process network traffic with minimal runtime overhead. The pr

Mosquitto هو وسيط رسائل MQTT وخادم مراسلة لإنترنت الأشياء (IoT) مصمم لتوجيه البيانات بين الناشرين والمشتركين. يعمل كمركز شبكة مركزي يتيح التواصل الخفيف بين المستشعرات الموزعة، وأجهزة التحكم، وأجهزة إنترنت الأشياء الأخرى. يتضمن المشروع بوابة جسر MQTT تُستخدم لربط الوسطاء المنفصلين، مما يسمح بتوجيه حركة المرور ومزامنتها عبر مواقع شبكة أو مناطق أمان مختلفة. كما يوفر تنفيذاً للعميل للاتصال بالوسيط والتفاعل معه. يدير النظام توجيه الرسائل القائم على المواضيع وتبادلات النشر/الاشتراك، مدعوماً بالتحكم في الوصول إلى الوسيط والمصادقة. ويتضمن قدرات لاستمرارية البيانات لاستعادة الحالة بعد إعادة التشغيل وواجهة قائمة على الويب لإدارة ومراقبة الوسيط.

ipfs-desktop is a graphical application for managing a local IPFS node, hosting content, and interacting with the peer-to-peer network. It serves as a desktop client that provides a visual interface for content-addressed storage management, peer-to-peer file sharing, and the administration of the node lifecycle. The project differentiates itself by providing a comprehensive suite of controllers for node health, gateway routing, and static site hosting. It includes a dedicated content-addressed storage browser for importing and organizing files, a gateway controller to route network content th

This project provides a technical specification and reference manual for the MQTT 3.1.1 standard, serving as a translated Chinese guide for implementing this lightweight IoT messaging protocol in resource-constrained device networks. The documentation covers the fundamental mechanisms of the publish-subscribe model, including topic-based routing with wildcard filtering, retained message storage, and the configuration of last will and testament messages. It details the protocol's approach to reliability through various quality of service levels, ranging from single-level acknowledgments to exa

Pushdeer هي خدمة إشعارات دفع مستضافة ذاتيًا مصممة لتقديم تنبيهات فورية للأجهزة المحمولة وأجهزة IoT. تعمل كخلفية مركزية لإدارة وتوجيه الإشعارات المخصصة عبر خادم خاص. يتميز النظام بقدرته على إرسال إشعارات الدفع بدون تطبيق (Appless)، والتي تستفيد من ميزات نظام التشغيل الأصلي لتلقي التنبيهات دون الحاجة إلى تطبيق عميل مخصص مثبت على الهاتف. بالنسبة لتكامل IoT، تعمل كبوابة مراسلة باستخدام بروتوكول MQTT لإرسال إشعارات نصية وصورية في الوقت الفعلي إلى الأجهزة الذكية. تتضمن المنصة مجموعة إدارة شاملة لمفاتيح API ورموز تسجيل الأجهزة لتأمين خط أنابيب الإشعارات. تدعم إعادة توجيه الإشعارات الخارجية من منصات الطرف الثالث عبر تنسيقات JSON مخصصة وتوفر توجيهًا قائمًا على المواضيع لتوجيه أنواع محتوى معينة إلى أجهزة مستهدفة. تشمل القدرات الخاصة بالأجهزة عرض الصور على شاشات الأجهزة، ومزامنة وقت الشبكة، والقدرة على إطلاق تنبيهات مادية مثل الطنانات. يتم توفير الخلفية كبيئة حاوية مصممة للنشر باستخدام Docker و Compose.

MQTTnet هي مكتبة .NET توفر إطار عمل لتنفيذ عملاء ووسطاء MQTT. تتضمن تنفيذ وسيط لاستضافة مركز رسائل مركزي يوجه الرسائل بين العملاء المتصلين، ومكتبة عميل لنشر الرسائل والاشتراك فيها. يدعم المشروع طبقات نقل TCP و WebSocket، مما يتيح حركة بيانات آمنة من خلال أمان طبقة النقل. يسمح بتطوير برمجيات وسيطة (Middleware) مخصصة لاعتراض الرسائل أو تحويلها أو التحقق منها أثناء مرورها عبر الخادم. تشمل مجالات القدرات توجيه الرسائل الموزعة، وإدارة الاتصال المستمر مع طوابير جودة الخدمة، وأساسيات الأمان للتحقق من بيانات اعتماد العميل وقيود الاشتراك في المواضيع.

Console هي أداة إدارة تعتمد على الويب لمراقبة وإدارة مجموعات Kafka. توفر واجهة رسومية لإدارة المواضيع (topics)، ومجموعات المستهلكين، وتدفقات البيانات في الوقت الفعلي. يتضمن المشروع مديرين مخصصين لـ Kafka Connect و Schema Registry، مما يسمح بنشر موصلات البيانات وحوكمة مخططات البيانات. يتميز بلوحة تحكم للمجموعة لتتبع صحة الوسطاء (brokers)، واستخدام التخزين، وحالة الرفوف، إلى جانب واجهة للتحكم في الوصول القائم على الأدوار وفحص سجلات التدقيق. تغطي المنصة تصفح البيانات وتصفيتها، وتنسيق مجموعات المستهلكين، وبناء خطوط أنابيب البيانات. كما تدعم مراقبة مهام تحويل البيانات وإدارة أذونات المستخدم عبر محرك سياسات مركزي.

embedded-notes هي مجموعة من أدلة الدراسة التقنية وملاحظات التطوير التي تركز على Linux المضمن، وداخلية نواة Linux، وبرمجة C. تعمل كمرجع لتطوير الأنظمة المضمنة ومورد تحضيري للمقابلات التقنية في هذا المجال. يوفر المشروع وثائق مفصلة حول كتابة برامج تشغيل الأجهزة، وإدارة الذاكرة الافتراضية، وفهم داخلية النواة. كما يتضمن أدلة حول بروتوكولات شبكة IoT، مثل MQTT وTCP/IP، ويحدد التفاصيل المعمارية لهياكل الرقائق والأجهزة الطرفية. تغطي المادة سطحاً واسعاً من برمجة الأنظمة، بما في ذلك إدارة الذاكرة اليدوية، وإدارة دورة حياة العمليات، وتنفيذ مفاهيم نظام التشغيل في الوقت الفعلي. كما تتضمن مراجع للأدوات منخفضة المستوى، مثل التجميع المتقاطع لـ ARM، وتحليل الثنائيات، وكتابة نصوص shell لأتمتة البناء.

MQTT-Explorer هي أداة تصور وتصحيح أخطاء لوسطاء MQTT. توفر واجهة قائمة على الويب لفحص حركة الرسائل في الوقت الفعلي وتحليل هياكل المواضيع من خلال متصفح هرمي. تنظم الأداة الرسائل الواردة في هيكل شجري متداخل لتبسيط مراقبة تدفقات البيانات ونشاط الوسيط. وتتضمن لوحة تحكم صديقة للهواتف المحمولة مع تخطيطات وأنماط تفاعل محسنة لمراقبة حالة الوسيط على أجهزة اللمس. يدعم التطبيق تصحيح أخطاء أجهزة إنترنت الأشياء وإدارة شبكات MQTT. ويوفر إمكانيات لتصور حركة المرور، ومراقبة الوسيط، وفحص الحمولة. يمكن استخدام البرنامج كخدمة ويب يمكن الوصول إليها عبر المتصفح أو كتطبيق سطح مكتب.

هذا المشروع عبارة عن مكتبة C متعددة المنصات مصممة لتنفيذ مراسلات MQTT في التطبيقات. تعمل كمجموعة أدوات شبكات غير متزامنة تتيح للأنظمة ذات الموارد المحدودة والمكونات الموزعة تبادل بيانات القياس عن بعد وإشارات التحكم مع وسطاء المراسلة. تتميز المكتبة بمعالج بروتوكول قائم على آلة الحالة (state-machine) يدير دورات حياة الاتصال وحالات الجلسة المستمرة، مما يضمن تسليم الرسائل بشكل موثوق حتى أثناء اتصال الشبكة المتقطع. تستخدم المكتبة خيط معالجة خلفي لإدارة عمليات الشبكة، مما يسمح للتطبيقات بالحفاظ على الاستجابة من خلال نظام إشعارات قائم على الاستدعاءات (callback-driven). علاوة على ذلك، تتميز المكتبة بتجريد نقل قابل للتوصيل يدعم قنوات اتصال متنوعة، بما في ذلك TCP، وTLS، وWebSockets، من خلال واجهة اتصال موحدة قائمة على URI. يوفر البرنامج مجموعة شاملة من قدرات المراسلة، بما في ذلك مستويات جودة الخدمة القابلة للتكوين، والنشر والاشتراك القائم على الموضوع، والقدرة على إرفاق بيانات وصفية بالرسائل. كما يدمج تتبع التشخيص وسجل تنفيذ وقت التشغيل للمساعدة في مراقبة نشاط الشبكة وتصحيح انتقالات البروتوكول.

Js-csp is a concurrency library that implements communicating sequential processes with channels and generator-based routines for asynchronous programming in JavaScript. It provides a framework for building data processing pipelines and managing concurrent workflows, bringing Go-style channels and process coordination primitives to applications. The library coordinates message passing through buffered channels, stream mixing, multi-channel selection, and pub-sub broadcasting. Communication pathways support unbuffered rendezvous, fixed buffers, sliding windows, and dropping overflow. Operation

هذا المشروع عبارة عن مجموعة تطوير برمجيات (SDK) للمراسلة بلغة Java مصممة لتسهيل تبادل البيانات في الوقت الفعلي بين التطبيقات ووسطاء الرسائل. تعمل كمكتبة عميل MQTT، وتوفر الأدوات اللازمة لتنفيذ أنماط مراسلة النشر والاشتراك داخل الأنظمة الموزعة وبيئات الأجهزة المتصلة بالإنترنت. تتميز المكتبة بتركيزها على اتصال الشبكة المرن وتسليم الرسائل الموثوق. تدير المكتبة الاتصالات المستمرة من خلال آلات حالة داخلية تتعامل مع إعادة الاتصال التلقائي ونبضات القلب (keep-alive)، مما يضمن الاستقرار في البيئات ذات الوصول المتقطع للشبكة. يمكن للتطبيقات تكوين مستويات محددة من جودة الخدمة لضمان سلامة البيانات، بدءاً من الإرسال والنسيان (fire-and-forget) وصولاً إلى التسليم لمرة واحدة بالضبط، واستخدام تكوينات الوصية الأخيرة (last-will-and-testament) لإدارة انقطاع اتصال العميل غير المتوقع. يدعم إطار العمل معالجة البيانات ذات الحجم الكبير باستخدام بدائيات اتصال غير متزامنة وغير محظورة. يتيح إطار العمل للمطورين توجيه الرسائل من خلال اشتراكات قائمة على الموضوع، بما في ذلك دعم أنماط البدل (wildcard)، مع تتبع تقدم العمليات الفردية من خلال مقابض قائمة على الرموز. يتم توزيع المكتبة كمجموعة تطوير Java قياسية للدمج في البنية التحتية الأوسع للمراسلة وIoT.