一、创建项目 1、打开idea,file--new--project 2、按照步骤①②③④操作 3、输入包名,并点击下一步 4、选择下载包的maven的setting.xml配置路径和包的存放地,然后点击next 5、确认最终的项目存放目录和项目名,点击finish 二、项目配置 1、在webapp ...
                            
                            
                                分类:
编程语言   时间:
2020-10-16 10:43:42   
                                阅读次数:
23
                             
                    
                        
                            
                            
                                用户行为日志分析是实时数据处理很常见的一个应用场景,比如常见的PV、UV统计。本文将基于Flink从0到1构建一个用户行为日志分析系统,包括架构设计与代码实现。本文分享将完整呈现日志分析系统的数据处理链路,通过本文,你可以了解到:基于discuz搭建一个论坛平台Flume日志收集系统使用方式Apache日志格式分析Flume与Kafka集成日志分析处理流程架构设计与完整的代码实现项目简介本文分享会
                            
                            
                                分类:
其他好文   时间:
2020-09-11 16:03:01   
                                阅读次数:
41
                             
                    
                        
                            
                            
                                SpringWebClientvs.RestTemplate点击左上角蓝字,关注“锅外的大佬”专注分享国外最新技术内容1.简介本教程中,我们将对比Spring的两种Web客户端实现——RestTemplate和Spring5中全新的Reactive替代方案WebClient。阻塞式vs非阻塞式客户端Web应用中,对其他服务进行HTTP调用是一个很常见的需求。因此,我们需要一个Web客户端工具。2.
                            
                            
                                分类:
编程语言   时间:
2020-08-29 15:22:30   
                                阅读次数:
60
                             
                    
                        
                            
                            
                                1. producer MQProducer接口: public interface MQProducer<K, V> { Future<RecordMetadata> send(ProducerRecord<K, V> var1) throws IllegalArgumentException;  ...
                            
                            
                                分类:
其他好文   时间:
2020-08-15 22:27:25   
                                阅读次数:
66
                             
                    
                        
                            
                            
                                
                    微信小程序中若要接收后台数据,如果不是要云开发的话,需要wx.request来获取后台的数据,但一般都是需要进行函数的封装, 以便实现接口的优化以及代码结构的美化. 注意:wx.request只能用来发送https网络请求。 小程序只能跟指定域名进行网络通信,故需实现来设置通信域名。 不过如果在开发 ...
                            
                            
                                分类:
微信   时间:
2020-08-10 13:21:20   
                                阅读次数:
135
                             
                    
                        
                            
                            
                                前言 前面我们为了解决go程同步的问题我们使用了channel, 但是go也提供了传统的同步工具. 它们都在go的标准库代码包 sync 和 sync/atomic 中. 下面我们来看一下锁的应用. 什么是锁呢? 就是某个协程(线程)在访问某个资源时先锁住, 防止其他协程的访问, 等访问完毕解锁后其 ...
                            
                            
                                分类:
其他好文   时间:
2020-08-04 09:46:17   
                                阅读次数:
59
                             
                    
                        
                            
                            
                                    程序、进程、线程的理解 程序(program):为完成特定任务、用某种语言编写的一组指令的集合。即指一 段静态的代码,静态对象。 进程(process):是程序的一次执行过程,或是正在运行的一个程序。 线程(thread):进程可进一步细化为线程,是一个程序内部的一条执行路径。 Java线程创建的方 ...
                            
                            
                                分类:
编程语言   时间:
2020-07-21 22:26:45   
                                阅读次数:
58
                             
                    
                        
                            
                            
                                思考: 1,消息丢失是什么造成的,从生产端和消费端两个角度来考虑? 2,消息重复是什么造成的,从生产端和消费端两个角度来考虑? 3,如何保证消息有序? 4,如果保证消息不重不漏,损失的是什么? 1.为什么会发生消息丢失和消息重复?消息发送Kafka消息发送有两种方式:同步(sync)和异步(asyn ...
                            
                            
                                分类:
其他好文   时间:
2020-07-21 00:57:57   
                                阅读次数:
177
                             
                    
                        
                            
                            
                                    Disruptor是一款java高性能无锁并发处理框架。和JDK中的BlockingQueue有相似处,但是它的处理速度非常快!!!号称“一个线程一秒钟可以处理600W个订单”(反正渣渣电脑是没体会到)。 Disruptor功能十分强大,比如消费者阻塞等待;生产者-消费者一对一、一对多、多对一、多对 ...
                            
                            
                                分类:
其他好文   时间:
2020-07-09 19:42:22   
                                阅读次数:
126
                             
                    
                        
                            
                            
                                    CentOS7 安装Kafka 关闭防火墙 systemctl stop firewalld.service systemctl disable firewalld.service 安装JDK yum install -y http://172.16.20.10/Oracle/JAVA/8/8u20 ...
                            
                            
                                分类:
其他好文   时间:
2020-07-09 15:30:49   
                                阅读次数:
140