50 Repositories
Java rocketmq-streams Libraries
Non-Blocking Reactive Foundation for the JVM
Reactor Core Non-Blocking Reactive Streams Foundation for the JVM both implementing a Reactive Extensions inspired API and efficient event streaming s
Acceso a Datos - 01 Streams, Ficheros y Expresiones Regulares. 2DAM. Curso 2021-2022
Acceso a Datos - 01 Streams, Ficheros y Expresiones Regulares Tema 01 Streams, Ficheros y Expresiones Regulares. 2DAM. Curso 2021/2022. Contenidos TDA
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
KC4Streams - a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces
KC4Streams (which stands for Kafka Commons for Streams) is a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces.
Microservices with Spring Boot and Kafka Demo Project
Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern
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
Reactive Streams Specification for the JVM
Reactive Streams The purpose of Reactive Streams is to provide a standard for asynchronous stream processing with non-blocking backpressure. The lates
A template and introduction for the first kafka stream application. The readme file contains all the required commands to run the Kafka cluster from Scrach
Kafka Streams Template Maven Project This project will be used to create the followings: A Kafka Producer Application that will start producing random
Akka gRPC - Support for building streaming gRPC servers and clients on top of Akka Streams.
akka-grpc Support for building streaming gRPC servers and clients on top of Akka Streams. This library is meant to be used as a building block in proj
A joint research effort for building highly optimized Reactive-Streams compliant operators.
reactive-streams-commons A joint research effort for building highly optimized Reactive-Streams compliant operators. Current implementors include RxJa
Standalone Play WS, an async HTTP client with fluent API
Play WS Standalone Play WS is a powerful HTTP Client library, originally developed by the Play team for use with Play Framework. It uses AsyncHttpClie
Beagle helps you identify keywords, phrases, regexes, and complex search queries of interest in streams of text documents.
Beagle Beagle is a detector of interesting things in text. Its intended use is in-stream search applications. Suppose you need to monitor a stream of
Querystream - Build JPA Criteria queries using a Stream-like API
QueryStream QueryStream allows you to perform JPA queries using a Stream-like API. Just like a Java 8 Stream, a QueryStream is built up in a pipeline,
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
Spring 5 Reactive playground
Spring Reactive Sample This is a sandbox project for demonstrating Reactive Streams support in Spring framework and Spring ecosystem. I've also mainta
source code of the live coding demo for "Building resilient and scalable API backends with Apache Pulsar and Spring Reactive" talk held at ApacheCon@Home 2021
reactive-iot-backend The is the source code of the live coding demo for "Building resilient and scalable API backends with Apache Pulsar and Spring Re
SpringBoot show case application for reactive-pulsar library (Reactive Streams adapter for Apache Pulsar Java Client)
Reactive Pulsar Client show case application Prerequisites Cloning reactive-pulsar Running this application requires cloning https://github.com/lhotar
The state-of-the-art Dashboard of Apache RoccketMQ provides excellent monitoring capability. Various graphs and statistics of events, performance and system information of clients and application is evidently made available to the user.
RocketMQ Dashboard How To Install With Docker get docker image mvn clean package -Dmaven.test.skip=true docker:build or docker pull apacherocketmq/ro
A practical example to showcase Redis Streams and RediSearch in action
Redis Streams in Action A practical example to showcase Redis Streams in action. The goal is to process Twitter data in real-time for search and query
Apache rocketmq
RocketMQ Streams Features 轻量级部署：可以单独部署，也支持集群部署 多种类型的数据输入以及输出，source支持 rocketmq ， sink支持db, rocketmq 等 DataStream Example import org.apache.rocketmq.st
mall4cloud微服务商城，基于Spring Cloud、Nacos、Seata、Mysql、Redis、RocketMQ、canal、ElasticSearch、minio的B2B2C微服务商城系统，采用主流的互联网技术架构、全新的UI设计 B2B2C微服务商城|小程序微服务商城|
README 前言 本商城是基于Spring Cloud、Nacos、Seata、Mysql、Redis、RocketMQ、canal、ElasticSearch、minio的微服务B2B2C电商商城系统，采用主流的互联网技术架构、全新的UI设计、支持集群部署、服务注册和发现以及拥有完整的订单流程等
RocketMQ-on-Pulsar - A protocol handler that brings native RocketMQ protocol to Apache Pulsar
RocketMQ on Pulsar(RoP) RoP stands for RocketMQ on Pulsar. Rop broker supports RocketMQ-4.6.1 protocol, and is backed by Pulsar. RoP is implemented as
Zero-dependency Reactive Streams publishers library
⚡️ Mutiny Zero: a zero-dependency Reactive Streams publishers library for Java Mutiny Zero is a minimal API for creating reactive-streams compliant pu
lilishop是采用JAVA开发的B2B2C多用户商城系统/电商系统/电子商务。基于当前流行技术组合的前后端分离商城系统：后端使用 SpringBoot、MybatisPlus、SpringSecurity、redis、ES、mysql、mongodb等主流技术，前端使用vue框架iview、uniapp。支持分布式部署，分布式事务，支持docker、k8s。商城支持 PC、WAP、H5、小程序、APP等各个客户端
Lilishop B2B2C商城系统 官方公众号 & 开源不易，如有帮助请点Star 介绍 官网：https://pickmall.cn Lilishop 是一款Java开发，基于SpringBoot研发的B2B2C多用户商城，前端使用 Vue、uniapp开发 系统全端全部代码开源 产品前后端分离
End to End project for Kafka Streams using Spring Cloud Kafka streams
Spring Kafka Streams using Spring Cloud Streams End to End example Endpoint http://localhost:8080/domain/lookup/facebook - to pull all facebook relate
结合应用场景介绍如何使用rocketmq，试图打造rocketmq领域最佳的入门示例，并包含40+篇原创博文、两本免费电子书。
rocketmq-learning 结合应用场景介绍如何使用rocketmq，试图打造rocketmq领域最佳的入门示例 代码介绍 代码组织将遵循功能，每一个功能都会结合具体使用场景。 transaction 事务消息发送。
Amazing Ruby's "Enumerable" ported to Java
Overview How to use? .all .any .none .select .map .count .reject .find How to contribute? Contributors Overview enumerable4j is a Ruby's well known En
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
友情提示：因为提供了 50000+ 行示例代码，所以艿艿默认注释了所有 Maven Module。 胖友可以根据自己的需要，修改 pom.xml 即可。 一个涵盖六个主流技术栈的正经仓库： 《Spring Boot 专栏》 《Spring Cloud Alibaba 专栏》 《Spring Clou
芋道 mall 商城，基于微服务的思想，构建在 B2C 电商场景下的项目实战。核心技术栈，是 Spring Boot + Dubbo 。未来，会重构成 Spring Cloud Alibaba 。
[toc] 友情提示：近期在升级和优化该项目，建议先 Star 本项目。主要在做几个事情： 1、微服务技术选型以 Spring Cloud Alibaba 为中心。 2、修改项目分层，并合并部分服务，简化整体服务的复杂性。 3、将管理后台从 React 重构到 Vue 框架。 交流群：传送门 前言
Reactive event streams, observable values and more for JavaFX.
ReactFX ReactFX is an exploration of (functional) reactive programming techniques for JavaFX. These techniques usually result in more concise code, le
SAMOA (Scalable Advanced Massive Online Analysis) is an open-source platform for mining big data streams.
SAMOA: Scalable Advanced Massive Online Analysis. This repository is discontinued. The development of SAMOA has moved over to the Apache Software Foun
Machine Learning Platform and Recommendation Engine built on Kubernetes
Update January 2018 Seldon Core open sourced. Seldon Core focuses purely on deploying a wide range of ML models on Kubernetes, allowing complex runtim
Proteus Java Client
Netifi Proteus Java This project has been moved to https://github.com/netifi/netifi-java Build from Source Run the following Gradle command to build t
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
Visit the official web site for more information. Armeria Build a reactive microservice at your pace, not theirs. Armeria is your go-to microservice f
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
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
RxJava: Reactive Extensions for the JVM RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-base
Reactive Streams Utilities - Future standard utilities library for Reactive Streams.
Reactive Streams Utilities This is an exploration of what a utilities library for Reactive Streams in the JDK might look like. Glossary: A short gloss
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
An advanced, but easy to use, platform for writing functional applications in Java 8.
Getting Cyclops X (10) The latest version is cyclops:10.4.0 Stackoverflow tag cyclops-react Documentation (work in progress for Cyclops X) Integration
jdbi is designed to provide convenient tabular data access in Java; including templated SQL, parameterized and strongly typed queries, and Streams integration
The Jdbi library provides convenient, idiomatic access to relational databases in Java. Jdbi is built on top of JDBC. If your database has a JDBC driv
A networking framework that evolves with your application
ServiceTalk ServiceTalk is a JVM network application framework with APIs tailored to specific protocols (e.g. HTTP/1.x, HTTP/2.x, etc…) and supports m
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
Mirror of Apache RocketMQ
Apache RocketMQ Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level c
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
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
Visit the official web site for more information. Armeria Build a reactive microservice at your pace, not theirs. Armeria is your go-to microservice f
Enhancing Java Stream API
StreamEx 0.7.3 Enhancing Java Stream API. This library defines four classes: StreamEx, IntStreamEx, LongStreamEx, DoubleStreamEx which are fully compa
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
An advanced, but easy to use, platform for writing functional applications in Java 8.
Getting Cyclops X (10) The latest version is cyclops:10.4.0 Stackoverflow tag cyclops-react Documentation (work in progress for Cyclops X) Integration
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