weixin_42065915的博客

原创 自定义校验器

自定义校验器

原创 程序员崩溃的编译时长

原创 自定义validator自定义注解

自定义validator

原创 阿里云验签方式上传

前置：自行开通阿里oss服务：https://www.aliyun.com/product/oss?spm=a2c4g.11174283.J_8058803260.125.d9387da2TjNfP6oss API:https://help.aliyun.com/document_detail/32013.html?spm=a2c4g.11186623.6.956.65694697WhZebu一、简单的文件上传：依赖：<dependency> <group...

原创 K8s最佳实践手册

k8sk8s基础Pod/Pod控制器Name/NameSpacesLabel/Label选择器Service/Ingressk8s安装k8s基础Pod/Pod控制器Name/NameSpacesLabel/Label选择器Service/Ingressk8s安装

原创 Docker技术实战

Docker容器Docker部署微服务相关的问题Docker安装Docker命令导入导出镜像查看容器日志高级操作映射端口挂载数据卷传递环境变量安装软件Docker DockerfileUSER/WORKDIRADD/COPYEXPOSERUN/ENV指令CMD/ENTRYPOINTdocker 起源实现下面6个隔离才是独立的基于容器的轻量级虚拟化解决方案容器Docker部署微服务相关的问题时间不统一的问题FROM java:8EXPOSE 8791VOLUME /tmpADD b

原创 上传文件出现文件为空的问题

出现的原因是再文件上传接口使用多线程再多线程中读取文件读取不到,是因为文件再上传后切换线程回自动删除temp文件,所以文件读取不要放在其他线程中处理就可以了

原创 自定义异常处理

自定义异常package com.yulang.web.exception;import org.springframework.http.HttpStatus;import org.springframework.web.bind.annotation.ExceptionHandler;import org.springframework.web.bind.annotation.ResponseBody;import org.springframework.web.bind.annotatio

原创 自定义校验器注解使用

自定义校验器定义注解自定义校验类定义注解package com.yulang.web.valitate;import org.hibernate.validator.constraints.NotBlank;import javax.validation.Constraint;import javax.validation.Payload;import java.lang.annotation.ElementType;import java.lang.annotation.Retentio

原创 jenkins基本使用

jenkins pipelinehttps://github.com/zeyangli

原创 通过一张表更新另一张表

update tableA a left join tableB b on a.id= b.id set a.name = b.name,a.age=b.age where a.id=b.id;

原创 Spring中简化if else

原创 Spring中使用监听模式

继承ApplicationEvent写event类package com.nmrbt.oms.event;import com.nmrbt.pojo.domain.UserProgress;import org.springframework.context.ApplicationEvent;public class OverOrderEvent extends Application...

原创 ES入门

倒排索引ES采用倒排索引的方式提升查询效率GET _search{“query”: {“match_all”: {}}}PUT /lib/{“settings”: {“number_of_shards”: 3,“number_of_replicas”: 0}}GET /lib/_settingsGET _all/_settings添加文档PUT /li...

原创 java处理表情的几种方式

1.通过URLEncoder.encode(request.getContent(),UTF_8)对表情进行处理获取的时候前端转码或者后台再译码java使用如下方式译码URLDecoder.decode(item.getContent(),UTF_8)2.使用第三方工具包implementation('com.vdurmont:emoji-java:5.1.1'...

原创 mongodb基础

原创 Netty相关

Nettynetty官网同步阻塞IO BIO —block IO非阻塞IO NIO —new IOnetty提供了三种线程模型

原创 docker 安装 rabbitMq访问不了

需要进入容器安装插件rabbitmq-plugins enable rabbitmq_management

原创 docker安装

sudo yum install -y yum-utils \ device-mapper-persistent-data \ lvm2sudo yum-config-manager \ --add-repo \ https://download.docker.com/linux/centos/docker-ce.repo sudo yum install dock...

原创 几种单例模式的优缺点

懒汉式package thread;public class SingleTonOne { private static final SingleTonOne SINGLE_TON_ONE = new SingleTonOne(); private SingleTonOne(){} public static SingleTonOne bulider(){ ...

原创 docker安装mysql

docker run -d -p 3306:3306 --name mysql -e MYSQL_ROOT_PASSWORD=root docker.io/mysqlalter user'root'@'%' IDENTIFIED BY 'MyNewPass@123'; ('%'号是允许远程连接,引号中的root为账号,后面引号中的内容为新密码)flush privileges;...

原创 docker安装jenkins

docker pull jenkinsmkdir /home/jenkins_homedocker run -- name jenkins_01 -p 8081:8080 -v /home/jenkins_01 jenkins

原创 基于MQ的分布式事务

分布式事务分布式事务实现的五个步骤出现异常一般会重试几次由消费者记录重试次数,重试次数过多内容格式错误等情况,通过线上预警机制通知运维人员;如果消息发送一直不成功就可以让人工进行干预...

原创 RabbitMq消息可靠性

发送可靠性业务场景:使用MQ实现分布式事务// 进入confirm模式， 每次发送消息，rabbtiqm处理之后会返回一个对应的回执消息AMQP.Confirm.SelectOk selectOk = channel.confirmSelect();channel.addConfirmListener(new ConfirmListener() { @Override public...

原创 RabbitMq持久化

true为持久化参数// 定义一个持久化的，direct类型交换器channel.exchangeDeclare("routing_test", "direct", true);MessageProperties.PERSISTENT_TEXT_PLAIN// 发送持久化消息到routing_test交换器上channel.basicPublish("routing_test", "c...

原创 面试题

为什么要使用消息队列?1.将主要业务与次要业务进行解耦;例如:订单业务和短信业务;不适用MQ的耦合场景使用MQ场景消息队列的有点和缺点?1.解耦,消峰,异步2.业务场景如何保证消息队列的高可用?如何保证消息不被重复消费?如何保证消息的顺序性?如何处理消息堆积?...

原创 rabbitmq单机到集群完整搭建

RabbitMQ 安装和使用一、安装依赖环境二、安装RabbitMQ三、启动和关闭四、开启Web管理插件五、防火墙添加端口多机多节点集群部署一、 环境准备二、修改配置文件三、防火墙添加端口四、启动RabbitMQ单机多节点部署一、环境准备二、启动RabbitMQ三、防火墙添加端口镜像队列模式集群RabbitMQ 安装和使用一、安装依赖环境1.在 http://w...

原创 ActiveMq协议

原创 ActiveMQ

参考文档高可用高可用方案1:通过共享数据库的方案实现高可用但是不能提高作业性能,只能实现故障切换具体配置步骤:1.在activeMq下lib目录下放入数据库驱动包;2.修改activemq.xml重启其他机器使用相同配置就可以了高可用方案2:同步队列和主题的信息<?xml version="1.0" encoding="UTF-8...

原创 NIO

原创 BIO

package com.yulang.threadpool.bio;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;import java.nio.charset.Charset;import java.util.Scanner;public class BioClient ...

原创 TCP/UDP

原创 Fork/join

package com.example.test.thread;import java.util.HashMap;import java.util.concurrent.*;public class TestHashMap {public static void main(String[] args) throws ExecutionException, InterruptedExcep...

原创 DelayQueue延时队列

是使用优先级队列进行实现的

原创 PriorityQueue优先级队列

<Dish> priorityQueue = new PriorityQueue<>(Comparator.comparingInt(Dish::getCalories));

原创 ArrayBlockQueue

通过数组存储数据阻塞:package com.yulang.threadpool.java8;import org.springframework.scheduling.annotation.Scheduled;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.TimeUni...

原创 HashSet

hashSet底层使用的hashmap存储的值使用的是hashmap的key进行存储所以不能重复

原创 CopyOnWriteArrayList

CopyOnWriteArrayList是线程安全的

原创 List底层

list的底层是object数组线程是不安全的

原创 ConcurrentSkipListMap

使用的是多级索引进行查找put的时候会随机建立多级索引