阿飞Sirx-CSDN博客

原创加载应用配置信息

private void loadApplicationConfiguration(CompositePropertySource compositePropertySource,String dataIdPrefix,NacosConfigProperties properties,Environment environment){ String fileExtension = properties.getFileExtension(); String nacosGroup = proper

2022-05-16 21:33:45 225

原创通过轮寻实现配置信息实时的推送

class LongPollingRunnable implements Runnable{ private final int taskId; public LongPollingRunnable(int taskId){ this.taskId = taskId; } @Override public void run(){ List<CacheData> cacheDatas = new ArrayList<CacheData>()

2022-05-12 21:20:47 294

原创给NacosConfig开启定时任务，定时检查配置信息

public class ClientWorker implements Closeable{ public ClientWorker(final HttpAgent agent,final ConfigFilterChainManager configFilterChainManager,final Properties properties){ //开启定时器，执行周期1s this.executor.scheduleWithFixedDelay(new Runnable(){

2022-05-10 20:45:21 322

原创通过ThreadLocal维护线程封闭性

private static ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>(){ public Connection initialValue(){ return DriverManager.getConnection(DB_URL); }};public static Connection getConnection(){ return connecti

2022-04-17 15:39:41 155

原创通过RestTemplate读取配置信息

初始化RestTemplate@Configurationpublic class OpenApiConfig{ @Bean public RestTemplate restTemplate(){ SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory(); requestFactory.setconnectTimeout(2000); requestFactor

2022-04-06 18:05:33 242

原创用NacosConfigService从配置中心获取配置信息

1.导入NacosClient依赖包<dependency> <grpupId>com.alibaba.nacos</groupId> <artifactId>nacos-client</artifactId> <version>1.3.1</version></dependency>2.用NacosConfigService从配置中心获取配置信息@Configurationpublic

2022-03-31 12:29:57 3119

原创给NacosConfig开启定时任务，定时检查配置信息

public class ClientWorker implements Closeable{ public ClientWorker(final HttpAgent agent,final ConfigFilterChainManager configFilterChainManager,final Properties properties){ //开启定时器，执行周期为2s this.executor.scheduleWithFixedDelay(new Runnable(){

2022-03-30 14:47:02 670

原创用文件存储Nacos元数据

@Componentpublic class RaftStore implements Closeable{ ... private final Properties meta = new Properties(); private static final String META_FILE_NAME= DATA_BASE_DIR+File.separator+"meta.properties"; private static final String CACHE_DIR = DATA_B

2022-03-29 17:13:55 692

原创用缓存存储Nacos元数据

@Componentpublic class DataStore{ //内存缓存对象 private Map<String,Datum> dataMap = new ConcurrentHashMap<>(1024); public void put(String key,Datum value){ dataMap.put(key,value); } public Datum remove(String key){ return dataMa

2022-03-29 16:49:31 608

原创 NacosRule实现服务发现的负载均衡

初始化NacosRule@Configurationpublic class NacosRibbonRuleConfig{ @Bean public NacosRule nacosRule(){ return new NacosRule(); } @LoadBalanced @Bean public RestTemplate restTemplate(){ return new RestTemplate(); } //配置全局负载均衡 @Co

2022-03-27 20:02:13 407

原创分布式系统幂等性设计及其服务端和消费端代码实现JAVA

分布式Id获取@DubboService(version="1.0.0",group="distributed-uuid-server")public class DistributedServiceImpl implements DistributedService{ @Autowired private Snowflakeconfig snowflakeConfig; Map<String,SnowFlake> snowFlakeHandlerMap = new Concur

2022-03-25 22:49:12 748

原创通过AOP切面和事件中心拦截服务注册

@Aspectpublic class DubboServiceRegistrartionEventPublishingAspect implements ApplicationEventPublisherAware{ //定义切面，拦截Spring cloud的ServiceRegistry接口的注册方法 public static final String REGISTER_POINTCUT_EXPRESSION = "execution(* org.springframework.cloud

2022-03-24 16:29:01 504

原创 NacosRegistration类维护Nacos元数据代码逻辑

public class NacosRegistration implements Registration,ServiceInstance{ ... @PostConstruct //读取开发人员在应用的配置文件中配置的元数据 Map<String,String> metadata = nacosDiscoveryProperties.getMetadata(); Environment env = context.getEnvironment(); Str

2022-03-24 15:16:34 787

原创表名的动态替换mysql

添加配置类@Configuration@MapperScan("com.xxx.aaa.mapper")//对应的mapper文件目录路径public class MybatisPlusConfig{ @Resource private UserService userService; @Bean public MybatisPlusInterceptor mybatisPlusInterceptor(){ MybatisPlusInterceptor interceptor

2022-03-23 14:50:48 1548

原创 spring-boot多数据源

1.配置多数据源的配置信息spring: datasource: dynamic: primary:master lazy:true strict:false datasource: url:jdbc:mysql://ip:port:dataname?.......代码实现1.引入依赖<dependency> <groupId>com.baomidou</groupId> <a

2022-03-22 17:27:35 603

原创 Mybatis-plus实现乐观锁

设计思路1.取出当前需要更新的记录，并获取当前版本好version2.在更新时候带上version3.执行更新时，sql中加入如下逻辑set version = new_version where version = old_version## 代码实现2.数据库实例表当中添加字段version2.添加mybatis全局配置```java@Configurationpublic class MybatisPlusOptLockerConfig{ @Bean public

2022-03-22 17:04:30 1010

原创订单缓冲同步到订单中心代码实例

Map<RoundRobinTable.Table,Long> lastIdMap = Maps.newHashMap();Map<RoundRobinTable.Table,Object> lastOrderIdMap = Maps.newHashMap();while(running){ RoundTable.Table table.= roundRobinTable.nextTable(); //批量查询缓冲表 List<Map<String,Obj

2022-03-16 19:05:33 499

原创 JAVA的MQ双写示例

public OrderDto create(final OrderDto order) throws OrderException{ OrderDto createOrderDto = executeInShardingTrans((status)->{ OrderDto insertOrderDto = convert(orderService.insert(order)); return insertOrderDto;});//发MQorderMqProducer.publis

2022-03-16 18:13:36 578

原创 JAVA异步Web服务实现

public void submitFuture(final HttpServletRequest req,final Callable<CompletableFuture> task) throwsException{ final String uri = req.getRequestURI(); final Map<String,String[]> params = req.getParameterMap(); final AsyncContext asyncCont

2022-03-15 15:34:44 745

原创异步编排CompletableFuture

场景一，并发调用，结果并集处理public static void test() throws Exception{ MyService service = new MyService(); CompletableFuture<String> future1 = sevice.getData("http://www.baidu.com"); CompletableFuture<String> future2 = service.getData("www.tx.com")

2022-03-14 21:00:30 513

原创 java的异步Callback任务

public class AsyncTest{ public static HttpAsyncClient httpAsyncClient; public static CompletableFuture<String> getHttpData(String url){ CompletableFuture asyncFuture = new completableFuture(); HttpAsyncRequestProducer producer = HttpAsync

2022-03-14 19:06:14 1042

原创异步Future并行处理业务请求代码示例

线程池配合Future实现，但是阻塞主请求线程，高并发时依然会造成线程数过多，CPU上下文切换，通过Future可以并发发出N个请求，然后等待最慢的一个返回，总响应时间为最慢的一个请求返回的用时public class Test{ final static ExecutorService executor = Executors.newFixedThreadPool(2); public static void main(String[] args){ RpcService rpc

2022-03-14 18:17:55 493

原创 java线程池的类型和创建方式

1.单线程线程池ExecutorService executorService = Executors.newSingleThreadExecutor();//等价于return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1,1,0L,TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()))2.创建固定的线程池ExecutorS

2022-03-14 17:05:30 463

原创验证数据库连接有效性Druid

public boolean validateObject(PooledObject<PoolableConnection> p){ try{ validateLifeTime(p); validateConnection(p.getObject()); return true; }catch(Exception e){ return false; }}private void validateLifetime(PooledObject<P

2022-03-13 15:22:46 1571

原创缓存的崩溃与快速修复

取模对于取模机制，如果其中一个实例坏掉，摘除此实例将会导致大量的缓存不命中，则瞬间的大流量导致后端数据服务或后端服务出现问题，对于这种情况，可以采用主从机制来避免实例坏了的问题，其中一个实例坏了可以用从/主顶上来，但是取模机制下增加一个节点会导致大量缓存不命中，一般是建立另一个集群，然后把数据迁移到新集群，把流量迁移过去。一致性HASH对于一致性哈希，如果其中一个实例坏了，摘除此实例只影响一致性哈希上的部分缓存不命中，不会导致大量缓存瞬间回源到后端/数据库服务，但是会产生一定的影响快速恢复如果出现

2022-03-13 14:53:27 1064

java8讲义与实战全篇

JavaGuide-main.zip

空空如也