1、lpush+rpop 采用rpop需要不停调用rpop方法查看list中是否有待处理消息。每调用一次都会发起一次连接，造成不必要浪费 代码： producer： package com.eval.mind.service.redis; import java.util.UUID; import ...
分类：
其他好文 时间：
2019-07-13 17:26:22
阅读次数：
156
tensorflow的数据集可以说是非常重要的部分，我认为人工智能就是数据加算法，数据没处理好哪来的算法？ 对此tensorflow有一个专门管理数据集的方式tfrecord·在训练数据时提取图片与标签就更加方便，但是tensorflow 的使用可以说，有时还是会踩着坑的，对此我做了一个代码专门用于 ...
分类：
其他好文 时间：
2019-07-12 00:43:19
阅读次数：
110
队列消息持久化之JDBC 1、 配置activemq.xml文件，修改持久化方式为jdbc 2、在broker外配置数据库连接bean 3、启动服务，可以看到数据库中多了3张表，表明配置成功 4、运行Producer，模拟生产者发送消息 控制台输出： Activemq管理控制台： 数据库表中: 5、 ...
分类：
其他好文 时间：
2019-07-11 12:20:40
阅读次数：
70
—————————————————示例——————————————————————— ...
分类：
其他好文 时间：
2019-07-10 10:53:36
阅读次数：
72
fetch.min.bytes. #获取最小字节数据 Consumer 向broker中要数据时是按大小来返回的，如果数据没有达到指定的M数，consumer会处于等待状态，直到broker 从producer 哪里获取到指定大小的数据为止。获取取的最小数据大小是指的每个partition上的数据。... ...
分类：
其他好文 时间：
2019-07-10 01:05:01
阅读次数：
105
参考别人的博客：https://www.cnblogs.com/whatisfantasy/p/6440585.html 线程 线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中，是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流，一个进程中可以并发多个线程，每条线程并行执行 ...
分类：
编程语言 时间：
2019-07-06 22:11:55
阅读次数：
169
[TOC] 列表生成式 列表生成式即List Comprehensions，是Python内置的非常简单却强大的可以用来创建list的生成式。 例如： 生成器 1.定义 一个函数调用时返回一个迭代器，那这个函数就叫做生成器（generator），如果函数中包含yield语法，那这个函数就会变成生成器 ...
分类：
编程语言 时间：
2019-07-06 22:08:18
阅读次数：
160
1.引入jar 2.kafka producer 3.consumer ...
分类：
其他好文 时间：
2019-07-04 11:24:00
阅读次数：
75
1、kafka的配置 2、topic的配置 3、producer的配置 4、consumer的配置 props.put("consumer.timeout.ms", "100"); 这个配置很重要，关乎取消息的阻塞的时间 默认-1,consumer在没有新消息时无限期的block。如果设置一个正值， ...
分类：
其他好文 时间：
2019-07-02 13:29:18
阅读次数：
81
RocketMQ重试机制 消息重试分为两种： Producer发送消息的重试 和 Consumer消息消费的重试 。 一、Producer端重试 Producer端重试是指: Producer往MQ上发消息没有发送成功，比如网络原因导致生产者发送消息到MQ失败。 看一下代码： 针对网上说的超时异常会 ...
分类：
其他好文 时间：
2019-07-02 00:17:20
阅读次数：
80
