暂无搜索历史
在Client和Server之间完成一次消息发送时，需要对发送的消息进行一个协议约定，因此就有必要自定义RocketMQ的消息协议；为了高效地在网络中传输消息和...
RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的；Master 角色的Broker支持读和写，Slave角色的 Broker仅支持读...
广播消费模式下，相同Consumer Group的每个Consumer实例都接收同一个Topic的全量消息。即每条消息都会被发送到Consumer Group中...
理解成rocketmq本身，broker主要用于producer和consumer接收和发送消息；broker会定时向nameserver提交自己的信息；是消息...
传统的WEB服务器在收到请求后，从磁盘读取数据，然后将数据写到网卡，通过网卡发送给客户端，这一读一写的过程中就涉及数据的拷贝：
Consumer主动从Broker获取消息，可以设置多久拉取一次、可以设置一次拉取多少条消息等参数；
Broker上的Topic上的消息都会顺序的写入到commitlog文件下，然后再异步转存到consumequeue以及indexFile文件；该消息的元信息存...
消费者中我们注册了一个监听器回调函数，当Consumer获取消息后，就会交给我们的回调函数来进行处理。如果处理完了，就返回一个ConsumeConcurrent...
服务器节点，每个服务器上可以有一个或多个kafka的实例，共同组成kafka集群；一个broker可以容纳多个topic，broker之间的地位是对等的，无主从...
transactional.id在kafka的事务机制中扮演了关键的角色，kafka正是基于该参数来过滤掉僵尸生产者的 （fencing out zombies...
Kafka 中默认的消费位移的提交方式为自动提交，这个由消费者客户端参数 enable.auto.commit 配置，默认值为 true 。这个默认的自动提交不...
Kafka允许同⼀个Partition存在多个消息副本(Replica)，每个Partition的副本通常由1个Leader及0个以上的Follower组成，⽣...
Kafka的Producer、Broker和Consumer之间采用的是一套自行设计的基于TCP层的协议，Kafka的这套协议完全是为了Kafka自身的业务需求...
首先生产者线程main生成消息后调用send方法，然后会经过拦截器、序列化器、分区器（Partition），分区器会对消息进行分区放入不同的本地队列，本地队列保...
将服务器的 ACK 级别设置为-1，可以保证 Producer 到 Server 之间不会丢失数据，即 At Least Once 语义；
如果有事务在表里执行增删改操作，那在行级会加独占锁，此时其实同时会在表级加一个意向独占锁；如果有事务在表里执行查询操作，那么会在表级加一个意向共享锁。其实平时操...
MySQL的主从复制和读写分离两者有着紧密的联系，首先要部署主从复制，只有主从复制完成了才能在此基础上进行数据的读写分离；
在项目初期，我们是没有将读写表分离的，而是基于一个主库完成读写操作。在业务量逐渐增大的时候，我们偶尔会收到系统的异常报警信息，DBA 通知我们数据库出现了死锁异...
间隙锁（Gap Lock）是Innodb在RR级别下为了解决幻读问题时引入的锁机制，（下面的所有案例没有特意强调都使用可重复读隔离级别）幻读的问题存在是因为新增...
备份原理是通过协议连接到 MySQL 数据库，将需要备份的数据查询出来，将查询出的数据转换成对应的insert 语句，当我们需要还原这些数据时，只要执行这些 i...
暂未填写公司和职称
暂未填写个人简介
暂未填写技能专长
暂未填写学校和专业
暂未填写个人网址
暂未填写所在城市
扫码关注腾讯云开发者
领取腾讯云代金券
