1、RpcEndpoint: RPC端点 Spark针对每个节点（Client、Master、Worker）都称之为一个RpcEndpoint，且都实现RpcEndpoint接口，内部根据不同端点的需求，设计不同的消息和不同的业务处理，如果需要发送（询问）则内部调用Dispatcher的对应方法 说 ...
分类：
Web程序 时间：
2019-12-22 14:19:28
阅读次数：
120
1、引言 IM等社交应用的开发工作中，乱码问题也很常见，比如: 1）IM聊天消息中的Emoji表情为什么发给后端后MySQL数据库里会乱码； 2）文件名中带有中文的大文件聊天消息发送后，对方看到的文名是乱码； 3）Http rest接口调用时，后端读取到APP端传过来的参数有中文乱码问题； ... ...
分类：
其他好文 时间：
2019-12-17 20:32:17
阅读次数：
105
ELK和EFK的区别在于 EFK有中间消息件，这个中间消息件可分为 redis 或者 kafka kafka负责收集客户端收集日志 总负责最后交给zookeeper，zookeeper负责把消息发送给logstash机器 logstash机器采集完发送给elasticsearch ，最后在kiban ...
分类：
其他好文 时间：
2019-12-16 10:18:34
阅读次数：
656
分布式事务了解吗？如果解决分布式事务问题的？ 面试官心里： 只要聊到你做了分布式系统，必问分布式事务，起码得知道有哪些方案，一般怎么来做，每个方案的优缺点是什么。 为什么要有分布式事务？ 分布式事务实现的几种方案： 1. 两阶段提交方案/XA方案 这种分布式事务方案，比较适合单块应用里。跨多个库的分 ...
分类：
编程语言 时间：
2019-12-15 14:18:20
阅读次数：
73
前言 之前在我的博客([一枝花算不算浪漫][1])中已经更新过两篇设计模式相关的内容 [【一起学设计模式】策略模式实战一：基于消息发送的策略模式实战][2] [【一起学习设计模式】策略模式实战二：配合注解 干掉业务代码中冗余的if else...][3] [【一起学设计模式】访问者模式实战：权限管理 ...
分类：
其他好文 时间：
2019-12-14 14:01:30
阅读次数：
86
实现代码如下： #websocket协议通信 import threading import time import websocket def when_message(ws, message): print('/n接收到的消息：' + message) # 当建立连接后，死循环不断输入消息发送给 ...
分类：
编程语言 时间：
2019-12-08 14:07:23
阅读次数：
248
目的： 消息如何保证100%的投递 幂等性概念 Confirm确认消息 Return返回消息 自定义消费者 前言： 想必知道消息中间件RabbitMQ的小伙伴，对于引入中间件的好处可以起到抗高并发，削峰，业务解耦的作用并不陌生。 康康简单流程图了解一下。详情了解RabbitMQ可移步：https:/ ...
分类：
其他好文 时间：
2019-12-06 13:35:49
阅读次数：
84
队列基础知识 队列用于任务与任务、任务与中断之间的通信； 队列中可以存储有限的、大小固定的数据项目，队列所能保存的最大数据项目的数量叫做队列的长度，创建队列的时候会指定数据项目的大小和队列的长度； 队列采用先进先出(FIFO)的存储缓冲机制，也可以使用后进先出(LIFO)的存储缓冲机制； 将消息发送 ...
分类：
其他好文 时间：
2019-12-02 13:54:38
阅读次数：
121
SpringBoot学习（六）——springboot快速整合RabbitMQ40/100发布文章weixin_43750212RabbitMQ消息队列@[toc]简介优点erlang开发，并发能力强。社区活跃，使用的人多，稳定性较强。延时低缺点erlang语言开发的，国内精通的不多，日后定制开发困难。RabbitMQ工作模式1，"HelloWorld!"模式简单模式是Rabb
分类：
编程语言 时间：
2019-11-29 23:37:27
阅读次数：
84
概述 Spring 由 20 多个模块组成，它们可以分为数据访问/集成（Data Access/Integration）、Web、面向切面编程（AOP, Aspects）、应用服务器设备管理（Instrumentation）、消息发送（Messaging）、核心容器（Core Container）和 ...
分类：
编程语言 时间：
2019-11-23 09:47:45
阅读次数：
86
