部署 Embedded 内嵌说明

Embedded 内嵌部署。只支持 java 环境（因为服务端是 java 开发的）。同时也可以与 proxy 组成集群

1、带控制台的（推荐）

带控制台的内嵌版本，基于 solon 开发。控制台地址默认为 /folkmq/。依赖包，大概 7Mb 左右：

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>folkmq-broker-embedded</artifactId>
    <version>1.7.8</version>
</dependency>

带控制台的内嵌版本，会加载的配置文件：

• Solon 集成

引入依赖包即可。具体示例：

https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-solon

• jFinal 集成

引入依赖包之后，还要添加 servlet 适配包。具体示例：

https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-jfinal

• Vert.X 集成

引入依赖包之后，还要添加 vert.x 适配包。具体示例：

https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-vertx

• SpringBoot2, SpringBoot3 集成

引入依赖包之后，还要添加 servlet 适配包，具体示例:

https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-springboot2

https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-springboot3

2、不带控制台的

• 添加依赖包

参考，https://folkmq.noear.org/article/818

• 示例代码

public class ServerDemo {
    public static void main(String[] args) throws Exception {
        //::启动服务端（需要有自己的协议端口）
        MqBorker broker = FolkMQ.createBorker()
                .addAccess("folkmq", "YapLHTx19RlsEE16")
                .start(18602);
                
         //::客户端连接
        MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602?ak=folkmq&sk=YapLHTx19RlsEE16")
                .connect();

        //订阅
        client.subscribe("demo", "demoapp", ((message) -> {
            System.out.println(message);
        }));

        //发布
        client.publishAsync("demo", new MqMessage("Helloworld!"));
    }
}