6月22日，上海·源创会，云技术专场火热报名中

forked from noear / folkmq

加入 Gitee

与超过 1200万开发者一起发现、参与优秀开源项目，私有仓库也完全免费：）

克隆/下载

README.md 4.56 KB

<h1 align="center" style="text-align:center;">
  FolkMQ
</h1>
<p align="center">
	<strong>The simplest message-oriented middleware. For simplicity, for the future!</strong>
</p>

<p align="center">
	<a href="https://folkmq.noear.org/">https://folkmq.noear.org</a>
</p>

<p align="center">
    <a target="_blank" href="https://search.maven.org/artifact/org.noear/folkmq">
        <img src="https://img.shields.io/maven-central/v/org.noear/folkmq.svg?label=Maven%20Central" alt="Maven" />
    </a>
    <a target="_blank" href="LICENSE">
		<img src="https://img.shields.io/:license-LGPL2.1-blue.svg" alt="LGPL2.1" />
	</a>
   <a target="_blank" href="https://www.oracle.com/java/technologies/javase/javase-jdk8-downloads.html">
		<img src="https://img.shields.io/badge/JDK-8-green.svg" alt="jdk-8" />
	</a>
    <a target="_blank" href="https://www.oracle.com/java/technologies/javase/jdk11-archive-downloads.html">
		<img src="https://img.shields.io/badge/JDK-11-green.svg" alt="jdk-11" />
	</a>
    <a target="_blank" href="https://www.oracle.com/java/technologies/javase/jdk17-archive-downloads.html">
		<img src="https://img.shields.io/badge/JDK-17-green.svg" alt="jdk-17" />
	</a>
    <a target="_blank" href="https://www.oracle.com/java/technologies/javase/jdk21-archive-downloads.html">
		<img src="https://img.shields.io/badge/JDK-21-green.svg" alt="jdk-21" />
	</a>
    <br />
    <a target="_blank" href='https://gitee.com/noear/folkmq/stargazers'>
        <img src='https://gitee.com/noear/folkmq/badge/star.svg' alt='gitee star'/>
    </a>
    <a target="_blank" href='https://github.com/noear/folkmq/stargazers'>
        <img src="https://img.shields.io/github/stars/noear/folkmq.svg?logo=github" alt="github star"/>
    </a>
</p>

<br/>
<p align="center">
	<a href="https://jq.qq.com/?_wv=1027&k=kjB5JNiC">
	<img src="https://img.shields.io/badge/QQ交流群-870505482-orange"/></a>
</p>

##### Language: English | [中文](README_CN.md)
<hr />

## Simplicity is the future

Source code is simple! Simple architecture! Easy to deploy! Easy to use!

## Function Introduction

| role     | function                                                                                    | 
|----------|---------------------------------------------------------------------------------------------|
| Producer | Publish messages, timed messages, sequential messages, expireable messages, transactional messages. Send Request (rpc) Qos0 and Qos1 are supported                      |     
|          |                                                                                             |       
| Consumer | Subscribe, unsubscribe. Consumption -ACK (automatic, manual). Listening (rpc)          |      
|          |                                                                                             |     
| Server   | Publish -Confirm, subscribe -Confirm, unsubscribe -Confirm, dispatch -Retry, dispatch -delay | 
| Server   | Single-threaded architecture, support for snapshot persistence (automatic, downtime, manual), Broker mode clustering, cluster hot-scaling                    |

## Features

* High throughput, low latency

The cluster mode can handle millions of messages per second with minimum latency of less than 1 millisecond.

* Extensibility

Cluster mode <mark> support hot expansion of service nodes </mark>. When the flow is high, it can be added at any time, and the flow can be reduced when it is low

* Durability, reliability

Messages are snapshot persisted (similar to redis) to local disk, and data backup is supported to prevent data loss

* Fast (standalone, ~ 180K TPS)

<img src="DEV-TEST.png" width="600" />

//Using MacBook pro 2020 + JDK8 native test, single client sending and receiving (running points inevitably have fluctuations, I chose the better one)

### Join a community exchange group

| QQ communication group：316697724                       | Wechat communication group (input: FolkMQ when applying)          |
|---------------------------|----------------------------------------|
|        | <img src="group_wx.png" width="120" />

## Video recording of development process

* Development process video： [《DEV-RECORD.md》](DEV-RECORD.md)
* Quick start：[《FolkMQ - Helloworld 入门》](https://www.bilibili.com/video/BV1Yj411L7fB/)

### Official website

https://folkmq.noear.org

### Special thanks to JetBrains for supporting the open source project

<a href="https://jb.gg/OpenSourceSupport">
  <img src="https://user-images.githubusercontent.com/8643542/160519107-199319dc-e1cf-4079-94b7-01b6b8d23aa6.png" align="left" height="100" width="100"  alt="JetBrains">
</a>

一键复制编辑原始数据按行查看历史

提交于 2024-03-05 06:45 . README

FolkMQ

The simplest message-oriented middleware. For simplicity, for the future!

https://folkmq.noear.org

Language: English | 中文

Simplicity is the future

Source code is simple! Simple architecture! Easy to deploy! Easy to use!

Function Introduction

role	function
Producer	Publish messages, timed messages, sequential messages, expireable messages, transactional messages. Send Request (rpc) Qos0 and Qos1 are supported

Consumer	Subscribe, unsubscribe. Consumption -ACK (automatic, manual). Listening (rpc)

Server	Publish -Confirm, subscribe -Confirm, unsubscribe -Confirm, dispatch -Retry, dispatch -delay
Server	Single-threaded architecture, support for snapshot persistence (automatic, downtime, manual), Broker mode clustering, cluster hot-scaling

Features

High throughput, low latency

The cluster mode can handle millions of messages per second with minimum latency of less than 1 millisecond.

Extensibility

Cluster mode support hot expansion of service nodes . When the flow is high, it can be added at any time, and the flow can be reduced when it is low

Durability, reliability

Messages are snapshot persisted (similar to redis) to local disk, and data backup is supported to prevent data loss

Fast (standalone, ~ 180K TPS)

//Using MacBook pro 2020 + JDK8 native test, single client sending and receiving (running points inevitably have fluctuations, I chose the better one)

Join a community exchange group

QQ communication group：316697724	Wechat communication group (input: FolkMQ when applying)

Video recording of development process

Development process video：《DEV-RECORD.md》
Quick start：《FolkMQ - Helloworld 入门》

Official website

https://folkmq.noear.org

Special thanks to JetBrains for supporting the open source project

JetBrains

马建仓 AI 助手

尝试更多

代码解读

代码找茬

代码优化

1

https://gitee.com/llm163520/folkmq.git

git@gitee.com:llm163520/folkmq.git

llm163520

folkmq

folkmq

main