Rocketmq rust版本-开篇

我是蚂蚁背大象(Apache EventMesh PMC&Committer),文章对你有帮助给Rocketmq-rust star,关注我GitHub:mxsm,文章有不正确的地方请您斧正,创建ISSUE提交PR~谢谢! Emal:mxsm@apache.com

Rust重构Rocketmq,大家好我是mxsm(Apache EventMesh PMC&Committer|Rocketmq活跃Contributor)最近在学习Rust的相关知识,Rust也是近些年来比较火的语言,本着技多不压身的想法和不会Rust开发的Java开发不是好开发的理念。最近在用Rust来重构Rocketmq,把所学的Rust的知识运用起来,检验一下学习成果。这个也是我下面这个项目的目的:rocketmq-rust

有对 rocketmq-rust 项目感兴趣的小伙伴可以一起来开发和研究(Rust新手轻点喷), 希望大家给个star。 不管你是Rust的新手,高手欢迎一起交流学习参与进来。

1. 什么是rocketmq-rust?

Rocketmq-rust是基于Apache Rocketmq Java版本的Rust实现,最终的目标是用Rust的完全实现一个和现有Rocketmq一样的Rust的版本的Rocketmq。两者可互通功能完全一致。

1.1 RocketMQ-Rust 的特点

  • Rust 语言优势: 利用 Rust 语言的内存安全性、零成本抽象、并发性能等特性,提供高效、可靠的消息中间件。
  • 异步和非阻塞设计: RocketMQ-Rust 充分利用 Rust 异步编程的能力,采用非阻塞设计,支持高并发消息处理。
  • 生态整合: 作为 Rust 生态系统的一部分,RocketMQ-Rust 与 Rust 生态中其他库和框架的兼容性良好,为开发者提供灵活的集成选项。
  • 跨平台支持: RocketMQ-Rust 支持多种平台,包括 Linux、Windows、macOS 等,方便在不同环境下使用。

1.2 项目进展

已经能够实现Broker的注册功能,初步实现了:

  • Broker registration(request code: 103)-Currently, only basic Broker registration is supported. Support for the Controller mode is pending.
  • Retrieve cluster information(request code: 106)

在这里插入图片描述

具体使用可以参照项目的README 文档

2. 如何参与贡献开发

项目地址:https://github.com/mxsm/rocketmq-rust

2.1 所需相关技能

  • 熟悉Apache Rocketmq的架构以及相关知识,对Rocketmq的Java源码有一定的了解(方便进行Rust重构)
  • 了解熟悉Rust的基本知识以及开发,这里包括以下方面:
    • Rust的基础知识
    • Rust的异步知识
    • Tokio框架开发等等

2.1 如何参与

  • rocketmq-rust 项目中会有一些ISSUE可以进行实现开发
  • 根据自己的兴趣爱好自己提ISSUE进行开发

3. 目标

  • 最终目标实现Rust版本的Rocketmq,相比Java版本的版本的功能一样。同时想对比一下两种语言的实现版本性能的差异性
  • 将所学的Rust知识融会贯通,学以致用。对于想学Rust的但是又不知道从哪里练手的人来说这个项目尝试一下

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/628232.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

隐私计算的技术体系有哪些

随着各行各业的数字化转型发展,围绕数据的数字化应用如雨后春笋般出现,数据作为业务过程的重要产品,数据作为一种资源、生产要素或商品,越来越得到大家的重视,同时,数据只有在交易流通中才能体现出价值,但需要数据安全的支撑。数据作为数字经济的生产要素之一,具有四方…

Leetcode 474 一和零

题意理解: 给你一个二进制字符串数组 strs 和两个整数 m 和 n 。 请你找出并返回 strs 的最大子集的长度,该子集中 最多 有 m 个 0 和 n 个 1 。 如果 x 的所有元素也是 y 的元素,集合 x 是集合 y 的 子集 。 将字符串0和1的个数看作是该字符…

基于SSM的网上订餐管理系统

末尾获取源码 开发语言:Java Java开发工具:JDK1.8 后端框架:SSM 前端:Vue 数据库:MySQL5.7和Navicat管理工具结合 服务器:Tomcat8.5 开发软件:IDEA / Eclipse 是否Maven项目:是 目录…

Python系列(2)—— 数据类型

Python核心数据类型 一、Numbers(数字)三、String(字符串)三、Tuple(元组)四、List(列表)五、Set(集合)六、Dictionary(字典) 在Pytho…

Go语言中的Pool

简介 Go语言中的pool是一个资源池,它可以存储一定数量的资源,这些资源可以被多个goroutine共享。Pool可以提高资源的利用率,减少资源的创建和销毁带来的开销。 原理 Pool的实现原理很简单,它使用一个队列来存储资源。当一个gor…

go语言初探(一)

package mainimport ("fmt""time" )func main() {fmt.Print("hello go!")time.Sleep(1 * time.Second)}运行后,结果如下: 1、golang表达式中,加;和不加;都可以 2、函数的{和函数名一…

五、Model与View

一、Model/View结构 数据:如数据库的一个数据表或者SQL查询结果,如内存中的数据类对象,或者磁盘文件结构等Model:与数据通信,并作为视图组件提供数据接口View:屏幕界面组件,视图从数据模型获得…

软件工程:黑盒测试等价分类法相关知识和多实例分析

目录 一、黑盒测试和等价分类法 1. 黑盒测试 2. 等价分类法 二、黑盒测试等价分类法实例分析 1. 工厂招工年龄测试 2. 规定电话号码测试 3. 八位微机测试 4. 三角形判断测试 一、黑盒测试和等价分类法 1. 黑盒测试 黑盒测试就是根据被测试程序功能来进行测试&#xf…

Arduino快速上手esp32方案开发

一、什么是ESP32? ESP32是Espressif Systems推出的一款高性能、低功耗的Wi-Fi和蓝牙双模系统级芯片(SoC),广泛应用于物联网、智能家居、可穿戴设备等领域。它基于极低功耗的Tensilica Xtensa LX6微处理器,并集成了丰富…

【现代密码学】笔记4--消息认证码与抗碰撞哈希函数《introduction to modern cryphtography》

【现代密码学】笔记4--消息认证码与抗碰撞哈希函数《introduction to modern cryphtography》 写在最前面4 消息认证码与抗碰撞哈希函数MAC概念回顾(是的,我忘记这些缩写是什么了。。)MAC的定义适应性CMA(Chosen Message Attack&a…

SpringBoot教程(十五) | SpringBoot集成RabbitMq

SpringBoot教程(十五) | SpringBoot集成RabbitMq RabbitMq是我们在开发过程中经常会使用的一种消息队列。今天我们来研究研究rabbitMq的使用。 rabbitMq的官网: rabbitmq.com/ rabbitMq的安装这里先略过,因为我尝试了几次都失败了,后面等我…

边缘型人格障碍测试

边缘性人格障碍属于常见多发的人格障碍类型,在2015年美国的相关调查显示,边缘型人格障碍的患病率在初级医疗环境中为6%,在精神科住院病人中则达到20%。 边缘性人格障碍治疗难度高,对于个人造成的危害大。应该及早了解边缘性人格障…

使用jarsigner给jar文件签名的5个步骤

jarsigner, keytool 这2个都是JDK的内置工具,在JDK的bin目录中可以找到, 下面是使用jarsigner给jar文件签名的5个步骤: 1. 使用java的jar工具创建JAR文件; # 将当前文件夹下的所有文件打包到myapp-1.0.jar文件中 后面的*为通配符, 也可以指定需要打包的jar中的文件或者文件夹…

软件测试|Git:fatal: refusing to merge unrelated histories错误分析与解决

问题介绍 在使用Git时,有时我们可能会遇到以下错误消息: fatal: refusing to merge unrelated histories这个错误通常发生在尝试合并两个不相关的Git仓库历史时。在本文中,我们将详细解释为什么会出现这个错误以及如何解决它。 问题分析 …

DataFunSummit:2023年云原生大数据峰会:核心内容与学习收获(附大会核心PPT下载)

随着数字化转型的深入推进,大数据技术已经成为企业获取竞争优势的关键因素之一。本次峰会汇聚了业界顶尖的大数据专家、企业领袖和技术精英,共同探讨云原生大数据领域的最新技术和趋势。本文将深入分析峰会的核心内容,并探讨参会者从中能学到…

Python字符串验证与正则表达式【第23篇—python基础】

文章目录 引言方法1:使用 isalpha() 方法方法2:使用正则表达式方法3:遍历字符检查应用场景示例与比较优化与扩展方法4:考虑空格和其他字符应用场景扩展 示例与比较优化与扩展方法4:考虑空格和其他字符方法5&#xff1a…

【期末不挂科-C++考前速过系列P5】大二C++实验作业-多态性(3道代码题)【解析,注释】

前言 大家好吖,欢迎来到 YY 滴C考前速过系列 ,热烈欢迎! 本章主要内容面向接触过C的老铁 主要内容含: 欢迎订阅 YY滴C专栏!更多干货持续更新!以下是传送门! YY的《C》专栏YY的《C11》专栏YY的《…

excel如何冻结窗格

冻结窗口(Freeze Panes) 打开你的 Excel 文件。 选择你希望冻结的行或列。 如果要冻结第一行,请选择第一行。 如果要冻结第一列,请选择第一列。 如果要同时冻结行和列,请选择希望冻结的左上角单元格的下方和右侧的单…

Docker容器(二)安装与初体验wordpress

一、安装 1.1关闭SeLinux SeLinux(Security-Enhanced Linux)是一种基于Linux内核的安全模块,旨在提供更严格的访问控制和安全策略。它通过强制实施安全策略来限制系统资源的访问,从而保护系统免受恶意软件和未经授权的访问。 在…

提升问题检索的能力

事实上,在信息极度丰富的时代,信息检索和筛选能力格外重要。一些搜索引擎的出现已极大地方便了我们日常的信息检索,此处需要注意的是我们不能仅仅局限于常见的搜索引擎,也需要关注和积累一些专业平台或是具有集成功能的引擎&#…