首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏python3

    python消息队列Queue

    )#初始化一个Queue对象,最多可接收三条put消息 q.put('message-1') q.put('message-2') print(q.full())#False,是否满了 q.put('message q.get_nowait()不阻塞,但会抛异常  False True except1,消息队列已满,现有消息数量:3 except2,消息队列已满,现有消息数量:3 message-1 message-2 message

    2.6K10发布于 2020-01-07
  • 来自专栏漫漫架构路

    ActiveMQ详解(1)——ActiveMQ简介与入门程序

    producer.sendMessage(destination,"message-" + i); } } } 查看控制台输出: 接收到了消息: message-1 接收到了消息: message-2 接收到了消息: message

    1.5K40发布于 2020-09-03
  • 来自专栏漫漫架构路

    RocketMQ详解(13)——RocketMQ的消息模式

    Message: messageId: 0A0E096CA41418B4AAC259EE89D70001,topic: DefaultCluster,tags: Tags,messageBody: Message

    2.9K20发布于 2020-09-03
  • pyspark作业使用虚拟环境

    中使用 cryptography(模拟在 executor 上加解密) data = [ "message-1", "message-2", "message gAAAAABpRXjy2z57n65rdWaF9FqC5bFzYK9K977N7f4IKT3qsfNVKa-G7h6IrwCaNLlYn2idjmL-3QjyL6Nznsgu7-5-Q58Sag==', 'message-2') ('message gAAAAABpRXjyB3UIwWpOkVn2B9GRMKjwQN3gKqQtmLHhblWafztHWuOAGDk8kRszPYF7uuKYEmeePOSbozmvxHzbpq9WjVHgAA==', 'message gAAAAABpRXjy2z57n65rdWaF9FqC5bFzYK9K977N7f4IKT3qsfNVKa-G7h6IrwCaNLlYn2idjmL-3QjyL6Nznsgu7-5-Q58Sag==', 'message-2') ('message gAAAAABpRXjyB3UIwWpOkVn2B9GRMKjwQN3gKqQtmLHhblWafztHWuOAGDk8kRszPYF7uuKYEmeePOSbozmvxHzbpq9WjVHgAA==', 'message

    21810编辑于 2026-01-16
领券