# =================================================================== # COMMON SPRING BOOT PROPERTIES # # This sample file is provided as a guideline.... ...
分类：
编程语言 时间：
2019-04-21 13:05:41
阅读次数：
113
Spring Cloud由以下子项目组成。 Spring Cloud Config Spring Cloud Config 配置中心——利用git来集中管理程序的配置。 项目地址：https://spring.io/projects/spring-cloud-config Spring Cloud ...
分类：
编程语言 时间：
2019-04-13 11:12:31
阅读次数：
218
集成tomcat就是随项目启动而启动tomcat，最简单的方法就是监听器监听容器创建之后以Broker的方式启动ActiveMQ。 1.web项目中Broker启动的方式进行集成 在这里采用Listener监听ServletContext创建和销毁进行Broker的启动和销毁。 0.需要的jar包: ...
分类：
编程语言 时间：
2019-04-13 01:20:40
阅读次数：
250
Celery - 一个懂得 异步任务 , 定时任务 , 周期任务 的芹菜 1.什么是Celery?Celery 是芹菜Celery 是基于Python实现的模块, 用于执行异步定时周期任务的其结构的组成是由 1.用户任务 app 2.管道 broker 用于存储任务 官方推荐 redis rabbi ...
分类：
其他好文 时间：
2019-04-11 16:32:12
阅读次数：
107
本地测试向服务器中ActiveMQ添加队列数据，报错连接超时 解决： 查看服务器端口号是否存在，(最好是0.0.0.0格式的，虽然暂时还不知道为啥得这个格式) 通过telnet测试该端口不通(61616端口) 服务器控制台开放该端口(添加规则) 再telnet就通了，然后继续测试，错误消失 ...
分类：
编程语言 时间：
2019-04-10 13:29:10
阅读次数：
763
Return: Map[TopicPartition, Long] Code: val props = new Properties() props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaPara("bootstrap.servers") ...
分类：
其他好文 时间：
2019-04-09 18:55:52
阅读次数：
180
持久化消息和非持久化消息的发送策略 消息同步发送和异步发送 ActiveMQ支持同步、异步两种发送模式将消息发送到broker上。同步发送过程中，发送者发送一条消息会阻塞直到broker反馈一个确认消息，表示消息已经被broker处理。这个机制提供了消息的安全性保障，但是由于是阻塞的操作，会影响到客 ...
分类：
其他好文 时间：
2019-04-08 01:04:59
阅读次数：
186
一.单节点 1.上传Kafka安装包到Linux系统【当前为Centos7】。 2.解压，配置conf/server.property。 2.1配置broker.id 2.2配置log.dirs 2.3配置zookeeper.connect 3.启动Zookeeper集群 备注：zookeeper集 ...
分类：
其他好文 时间：
2019-04-07 13:11:03
阅读次数：
159
环境 /opt/kafka_2.12-1.0.0 /opt/kafka（软连接） 软件下载 Kafka下载 http://archive.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz JDK下载 https://download.oracle.co ...
分类：
其他好文 时间：
2019-04-07 10:08:07
阅读次数：
227
一、如何启动active MQ 服务 （一）、使用命令启动 （二）、代码启动broker 在程序中可以通过编码的方式启动broker，如果要启动多个broker需要为每一个broker设置名字 broker.setName("brokerOne") 1、使用BrokerService 启动broke ...
分类：
其他好文 时间：
2019-04-05 20:11:07
阅读次数：
179
