使用场景 大数据：数据量和速率激增，数据类型越来越复杂 应用开发：消息引擎，应用解耦，分布式存储，流处理 Kafka的体系结构 topic : 主题（消息的逻辑分类） 客户端： 细分为生产者（朝主题发送消息）， 消费者（读取主题的消息）； 服务端： broker (1 处理客户端发送和提供消费支持 ...
分类：
其他好文 时间：
2020-04-17 11:08:28
阅读次数：
73
1. 概念 1.1 AMQP协议 AMQP，即Advanced Message Queuing Protocol，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语 ...
分类：
其他好文 时间：
2020-04-14 16:52:39
阅读次数：
69
实验平台 linux 实验内容 编写UDP服务器和客户端程序，客户端发送消息，服务器接收消息，并打印客户端的IP地址和端口号。 实验原理 UDP是无需连接的通信，其主要实现过程如下： 同样，我们可以按照上一篇博客：基于TCP的客户端和服务器端的代码设计 的办法，将服务器代码分成两部分，一个是初始化， ...
分类：
其他好文 时间：
2020-04-10 12:02:14
阅读次数：
65
Spring Framework Spirng Framework 特有功能 Spring 常用组件 Spring Bean Spring Bean 容器的生命周期 Spring IOC 容器(底层是Map,解耦,即时与延迟加载) AOP(面向切面编程) Spring MVC(模型 视图 控制器) ...
分类：
编程语言 时间：
2020-03-27 12:34:59
阅读次数：
82
有时候我们需要监控一些网络上的变化，但是每次去刷新网页却又很麻烦，而且大部分刷新的时候网页并没有更新。那么有没有一个工具，可以监控网页变化，并将变化的结果推送到手机微信上呢？ 这里有很多应用场景，比如前一段时间很火的工具来监控JD、TB等口罩是否有货的状态、还有就是刷票、抢课、监听网页便也变化、爬虫 ...
分类：
微信 时间：
2020-03-24 14:34:19
阅读次数：
120
首先，我们通过一个DEMO来模拟TCP的拆包粘包的情况：客户端连续向服务端发送100个相同消息。服务端的代码如下： 客户端代码如下： java AtomicLong count = new AtomicLong(0); NioEventLoopGroup boss = new NioEventLoo ...
分类：
Web程序 时间：
2020-03-21 14:53:20
阅读次数：
69
1. 如果是一个业务被拆分成多个子业务部署在不同服务器上，是分布式应用；如果是同一个业务部署在多台服务器上，是集群； 2. 远程过程调用RPC：一种通过网络从远程计算机上请求服务，而不需要了解底层网络技术的协议；典型实现包括Dubbo，Thrift，CRPC等； 3. 消息队列：消息发布者只管将消息 ...
分类：
其他好文 时间：
2020-03-21 14:25:45
阅读次数：
55
EMQ： 百万级分布式开源物联网MQTT消息服务器。 一般是emq broker暴露MQTT的1883/ MQTTS的8883端口，现场的许多网关通过MQTT协议作为MQTT client与emq进行pub/ sub消息。 特点： 完全开放源码 基于Apache Version 2.0开源协议 百万 ...
分类：
其他好文 时间：
2020-03-18 15:21:00
阅读次数：
146
基本介绍与思路 收发并行 前一篇博客中，完成了客户端与服务端的简单TCP交互，但这种交互是触发式的：客户端发送一条消息，服务端收到后再回送一条。没有做到收发并行。收发并行的字面意思很容易理解，即数据的发送与接收互相不干扰，相互独立。当然，要保证服务端和客户端都能做到收发并行。 业务逻辑 脱离业务逻辑 ...
分类：
编程语言 时间：
2020-03-17 23:44:20
阅读次数：
72
消息服务消息服务指的是两个应用程序之间进行异步通信的API，它为标准消息协议和消息服务提供了一组通用接口，包括创建、发送、读取消息等，用于支持应用程序开发。在Java中，当两个应用程序使用JMS进行通信时，它们之间并不是直接相连的，而是通过一个共同的消息收发服务连接起来，可以达到解耦的效果。 JMS ...
分类：
其他好文 时间：
2020-03-15 20:29:43
阅读次数：
70
