TransactionProducer(事务消息): 在分布式系统中,我们时常会遇到分布式事务的问题,除了常规的解决方案之外,我们还可以利用RocketMQ的事务性消息来解决分布式事务的问题。RocketMQ和其他消息中间件最大的一个区别是支持了事务消息,这也是分布式事务里面的基于消息的最终一致性方 ...
分类:
其他好文 时间:
2019-09-11 18:27:08
阅读次数:
105
MySQL 运行状态及调优 1.查看MySQL服务器配置信息mysql> show variables; 2.查看MySQL服务器运行的各种状态值mysql> show global status; 3.慢查询mysql> show variables like '%slow%'; + + + | ...
分类:
数据库 时间:
2019-09-11 17:56:57
阅读次数:
97
1 #include <bits/stdc++.h> 2 #define _for(i,a,b) for(int i = (a);i < b;i ++) 3 #define _rep(i,a,b) for(int i = (a);i > b;i --) 4 #define INF 0x3f3f3f3... ...
分类:
其他好文 时间:
2019-09-11 16:16:41
阅读次数:
82
一.前言 任何消息队列都是万变不离其宗都是3部分,消息生产者(Producer)、消息消费者(Consumer)和服务载体(在Kafka中用Broker指代)。那么本篇主要讲解Producer端,会有适当的图解帮助理解底层原理。 一.开发应用 首先介绍一下开发应用,如何构建一个KafkaProduc ...
分类:
其他好文 时间:
2019-09-10 22:05:10
阅读次数:
115
Kafka是一个分布式的Streaming处理平台,Kafka可以用于数据库中数据的导入导出,也可以用于实时流的处理,但是Kafka最核心的功能就是作为分布式的消息中间件。 Kafka集群是由多个Broker Server组成的,消息的发送者称为Producer,消息的消费者称为Consumer,t ...
分类:
其他好文 时间:
2019-09-08 22:43:34
阅读次数:
161
总体介绍 承接着我们的springmvc+mybatis+mysql初级高级课程,以Dept部门模块做一个微服务通用案例Consumer消费者(Client)通过REST调用Provider提供者(Server)提供的服务 Maven的分包分模块架构复习 一个简单的Maven模块结构是这样的: sp ...
分类:
其他好文 时间:
2019-09-08 20:05:05
阅读次数:
73
创建三个Maven Project: dubbo-service:公共模块,包括服务接口(packaging:jar) dubbo-service-impl:服务提供方,提供服务接口的具体实现,需要依赖dubbo-service(packaging:jar) dubbo-consumer:服务调用方 ...
分类:
其他好文 时间:
2019-09-08 11:19:21
阅读次数:
73
本地测试环境: dubbo 2.6.0 springboot 2.1.7 JDK 1.8 Zookeeper 3.5.5 pom关键依耐: 1.provider(提供者) 1.1 启动类注解 1.2 服务实现类 1.3 配置文件(yml) 2.consumer(消费者) 2.1 启动类注解 2.2 ...
分类:
编程语言 时间:
2019-09-05 22:56:59
阅读次数:
787
一、背景 1.1文件组织架构 首先看一下mysql数据系统涉及到的文件组织架构,如下图所示: msyql文件组织架构图 从图看出: 1、日志文件:slow.log(慢日志),error.log(错误日志),general.log(基本日志) 2、配置文件:my.cnf 3、数据库:performan ...
分类:
数据库 时间:
2019-09-05 17:02:05
阅读次数:
123
三、如何保证消息的顺序性 拆分多个queue,每个queue一个consumer,就是多一些queue而已,确实是麻烦点;或者就一个queue但是对应一个consumer,然后这个consumer内部用内存队列做排队,然后分发给底层不同的worker来处理 写入一个partition中的数据一定是有 ...
分类:
其他好文 时间:
2019-09-03 09:14:07
阅读次数:
117