springboot 2.X 能用 springboot-data-ES 5.X的 用特殊方式引入 5.X的ES 配置 bootstrap.xml 因为在调试,所以暂时写死了,具体的路径按照上面的配置 然后在serviceimpl中输入 通过transportClient 实现CRUD 最后POM. ...
分类:
编程语言 时间:
2018-12-20 16:55:33
阅读次数:
381
介绍 MQ全称为Message Queue, 是一种分布式应用程序的的通信方法,它是消费-生产者模型的一个典型的代表,producer往消息队列中不断写入消息,而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表,是一款基于AMQP协议可复用的企业消息系统 系 ...
分类:
其他好文 时间:
2018-12-20 14:15:39
阅读次数:
247
rabbitmq作为消息队列可以有消息消费确认机制,redis的list结构可以简单充当消息队列,但不具备消费确认机制,随意关停程序,会丢失一部分正在程序中处理但还没执行完的消息。 使用rabbitmq的最常用库pika ...
分类:
编程语言 时间:
2018-12-19 15:54:26
阅读次数:
887
1.查询服务状态rabbitmqctl status 2 列举虚拟主机列表rabbitmqctl list_vhosts 3 列举用户列表rabbitmqctl list_users 4 添加用户和密码rabbitmqctl add_user myadmin 123 5 设置权限 rabbitmqc ...
分类:
其他好文 时间:
2018-12-19 15:53:46
阅读次数:
96
使用pika库操作rabbit 查找whereis rabbitmq-server 启动/usr/sbin/rabbitmq-server & 打印了一些rabbitmq服务状态信息,包括内存,硬盘,和使用erlong的版本信息rabbitmqctl -q status 查看所有队列消息rabbit ...
分类:
其他好文 时间:
2018-12-19 15:38:57
阅读次数:
145
1.利用rabbitmq导数据包,第一不能正常导入,第二次正常,第三次又出现问题,第四次又恢复正常的坑爹问题。 2.可访问rabbitmq注意消费者个数是否正常 有两个消费者,导致第一次消息被第一个消费者接收,没执行业务。第二个消息被第二个消费者接收,执行业务。初步估计是有死线程存在 3.正常消费者 ...
分类:
其他好文 时间:
2018-12-18 17:59:01
阅读次数:
391
创建用户 rabbitmqctl add_user kye01 123456 设置用户角色 rabbitmqctl set_user_tags kye01 monitoring 查看用户清单 rabbitmqctl list_users 给用户授权 rabbitmqctl set_permissio ...
分类:
其他好文 时间:
2018-12-18 16:00:32
阅读次数:
184
环境搭建: RabitMQ是用Elang编写的,虽然Elang本身是跨平台的,但也同时意味着搭建Rabit环境需要首先配置Elang环境。配置RabitMQ的网上教程还比较多的: windows 下 rabbitMQ 的下载安装配置文档 windows下 安装 rabbitMQ 及操作常用命令 wi ...
分类:
其他好文 时间:
2018-12-18 10:51:31
阅读次数:
238
应用场景 之前我们已经通过 "《Spring Cloud Stream消费失败后的处理策略(一):自动重试》" 一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试功能:重新入队。 动手试试 准备一个会消费失败的例子,可以直接 ...
分类:
编程语言 时间:
2018-12-18 02:36:11
阅读次数:
289
应用场景 前两天我们已经介绍了两种Spring Cloud Stream对消息失败的处理策略: "自动重试" :对于一些因环境原因(如:网络抖动等不稳定因素)引发的问题可以起到比较好的作用,提高消息处理的成功率。 "自定义错误处理逻辑" :如果业务上,消息处理失败之后有明确的降级逻辑可以弥补的,可以 ...
分类:
编程语言 时间:
2018-12-18 02:15:13
阅读次数:
248