1、持久性 kafka使用文件存储消息，这就直接决定kafka在性能上严重依赖文件系统的本身特性。且无论任何OS下，对文件系统本身的优化几乎没有可能。因为kafka是对日志进行append操作，因此磁盘检索的开支是较小的；同时为了减少磁盘写入的次数，broker会将消息暂时buffer起来，当消息的 ...
分类：
其他好文 时间：
2019-04-24 00:23:31
阅读次数：
184
STOMP即Simple (or Streaming) Text Orientated Messaging Protocol，简单(流)文本定向消息协议，它提供了一个可互操作的连接格式，允许STOMP客户端与任意STOMP消息代理（Broker）进行交互。STOMP协议由于设计简单，易于开发客户端， ...
分类：
Web程序 时间：
2019-04-21 20:04:18
阅读次数：
932
# =================================================================== # COMMON SPRING BOOT PROPERTIES # # This sample file is provided as a guideline.... ...
分类：
编程语言 时间：
2019-04-21 13:05:41
阅读次数：
113
1.v$database SELECT name,open_mode,database_role,protection_mode,protection_level FROM v$database; 其中： open_mode ：read write、read only、read only with ... ...
分类：
其他好文 时间：
2019-04-14 12:26:22
阅读次数：
274
（一）三种保护模式介绍1.最大性能模式这种模式保证数据库主库性能最大化，主备库之间数据是异步传输的。即，主备日志归档以后才会传输到备库，在备库上使用归档日志文件做恢复操作。这种模式提供在不影响primary数据库性能前提下最高级别的数据保护策略。事物可以随时提交，当前primary数据库的redo数 ...
分类：
其他好文 时间：
2019-04-13 15:09:27
阅读次数：
142
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
