码迷,mamicode.com
首页 >  
搜索关键字:消息队列 activemq leveldb    ( 5353个结果
注意Spring事务这一点,避免出现大事务
背景本篇文章主要分享压测的(高并发)时候发现的一些问题。之前的两篇文章已经讲述了在高并发的情况下,消息队列和数据库连接池的一些总结和优化,有兴趣的可以在我的公众号中去翻阅。废话不多说,进入正题。事务,想必各位CRUD之王对其并不陌生,基本上有多个写请求的都需要使用事务,而Spring对于事务的使用又特别的简单,只需要一个@Transactional注解即可,如下面的例子:@Transactiona
分类:编程语言   时间:2020-10-29 09:59:52    阅读次数:83
注意Spring事务这一点,避免出现大事务
背景本篇文章主要分享压测的(高并发)时候发现的一些问题。之前的两篇文章已经讲述了在高并发的情况下,消息队列和数据库连接池的一些总结和优化,有兴趣的可以在我的公众号中去翻阅。废话不多说,进入正题。事务,想必各位CRUD之王对其并不陌生,基本上有多个写请求的都需要使用事务,而Spring对于事务的使用又特别的简单,只需要一个@Transactional注解即可,如下面的例子:@Transactiona
分类:编程语言   时间:2020-10-29 09:59:40    阅读次数:20
随笔——消息队列线程池模型如何保证重启时消息不丢
背景今天在脉脉上面看到了一个帖子,比较有意思:这个帖子的意思是:在使用Kafka的时候,我们已经设置了多个分区,如何去提升消费能力?如果使用线程池的方式去提升如何保证重启时消息不丢。这个题其实问了两个点,第一个是如何提升消费能力,第二个是如果选择线程池,我们如何做到消息不丢。这里先解释一下这两个问题到底是怎么回事,在很多消息队列中都有一个概念叫partion,代表着分区,分区是我们提高消息队列消费
分类:编程语言   时间:2020-10-29 09:42:12    阅读次数:19
高并发场景下的限流策略
高并发场景下的限流策略在高并发的场景下,我们的优化和保护系统的方式通常有:多级缓存、资源隔离、熔断降级、限流等等。今天我们来聊聊限流。为什么需要限流举个比较简单的例子,正常来说,一个员工A他每天能够处理的工作是10个,突然某一天来了100个工作量,这时候,如果员工A还处理100个,只有一种可能,这个员工被压垮。如果我们能预先知道会有100个任务会来,我们通过增加员工数或定义消息队列等等来临时解决。
分类:其他好文   时间:2020-10-29 09:24:41    阅读次数:18
C# 使用RabbitMQ消息队列
参考文章 https://www.cnblogs.com/kiba/p/11703073.html和https://www.cnblogs.com/longlongogo/p/6489574.html 经过代码检测两份文章的代码部分不适用,只参考了RabbitMQ的介绍和安装部分。 安装版本是 ra ...
分类:Windows程序   时间:2020-10-22 22:52:25    阅读次数:43
RPC和消息队列
RPC和消息队列 1 消息队列 1 两个服务调用:restful(http协议),rpc(远程过程调用) 2 rpc:远程过程调用 -gRPC:谷歌出的,跨语言 3 不管用rpc或者restful来通信,涉及到同步,异步 4 消息队列解决的问题 -应用解耦 -流量消峰 -消息分发(发布订阅:观察者模 ...
分类:其他好文   时间:2020-10-22 22:15:29    阅读次数:23
rabbitmq使用
1.rabbitmq使用 - 目的: 可以下载镜像,使用rabbitmq- 操作流程: RabbitMQ介绍和使用 1,RabbitMQ介绍 消息队列是消息在传输的过程中保存消息的容器。 现在主流消息队列有:RabbitMQ、ActiveMQ、Kafka等等。 RabbitMQ和ActiveMQ比较 ...
分类:其他好文   时间:2020-10-19 22:42:02    阅读次数:21
Springboot 1.5.7整合Kafka-client
在一次项目中,因甲方需要使用kafka消息队列推送数据,所以需要接入kafka,并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本,对应的springboot.kafka.starter有冲突,所以就接入了kafka-client。springboot接入ka ...
分类:编程语言   时间:2020-10-18 10:00:08    阅读次数:18
Redis-发布订阅模式
1.1 列表的局限 前面我们说通过队列的 rpush 和 lpop 可以实现消息队列(队尾进队头出),但是消费者需要不停地调用 lpop 查看 List 中是否有等待处理的消息(比如写一个 while 循环)。 为了减少通信的消耗,可以 sleep()一段时间再消费,但是会有两个问题: 1、如果生产 ...
分类:其他好文   时间:2020-10-14 20:38:26    阅读次数:21
ActiveMq简单整合
ActiveMq 1. 原生JMS API操作ActiveMQ PTP 模式(生产者) /** * 演示点对点模式 -- 消息生产者 */ public class PTP_Producer { public static void main(String[] args) throws JMSExc ...
分类:其他好文   时间:2020-10-14 20:29:24    阅读次数:24
5353条   上一页 1 ... 8 9 10 11 12 ... 536 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!