Spark Streaming处理流程中,遇到某些批次耗时长的问题,排查思路
分类:
其他好文 时间:
2020-11-18 13:12:54
阅读次数:
8
应网友要求,写一写连接池实现细节。一、如何通过连接访问下游工程架构中有很多访问下游的需求,下游包括但不限于服务/数据库/缓存,其通讯步骤是为:(1)与下游建立一个连接(2)通过这个连接,收发请求(3)交互结束,关闭连接,释放资源这个连接是什么呢,通过连接怎么调用下游接口?服务/数据库/缓存,官方会提供不同语言的Driver、Document、DemoCode来教使用方建立连接与调用接口,以Mong
分类:
其他好文 时间:
2020-11-18 13:05:10
阅读次数:
12
《“ID串行化”保证群消息顺序性》提到,可以通过连接池的改造,实现ID串行化,本篇讲讲连接池的原理,以及实现细节。通常如何通过连接访问下游?工程架构中有很多访问下游的需求,下游包括但不限于服务/数据库/缓存,其通讯步骤是为:(1)与下游建立一个连接;(2)通过这个连接,收发请求;(3)交互结束,关闭连接,释放资源;不管是服务/数据库/缓存,官方会提供不同语言的Driver、Document、Dem
分类:
其他好文 时间:
2020-11-16 13:57:11
阅读次数:
7
一、JDBC六个步骤 1.加载驱动 Class.forName(driver_class); 2.创建数据库连接 DriverManager.getConnection(url,user,password); 3.创建PreparedStatement PreparedStatement ps=co ...
分类:
数据库 时间:
2020-11-16 13:44:24
阅读次数:
52
1.加载驱动 Class.forName(driver_class); 2.创建数据库连接 DriverManager.getConnection(url,user,password); 3.创建PreparedStatement PreparedStatement ps=connection.pr ...
分类:
数据库 时间:
2020-11-16 13:44:12
阅读次数:
24
package com.atguigu.structure.streaming import org.apache.spark.sql.streaming.Trigger import org.apache.spark.sql.{DataFrame, SparkSession} import org ...
分类:
其他好文 时间:
2020-11-16 13:25:07
阅读次数:
3
mongodb 官方的go驱动包 go.mongodb.org/mongo-driver 使用起来比较繁琐,最近对其进行了二次封装 github地址:https://github.com/w3liu/go-common/tree/master/store/mongo测试用例如下: func Test ...
分类:
数据库 时间:
2020-11-13 13:16:09
阅读次数:
40
https://blog.csdn.net/zhuyong006/article/details/89513526 ...
分类:
其他好文 时间:
2020-11-10 11:06:39
阅读次数:
64
转自:https://www.xttblog.com/?p=2925 CAP原则又称CAP定理,指的是在一个分布式系统中,Consistency(一致性)、 Availability(可用性)、Partition tolerance(分区容错性),三者不可得兼。 分布式系统(distributed ...
分类:
其他好文 时间:
2020-11-08 17:38:57
阅读次数:
35
前言 在编写代码的过程中充分运用软件工程的思想是一个优秀程序员不可或缺的技能。一个优秀的程序应该具有良好的可靠性、容错性、易用性、易读性、可扩充性、可理解性和可维护性等等性能。为了达到这些要求,我们应该学会如何让自己编写的程序更加符合软件工程的思想,通过学习代码编写的规范和各种面向对象思想的实现方式 ...
分类:
微信 时间:
2020-11-08 16:52:15
阅读次数:
33