106 Repositories
Java distributed-messaging Libraries
📬Zola (Extremely) Simple Message Queue for spring, It is the simplest Message Queue you've ever experienced.
It is the simplest Message Queue you've ever experienced. home (engish version) korean version docs 📗 Getting Started || Overview || Docs ZSMQ ZSMQ (
The repository is created to showcase examples of microservices patterns using different technologies.
Repository Objective The goal of this repository is to demonstrate coding examples in different languages mainly Java and .NET core. These examples wi
Console-based real-time messaging platform.
Concord NOTE: To improve organization, Concord has been moved to the Concord Communication GitHub organization. Open-source, independent, real-time me
HurricaneDB a real-time distributed OLAP engine, powered by Apache Pinot
HurricaneDB is a real-time distributed OLAP datastore, built to deliver scalable real-time analytics with low latency. It can ingest from batch data sources (such as Hadoop HDFS, Amazon S3, Azure ADLS, Google Cloud Storage) as well as stream data sources (such as Apache Kafka).
PolarDB-X is a cloud native distributed SQL Database designed for high concurrency, massive storage, complex querying scenarios.
中文文档 What is PolarDB-X ？ PolarDB-X is a cloud native distributed SQL Database designed for high concurrency, massive storage and complex querying scen
Distributed id generator application
Java distributed Unique ID generator inspired by Twitter snowflake You can read about Twitter snowflake here. The IDs are 64-bits in size and are gene
OwlGram is an unofficial messaging app that uses Telegram's API.
🦉 OwlGram OwlGram is an unofficial messaging app that uses Telegram's API. 🛠 About Reproducible Builds To reproduce the build of OwlGram is only nee
An Open-Source, Distributed MQTT Broker for IoT.
简体中文 | English MMQ broker MMQ broker 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。 MMQ broker 完整支持MQTT V3.1 和 V3.1.1。 特征 分布式MQTT服务 万级连接数并发（3台
The Distributed Application Runtime (Dapr) provides APIs that simplify microservice connectivity
Quarkus - Dapr Introduction What is Quarkus? Traditional Java stacks were engineered for monolithic applications with long startup times and large mem
Distributed Systems Assignment 1
DSYS_A1 Distributed Systems Assignment 1 The application that I have decided to have as my assignment is a testing application. The supervisor server
Distributed WebSocket Server
Keeper 分布式 WebSocket 服务器。 注意事项 IO 线程和业务线程分离：对于小业务，依旧放到 worker 线程中处理，对于需要和中间件交互的丢到业务线程池处理，避免 worker 阻塞。 WebSocket 握手阶段支持参数列表。 插件 本服务功能插件化。
[Nelson] Microservices and Distributed Systems [ENG, 2022]
![[Nelson] Microservices and Distributed Systems [ENG, 2022]](https://github.com/webmakaka/Microservices-and-Distributed-Systems/raw/master/img/pic-01-diagram.png?raw=true)
[Nelson] Microservices and Distributed Systems [ENG, 2022] Course
A small Private Messaging Minecraft Plugin
Project PM is a Private Messaging system Mini-Plugin Description 👀 This is a test plugin, meaning I didn't really intend it for the public use, the "
This project is a simple messaging application made using React-Native framework, Gifted-Chat library and Firebase database
This project is a simple messaging application made using React-Native framework, Gifted-Chat library and Firebase database. The example that will be shown here focuses on the ability of two people to message each other in a chat room.
Flights metasearch engine simulation using Java, GraphQL and React.js, developed for COMP30220 Distributed Systems.
Distributed Airways For the full project report, see ./report.pdf. A demonstration video is available here. Requirements Docker JDK 8 and Apache Maven
Distributed, masterless, high performance, fault tolerant data processing
Onyx What is it? a masterless, cloud scale, fault tolerant, high performance distributed computation system batch and stream hybrid processing model e
Nacos: Dynamic Naming and Configuration Service
An easy-to-use dynamic service discovery, configuration and service management platform for building cloud native applications.
A fault tolerant, protocol-agnostic RPC system
Finagle Status This project is used in production at Twitter (and many other organizations), and is being actively developed and maintained. Releases
Cadence is a distributed, scalable, durable, and highly available orchestration engine to execute asynchronous long-running business logic in a scalable and resilient way.
Cadence This repo contains the source code of the Cadence server and other tooling including CLI, schema tools, bench and canary. You can implement yo
Apache Mesos is a cluster manager that provides efficient resource isolation and sharing across distributed applications, or frameworks
Apache Mesos is a cluster manager that provides efficient resource isolation and sharing across distributed applications, or frameworks. It can run Hadoop, Jenkins, Spark, Aurora, and other frameworks on a dynamically shared pool of nodes.
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
Temporal is a microservice orchestration platform which enables developers to build scalable applications
Temporal is a microservice orchestration platform which enables developers to build scalable applications without sacrificing productivity or reliability. Temporal server executes units of application logic, Workflows, in a resilient manner that automatically handles intermittent failures, and retries failed operations.
Apache Drill is a distributed MPP query layer for self describing data
Apache Drill Apache Drill is a distributed MPP query layer that supports SQL and alternative query languages against NoSQL and Hadoop data storage sys
Distributed Tracing, Metrics and Context Propagation for application running on the JVM
Kamon Kamon is a set of tools for instrumenting applications running on the JVM. The best way to get started is to go to our official Get Started Page
A scalable, mature and versatile web crawler based on Apache Storm
StormCrawler is an open source collection of resources for building low-latency, scalable web crawlers on Apache Storm. It is provided under Apache Li
Spark-Crawler: Apache Nutch-like crawler that runs on Apache Spark.
Sparkler A web crawler is a bot program that fetches resources from the web for the sake of building applications like search engines, knowledge bases
Framework for automated integration tests with focus on messaging integration
Citrus Integration Testing Welcome to Citrus Citrus is a test framework written in Java that is able to create fully automated end-to-end use case tes
Lightweight service-based PubSub, RPC and public APIs in Java
kite - service-based RPC, public APIs and PubSub in Java kite is a collection of reactive application messaging libraries that aim at providing high l
Distributed-messenger - 👨👨👧 Sistema de chat utilizando sockets desenvolvido para a disciplina de Sistemas Paralelos e Distribuídos
Distributed Messenger 👨👨👧 Sistema de chat utilizando sockets desenvolvido para a disciplina de Sistemas Paralelos e Distribuídos Requisitos do Pr
SeaTunnel is a distributed, high-performance data integration platform for the synchronization and transformation of massive data (offline & real-time).
SeaTunnel SeaTunnel was formerly named Waterdrop , and renamed SeaTunnel since October 12, 2021. SeaTunnel is a very easy-to-use ultra-high-performanc
Apollo is a reliable configuration management system suitable for microservice configuration management scenarios.
English | 中文 Apollo - A reliable configuration management system Apollo is a reliable configuration management system. It can centrally manage the con
Spring Cloud Alibaba provides a one-stop solution for application development for the distributed solutions of Alibaba middleware.
Spring Cloud Alibaba A project maintained by Alibaba. See the 中文文档 for Chinese readme. Spring Cloud Alibaba provides a one-stop solution for distribut
A distributed task scheduling framework
XXL-JOB XXL-JOB, a distributed task scheduling framework. -- Home Page -- Introduction XXL-JOB is a distributed task scheduling framework. It's core d
APM, Application Performance Monitoring System
Apache SkyWalking SkyWalking: an APM(application performance monitor) system, especially designed for microservices, cloud native and container-based
Spring Boot microservices app with Spring Cloud, Robust and resilient backend managing e-Commerce app
e-Commerce-boot μServices Important Note: This project's new milestone is to move The whole system to work on Kubernetes, so stay tuned. Introduction
Apache Pinot - A realtime distributed OLAP datastore
What is Apache Pinot? Features When should I use Pinot? Building Pinot Deploying Pinot to Kubernetes Join the Community Documentation License What is
A scalable, distributed Time Series Database.
___ _____ ____ ____ ____ / _ \ _ __ ___ _ _|_ _/ ___|| _ \| __ ) | | | | '_ \ / _ \ '_ \| | \___ \| | | | _ \
Build criterion and ecosystem above multi-model databases
ShardingSphere - Building a Criterion and Ecosystem Above Multi-Model Databases Official Website: https://shardingsphere.apache.org/ Stargazers Over T
Running compute-intense parts of BigStitcher distributed
BigStitcher-Spark Running compute-intense parts of BigStitcher distributed. For now we support fusion with affine transformation models (including tra
A distributed lock that supports the use of Redis and Zookeeper, out of the box, fast and easy to use
lock-spring-boot-starter A distributed lock that supports the use of Redis and Zookeeper, out of the box, fast and easy to use 一款基于 Redis 和 Zookeeper
🕊️ The world's most advanced open source instant messaging engine for 100K~10M concurrent users https://turms-im.github.io/docs
简体中文 What is Turms Turms is the most advanced open-source instant messaging engine for 100K~10M concurrent users in the world. Please refer to Turms D
Microservice-based online payment system for customers and merchants using RESTful APIs and message queues
Microservice-based online payment system for customers and merchants using RESTful APIs and message queues
Carbyne Stack secret sharing distributed object store
Carbyne Stack Amphora Secret Share Store Amphora is an open source object store for secret shared data and part of Carbyne Stack. DISCLAIMER: Carbyne
Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low latency stream processing and data analysis framework. Milliseconds latency and 10+ times faster than Flink for complicated use cases.
Table-Computing Welcome to the Table-Computing GitHub. Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low la
A lightweight messaging library that simplifies the development and usage of RabbitMQ with the AMQP protocol.
kryo-messaging This library contains a simple MessagingService which simplifies the setup and work with RabbitMQ and the AMQP protocol. Usage Gradle r
The Java agent for Apache SkyWalking
Apache SkyWalking Java Agent SkyWalking-Java: The Java Agent for Apache SkyWalking, which provides the native tracing/metrics/logging abilities for Ja
An Open-Source, Distributed MQTT Message Broker for IoT.
MMQ broker MMQ broker 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。 MMQ broker 完整支持MQTT V3.1 和 V3.1.1。 安装 MMQ broker 是跨平台的，支持 Linux、Unix、macOS
Universal, flexible, high-performance distributed ID generator
CosId Universal, flexible, high-performance distributed ID generator 中文文档 Introduction CosId aims to provide a universal, flexible and high-performanc
Kong agent for Apache SkyWalking
Apache SkyWalking Kong Agent SkyWalking Kong agent built on SkyWalking Nginx Lua agent to trace Kong API gateway for Apache SkyWalking APM. Usage Inst
Free implementation of Play Services
microG GmsCore is a FLOSS (Free/Libre Open Source Software) framework to allow applications designed for Google Play Services to run on systems, where Play Services is not available.
OpenSearch is an open source distributed and RESTful search engine.
OpenSearch is an open source search and analytics engine derived from Elasticsearch
Publish Jenkins performances metrics to an OpenTelemetry endpoint, including distributed traces of job executions and health metrics of the controller.
OpenTelemetry Introduction Architecture Features Getting Started Examples Configuration as Code Contributing Introduction Collect Jenkins monitoring d
Java implementation of Condensation - a zero-trust distributed database that ensures data ownership and data security
Java implementation of Condensation About Condensation enables to build modern applications while ensuring data ownership and security. It's a one sto
基于 springboot websocket 的群聊实现
基于 springboot websocket 的群聊实现 功能列表 分布式 同一帐号多设备登录 群聊 多设备 简单鉴权 心跳检查 依赖 maven jdk11 redis redis 配置 redis 默认使用 localhost:6379。如果需要修改 host:port，可以修改 applic
A strongly consistent distributed transaction framework
A strongly consistent distributed transaction framework
Financial-level flexible distributed transaction solution
Financial-level flexible distributed transaction solution
APM, (Application Performance Management) tool for large-scale distributed systems.
Visit our official web site for more information and Latest updates on Pinpoint. Latest Release (2020/01/21) We're happy to announce the release of Pi
dynamic datasource for springboot 多数据源 动态数据源 主从分离 读写分离 分布式事务
一个基于springboot的快速集成多数据源的启动器 简介 dynamic-datasource-spring-boot-starter 是一个基于springboot的快速集成多数据源的启动器。 其支持 Jdk 1.7+, SpringBoot 1.4.x 1.5.x 2.x.x。 文档 | D
Distributed scheduled job framework
ElasticJob - distributed scheduled job solution Official website: https://shardingsphere.apache.org/elasticjob/ ElasticJob is a distributed scheduling
A high available,high performance distributed messaging system.
#新闻 MetaQ 1.4.6.2发布。更新日志 MetaQ 1.4.6.1发布。更新日志 MetaQ 1.4.5.1发布。更新日志 MetaQ 1.4.5发布。更新日志 Meta-ruby 0.1 released: a ruby client for metaq. SOURCE #介绍 Meta
High Performance Inter-Thread Messaging Library
LMAX Disruptor A High Performance Inter-Thread Messaging Library Maintainer LMAX Development Team Support Open a ticket in GitHub issue tracker Google
The official home of the Presto distributed SQL query engine for big data
Presto Presto is a distributed SQL query engine for big data. See the User Manual for deployment instructions and end user documentation. Requirements
A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.
Apache Gobblin Apache Gobblin is a highly scalable data management solution for structured and byte-oriented data in heterogeneous data ecosystems. Ca
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
Heron is a realtime analytics platform developed by Twitter. It has a wide array of architectural improvements over it's predecessor. Heron in Apache
Netflix's distributed Data Pipeline
Suro: Netflix's Data Pipeline Suro is a data pipeline service for collecting, aggregating, and dispatching large volume of application events includin
Distributed and fault-tolerant realtime computation: stream processing, continuous computation, distributed RPC, and more
IMPORTANT NOTE!!! Storm has Moved to Apache. The official Storm git repository is now hosted by Apache, and is mirrored on github here: https://github
H2O is an Open Source, Distributed, Fast & Scalable Machine Learning Platform: Deep Learning, Gradient Boosting (GBM) & XGBoost, Random Forest, Generalized Linear Modeling (GLM with Elastic Net), K-Means, PCA, Generalized Additive Models (GAM), RuleFit, Support Vector Machine (SVM), Stacked Ensembles, Automatic Machine Learning (AutoML), etc.
H2O H2O is an in-memory platform for distributed, scalable machine learning. H2O uses familiar interfaces like R, Python, Scala, Java, JSON and the Fl
Micro second messaging that stores everything to disk
Chronicle Queue Contents Table of Contents Contents About Chronicle Software What is Chronicle Queue Java Docs Usage More benchmarks Downloading Chron
Zipkin is a distributed tracing system
zipkin Zipkin is a distributed tracing system. It helps gather timing data needed to troubleshoot latency problems in service architectures. Features
Chaos engineering tool for simulating real-world distributed system failures
Proxy for simulating real-world distributed system failures to improve resilience in your applications. Introduction Muxy is a proxy that mucks with y
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
A scalable, distributed Time Series Database.
___ _____ ____ ____ ____ / _ \ _ __ ___ _ _|_ _/ ___|| _ \| __ ) | | | | '_ \ / _ \ '_ \| | \___ \| | | | _ \
Micro second messaging that stores everything to disk
Chronicle Queue Contents Table of Contents Contents About Chronicle Software What is Chronicle Queue Java Docs Usage More benchmarks Downloading Chron
A distributed in-memory data store for the cloud
EVCache EVCache is a memcached & spymemcached based caching solution that is mainly used for AWS EC2 infrastructure for caching frequently used data.
CrateDB is a distributed SQL database that makes it simple to store and analyze massive amounts of machine data in real-time.
About CrateDB is a distributed SQL database that makes it simple to store and analyze massive amounts of machine data in real-time. CrateDB offers the
OrientDB is the most versatile DBMS supporting Graph, Document, Reactive, Full-Text, Geospatial and Key-Value models in one Multi-Model product. OrientDB can run distributed (Multi-Master), supports SQL, ACID Transactions, Full-Text indexing and Reactive Queries. OrientDB Community Edition is Open Source using a liberal Apache 2 license.
OrientDB | Develop branch: | 2.2.x branch: | Chat with the community: What is OrientDB? OrientDB is an Open Source Multi-Model NoSQL DBMS with the sup
The official home of the Presto distributed SQL query engine for big data
Presto Presto is a distributed SQL query engine for big data. See the User Manual for deployment instructions and end user documentation. Requirements
Activiti is a light-weight workflow and Business Process Management (BPM) Platform targeted at business people, developers and system admins. Its core is a super-fast and rock-solid BPMN 2 process engine for Java. It's open-source and distributed under the Apache license. Activiti runs in any Java application, on a server, on a cluster or in the cloud. It integrates perfectly with Spring, it is extremely lightweight and based on simple concepts.
Activiti Homepage: http://activiti.org Activiti is a light-weight workflow and Business Process Management (BPM) Platform targeted at business people,
A novel implementation of the Raft consensus algorithm
Copycat Copycat has moved! Copycat 2.x is now atomix-raft and includes a variety of improvements to Copycat 1.x: Multiple state machines per cluster M
Distributed Stream and Batch Processing
What is Jet Jet is an open-source, in-memory, distributed batch and stream processing engine. You can use it to process large volumes of real-time eve
Orbit - Virtual actor framework for building distributed systems
Full Documentation See the documentation website for full documentation, examples and other information. Orbit 1 Looking for Orbit 1? Visit the orbit1
Reactive Microservices for the JVM
Lagom - The Reactive Microservices Framework Lagom is a Swedish word meaning just right, sufficient. Microservices are about creating services that ar
Build highly concurrent, distributed, and resilient message-driven applications on the JVM
Akka We believe that writing correct concurrent & distributed, resilient and elastic applications is too hard. Most of the time it's because we are us
APM, (Application Performance Management) tool for large-scale distributed systems.
Visit our official web site for more information and Latest updates on Pinpoint. Latest Release (2020/01/21) We're happy to announce the release of Pi
Redisson - Redis Java client with features of In-Memory Data Grid. Over 50 Redis based Java objects and services: Set, Multimap, SortedSet, Map, List, Queue, Deque, Semaphore, Lock, AtomicLong, Map Reduce, Publish / Subscribe, Bloom filter, Spring Cache, Tomcat, Scheduler, JCache API, Hibernate, MyBatis, RPC, local cache ...
Redisson - Redis Java client with features of In-Memory Data Grid Quick start | Documentation | Javadocs | Changelog | Code examples | FAQs | Report a
Hystrix is a latency and fault tolerance library designed to isolate points of access to remote systems, services and 3rd party libraries, stop cascading failure and enable resilience in complex distributed systems where failure is inevitable.
Hystrix: Latency and Fault Tolerance for Distributed Systems Hystrix Status Hystrix is no longer in active development, and is currently in maintenanc
Free and Open, Distributed, RESTful Search Engine
Elasticsearch A Distributed RESTful Search Engine https://www.elastic.co/products/elasticsearch Elasticsearch is a distributed RESTful search engine b
Easy to use cryptographic framework for data protection: secure messaging with forward secrecy and secure data storage. Has unified APIs across 14 platforms.
Themis provides strong, usable cryptography for busy people General purpose cryptographic library for storage and messaging for iOS (Swift, Obj-C), An
APM, (Application Performance Management) tool for large-scale distributed systems.
Visit our official web site for more information and Latest updates on Pinpoint. Latest Release (2020/01/21) We're happy to announce the release of Pi
HornetQ is an open source project to build a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system.
HornetQ If you need information about the HornetQ project please go to http://community.jboss.org/wiki/HornetQ http://www.jboss.org/hornetq/ This file
Fast and reliable message broker built on top of Kafka.
Hermes Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and a
Mirror of Apache ActiveMQ Artemis
ActiveMQ Artemis This file describes some minimum 'stuff one needs to know' to get started coding in this project. Source For details about the modify
Apache Pulsar - distributed pub-sub messaging system
Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API. Learn more about Pulsar at https:
Java client for NATS
NATS - Java Client A Java client for the NATS messaging system. A Note on Versions This is version 2.x of the java-nats library. This version is a gro
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
Nakadi Event Broker Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues, which can be used
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
High Performance Inter-Thread Messaging Library
LMAX Disruptor A High Performance Inter-Thread Messaging Library Maintainer LMAX Development Team Support Open a ticket in GitHub issue tracker Google
Distributed lock for your scheduled tasks
ShedLock ShedLock makes sure that your scheduled tasks are executed at most once at the same time. If a task is being executed on one node, it acquire
:fire: Seata is an easy-to-use, high-performance, open source distributed transaction solution.
Seata: Simple Extensible Autonomous Transaction Architecture What is Seata? A distributed transaction solution with high performance and ease of use f
ScaleCube Services is a high throughput, low latency reactive microservices library built to scale. it features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)
scalecube-services MICROSERVICES 2.0 An open-source project that is focused on streamlining reactive-programming of Microservices Reactive-systems tha