快速入门 - Helloworld

1、启动服务

我们用最简单的方式，使用 docker 命令启动 FolkMQ 单机服务（默认采用 "tcp" 传输方式）

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-broker:1.7.8

2、编写客户端代码（for Java Demo）

兼容 groovy, kotlin 等 jvm 的语言，都可整合使用！

• 添加依赖包

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>folkmq-transport-netty</artifactId>
    <version>1.7.8</version>
</dependency>

客户端通过 url 的形式与服务端连接，且客户端要单例化。

• 编写代码

public class ClientDemo {
    public static void main(String[] args) throws Exception {
        //创建客户端，并连接
        MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                                .nameAs("demoapp")
                                .connect();

        //订阅主题，并指定加入的消费者分组
        client.subscribe("demo.topic", message -> {
            System.out.println(message);
        });

        //发布消息
        client.publish("demo.topic", new MqMessage("helloworld!"));
    }
}