1，依赖与配置 1pom.xml 2，配置文件相关内容，这里使用系统默认的两个管道，output 和 input 分别对应 Source 和 Sink 两个接口 2，代码部分 1，作为数据的实体类，注意需要实现 Serializable 接口 2，消费者监听 3，封装发送消息的生产者 4，测试的 控 ...
分类：
编程语言 时间：
2020-04-13 14:09:26
阅读次数：
94
睡眠与唤醒 Peterson解法和TSL解法都是正确的，但它们都有忙等待的缺点。这些解法在本质上是这样的： 当一个进程想进入临界区时，先检查是否允许进入，若不允许，则进程将踏步等待，直到许可为止 。 这种方法不仅浪费CPU时间，还可能引起预料不到的结果，即： 优先级翻转问题（priority inv ...
分类：
编程语言 时间：
2020-04-11 15:51:23
阅读次数：
97
实验平台 linux 实验内容 编写UDP服务器和客户端程序，客户端发送消息，服务器接收消息，并打印客户端的IP地址和端口号。 实验原理 UDP是无需连接的通信，其主要实现过程如下： 同样，我们可以按照上一篇博客：基于TCP的客户端和服务器端的代码设计 的办法，将服务器代码分成两部分，一个是初始化， ...
分类：
其他好文 时间：
2020-04-10 12:02:14
阅读次数：
65
1.问题出现 搭完mq单主单从集群之后，美滋滋想发一下message, 没想到碰到一个坑爹的问题： com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 14 DESC: service not available now, m ...
分类：
系统相关 时间：
2020-04-10 00:36:42
阅读次数：
616
近期项目组要做服务的迁移，但是迁移之后，数据库的数据读取速度非常慢，由于有新的开发任务，也就没有太多关注性能问题。一个同事经过测试发现，可能是数据库的用户密码的加密问题，后来数是没有使用数据库连接池。但是springboot不会自动使用连接池吗？很奇怪。 迁移服务后，一个发送消息的服务突然提示不能使 ...
分类：
数据库 时间：
2020-04-09 00:10:57
阅读次数：
73
1、RabbitMQ相关介绍 （1）RabbitMQ整体上是一个生产者和消费者模型，主要负责接收、存储、转发消息。RabbitMQ整体结构图如下： （2）生产者：发送消息的一方，生产者创建一条消息，发布到RabbitMQ上，消息一般分为两部分：消息体和标签，消息体是带有业务逻辑结构的数据，也可以进一 ...
分类：
其他好文 时间：
2020-04-06 19:03:19
阅读次数：
74
Kafka-消费者-偏移量的提交方式 每次调用poll()方法，它总是返回由生产者写入Kafka但还没有被消费者读取过的记录，可以追踪到哪些记录是被群组里的哪个消费者读取的。 更新分区当前位置的操作叫做提交。 消费者往一个叫做 _consumer_offset的特殊主题发送消息，消息里包含每个分区的 ...
分类：
其他好文 时间：
2020-04-06 15:43:22
阅读次数：
74
1、了解消息中间件 消息中间件，Message Queue Middleware,简称MQ,又称消息对列或消息对列中间件，利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 一般有两种传递方式：点对点模式，基于队列的一对一，消息生产者发送消息到对列，消费者从队 ...
分类：
其他好文 时间：
2020-04-05 13:59:54
阅读次数：
63
能够说出消息队列的应用场景以及RabbitMQ的主要改娘 完成RabbitMQ的安装以及RabbitMQ三种模式的入门案例 完成用户注册，能够将消息发送给RabbitMQ 完成短信微服务，能够接收消息并调用阿里云通信完成短信发送 消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流 ...
分类：
其他好文 时间：
2020-04-05 00:42:00
阅读次数：
106
什么是顺序发送: 消息生产和消息消费都严格按照先进先出的原则 顺序消息分为两种: 全局顺序: top下所有的queue都要进行FIFO 生产和消费,这种比较少用,会造成消息的堵塞,吞吐量不高, 局部顺序消息 确保top下面的一组队列 queque 顺序保存一直就行了,先发送的消息一定先被消费,比如我 ...
分类：
其他好文 时间：
2020-04-03 18:14:40
阅读次数：
64
