FolkMQ

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.0.10 

<dependencies>
    <!-- 可选包：java-tcp（90kb左右）, smartsocket（260Kb左右）, netty（2.5Mb左右） -->
    <dependency>
        <groupId>org.noear</groupId>
        <artifactId>folkmq-transport-java-tcp</artifactId>
        <version>1.0.10</version>
    </dependency>
</dependencies>

public class ClientDemo1 {
    public static void main(String[] args) throws Exception {
        //客户端（鉴权为可选。服务端，不添加则不鉴权）
        MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602?ak=folkmq&sk=YapLHTx19RlsEE16")
                .connect();

        //订阅（consumer = ip or cluster name）
        client.subscribe("demo", "demoapp", message -> {
            System.out.println(message);
        });

        //发布
        client.publish("demo", "helloworld!").get();
    }
}

//消息客户端接口
public interface MqClient {
    //连接
    MqClient connect() throws IOException;

    //断开连接
    void disconnect() throws IOException;

    //客户端配置
    MqClient config(ClientConfigHandler configHandler);

    //自动回执
    MqClient autoAcknowledge(boolean auto);

    //订阅主题
    void subscribe(String topic, String consumer, MqConsumeHandler consumerHandler) throws IOException;

    //取消订阅主题
    void unsubscribe(String topic, String consumer) throws IOException;
    
    //发布消息
    default CompletableFuture<?> publish(String topic, String content) throws IOException {
        return publish(topic, content, null, 1);
    }
    
    //发布消息
    default CompletableFuture<?> publish(String topic, String content, int qos) throws IOException {
        return publish(topic, content, null, qos);
    }
    
    //发布消息
    default CompletableFuture<?> publish(String topic, String content, Date scheduled) throws IOException {
        return publish(topic, content, scheduled, 1);
    }
    
    //发布消息
    CompletableFuture<?> publish(String topic, String content, Date scheduled, int qos) throws IOException;
}