• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java RTopic类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中org.redisson.api.RTopic的典型用法代码示例。如果您正苦于以下问题:Java RTopic类的具体用法?Java RTopic怎么用?Java RTopic使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

RTopic类属于org.redisson.api包,在下文中一共展示了RTopic类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: send

点赞 3

import org.redisson.api.RTopic; //导入依赖的package包/类
@Override
public void send() {
    if (redissonClient.isShutdown() || redissonClient.isShuttingDown()) {
        return;
    }
    if (to instanceof QueueMessageSubject) {
        queueConsumer.accept(((QueueMessageSubject) to).getQueueName());
    }
    if (to instanceof MultipleQueueMessageSubject) {
        ((MultipleQueueMessageSubject) to).getQueueName().forEach(queueConsumer);
    }
    if (to instanceof TopicMessageSubject) {
        RTopic<Message> topic = redissonClient.getTopic("topic_" + ((TopicMessageSubject) to).getTopic(), codec);
        topic.publish(message);
    }
}
 

开发者ID:hs-web,
项目名称:hsweb-framework,
代码行数:17,
代码来源:RedissonMessagePublish.java

示例2: writeImpl

点赞 3

import org.redisson.api.RTopic; //导入依赖的package包/类
@Override
protected void writeImpl(PacketFuture pf) throws Exception {
    InsPacket packet = pf.send();
    packet.type(InsPacket.Type.GROUP.ordinal());
    ByteBuffer bytes = codec(packet.version()).encode(packet);

    String topic = packet.ins().toGroup().name();
    List<Co> toCo = packet.ins().toCo();
    if (toCo.isEmpty()) {
        RTopic<byte[]> groupTopic = redisson.getTopic(topic, ByteArrayCodec.INSTANCE);
        groupTopic.publish(bytes.array());
    } else {
        for (Co co : toCo) {
            RTopic<byte[]> coTopic = redisson.getTopic(String.valueOf(co.hashCode()), ByteArrayCodec.INSTANCE);
            coTopic.publish(bytes.array());
        }
    }
    pf.result(new PacketResult(PacketResult.IOSt.SEND_SUCC));
}
 

开发者ID:dzh,
项目名称:coca,
代码行数:20,
代码来源:RedisGroupChannel.java

示例3: main

点赞 3

import org.redisson.api.RTopic; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
    // connects to 127.0.0.1:6379 by default
    RedissonClient redisson = Redisson.create();

    CountDownLatch latch = new CountDownLatch(1);
    
    RTopic<String> topic = redisson.getTopic("topic2");
    topic.addListener(new MessageListener<String>() {
        @Override
        public void onMessage(String channel, String msg) {
            latch.countDown();
        }
    });
    
    topic.publish("msg");
    latch.await();
    
    redisson.shutdown();
}
 

开发者ID:redisson,
项目名称:redisson-examples,
代码行数:20,
代码来源:TopicExamples.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)