TubeMQ源码构建运行

秒速五厘米 2023-09-30 12:52 17阅读 0赞

![4414cac596b1f6f1507c104520fb7193.png][]

## 准备工作 ##

## 简介 ##

TubeMQ是一款开源的分布式消息中间件，采用Protocol Buﬀer构建消息对象模型。于2019年9月12日开源，即中秋 前一天。

## 下载 ##

安装 git 等工具

*  简单粗暴git直接拉取

git clone https://github.com/Tencent/TubeM

## 源码结构 ##

*  整体结构

![811ea4ea69b3a9fdad9c4c62b1ef55b1.png][]

*  结构释义

![342f94fbe2725f1435d4770c2074dd72.png][]

可见暂时支持Linux启动、打包可配置化 、丰富的Demo。

## 试用 ##

## 牛刀小试 ##

**编译**

点击生产者Demo运行，报错：

Error:(26, 54) java: 程序包com.tencent.tubemq.corebase.protobuf.generated不存在

发现这个包应该是核心包里的，于是全局搜索这个类，很遗憾没有。全局搜索，在 RPC.proto 里找到了下面这段：

option java_package = "com.tencent.tubemq.corebase.protobuf.generated"; 
    option java_outer_classname = "RPCProtos"; 
    option java_generate_equals_and_hash = true; 
    option optimize_for = SPEED;

嗯，是gRPC的语法。 查到中央仓库暂无tubemq(2019中秋)，于是自己编译它. 开始编译，无意外，日常报错：

[ERROR] Failed to execute goal com.github.igor-petruk.protobuf:protobuf-mavenplugin:0.6.3:run (default) on project tubemq-core: Cannot execute 'protoc': Cannot run program "protoc": CreateProcess error=2, 系统找不到指定的文件。 -> [Help 1]

于是找到这个插件：

<p1ugin>
        <groupId> com.github.igor-petruk.protobuf</groupId>
        <artifactId>protobuf-maven-plugin</artifactId>
        <version>0.6.3</version>
        <executions>
            <execution>
                <phase>generate-sources </phase>
                <goals>
                    <goa1>run</goa1>
                </goals>
            </execution>
        </executions>
    </plugin>

插件执行时，找不到 protoc 程序，当然，我没有装这个。于是安装protoc Windows版。

## Protocol Buﬀer ##

*  Protocol Buﬀers 是一种轻便高效的结构化数据存储格式，可以用于结构化数据串行化，或者说序列化。它很适 合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列 化结构数据格式。目前提供了 C++、Java、Python 三种语言的 API.
 *  可见TubeMQ也采用了这种格式.
 *  考虑到Windows安装protobuf的复杂性，所以到Linux环境编译TubeMQ试试.
 *  先确认Maven存在与否，输入 mvn -version ，如果不存在请安装Maven

![f0f95d4f8739db658d7a7f91fbaddefa.png][]

*  接着按上文地址下载TubeMQ源码

![af5180e2591bc97d14d3a501c771612e.png][]

## 编译 ##

mvn clean compile

同样的错误，没有安装 protoc ，意料之中^\_^

![eaa5912c85b952ae3d673cdc79711201.png][]

但是Linux装工具简单多了，相比Windows.

## 安装protoc ##

下载地址 2.5.0 pan.baidu.com/s/1pJlZubT

下载2.5.0，因为TubeMQ暂时用的是2.5.0的jar包。 2.6.1 pan.baidu.com/share/init?… 密码：paju

![format_png][]

下载完毕，执行编译等.

sh configure --prefix=/usr/local/protobuf-2.6.1 
    make && make check && make install

执行命令，------漫长的等待后。 常规的，检查有无安装成功

![format_png 1][]

配置环境变量

![132828551d61650b34c8955e900fe7d4.png][]

安装完毕.

*  再次编译 mvn clean compile ，报错了，但是方向是对的了，因为这次报错说安装的protoc版本不匹配：
 *  查看下项目中的protobuf-java包的版本号是2.5.0,在中央仓库看了下，这个版本竟然是2013年的↓

![1c48d7aede750d3c8afbfcc131ec1142.png][]

可能需要安装2.5.0版本的环境.这时刘 欢的歌声响起："看成败人生豪迈,只不过是从头再来"。^\_^那就重新来，下载2.5.0的tar包，执行命令，编 译，"漫长的等待"(。-ω-)zzz↓

![format_png 2][]

<dependency>
        <groupId>com.sleepycat</groupId>
        <artifactId>je</artifactId>
        <version>5.0.73</version> 
    </dependency>

Bingo！编译成功。

![f2dedae5fd566625ad19e3198c32ab4a.png][]

mvn clean package

## 启动 ##

## Server ##

*  打包项目，效果

![d53b3339839d3c802f2ebf78b511d58a.png][]

![2f38003d8b4238fa6f32df24dfcc047f.png][]

*  install

mvn clean install

![6fa0a5eb3b1415a709f2446f31c5b4ad.png][]

![6a68a2067f36006b4f011f5c57f8c5a7.png][]

*  运行

cd ../tubemq-server/target/tubemq-server-3.8.0-bin/tubemq-server-3.8.0/conf # 进入这根目录，修改配置文件
    
    cd ../tubemq-server
    
    sh bin/master.sh start # 启动
    
    sh bin/broker.sh start # 启动

[4414cac596b1f6f1507c104520fb7193.png]: https://img-blog.csdnimg.cn/img_convert/4414cac596b1f6f1507c104520fb7193.png
[811ea4ea69b3a9fdad9c4c62b1ef55b1.png]: https://img-blog.csdnimg.cn/img_convert/811ea4ea69b3a9fdad9c4c62b1ef55b1.png
[342f94fbe2725f1435d4770c2074dd72.png]: https://img-blog.csdnimg.cn/img_convert/342f94fbe2725f1435d4770c2074dd72.png
[f0f95d4f8739db658d7a7f91fbaddefa.png]: https://img-blog.csdnimg.cn/img_convert/f0f95d4f8739db658d7a7f91fbaddefa.png
[af5180e2591bc97d14d3a501c771612e.png]: https://img-blog.csdnimg.cn/img_convert/af5180e2591bc97d14d3a501c771612e.png
[eaa5912c85b952ae3d673cdc79711201.png]: https://img-blog.csdnimg.cn/img_convert/eaa5912c85b952ae3d673cdc79711201.png
[format_png]: https://img-blog.csdnimg.cn/img_convert/7356ba67a8cf265b7c2b1268f1629751.webp?x-oss-process=image/format,png
[format_png 1]: https://img-blog.csdnimg.cn/img_convert/de5932b9283ce89f3fb7a3b7e5642691.webp?x-oss-process=image/format,png
[132828551d61650b34c8955e900fe7d4.png]: https://img-blog.csdnimg.cn/img_convert/132828551d61650b34c8955e900fe7d4.png
[1c48d7aede750d3c8afbfcc131ec1142.png]: https://img-blog.csdnimg.cn/img_convert/1c48d7aede750d3c8afbfcc131ec1142.png
[format_png 2]: https://img-blog.csdnimg.cn/img_convert/bbcc6cb43b80422b164755222d075a16.webp?x-oss-process=image/format,png
[f2dedae5fd566625ad19e3198c32ab4a.png]: https://img-blog.csdnimg.cn/img_convert/f2dedae5fd566625ad19e3198c32ab4a.png
[d53b3339839d3c802f2ebf78b511d58a.png]: https://img-blog.csdnimg.cn/img_convert/d53b3339839d3c802f2ebf78b511d58a.png
[2f38003d8b4238fa6f32df24dfcc047f.png]: https://img-blog.csdnimg.cn/img_convert/2f38003d8b4238fa6f32df24dfcc047f.png
[6fa0a5eb3b1415a709f2446f31c5b4ad.png]: https://img-blog.csdnimg.cn/img_convert/6fa0a5eb3b1415a709f2446f31c5b4ad.png
[6a68a2067f36006b4f011f5c57f8c5a7.png]: https://img-blog.csdnimg.cn/img_convert/6a68a2067f36006b4f011f5c57f8c5a7.png