Java高并发处理机制

简介: Java高并发处理机制

高并发处理的思路:


  • 扩容:水平扩容、垂直扩容
  • 缓存:将基础的数据放入缓存进行处理
  • 使用SpringCloud的注册中心,分服务注册到同一个注册中心,服务器检测使用Spring的熔断操作,检测服务器的心跳那个正常随机跳转到正常的服务器上

也可以使用熔断机制通过实现Hystrix会监测微服务间调用的状况,当失败的调用到一定阈值缺省是5秒内20次调用失败,就会启用熔断机制


熔断机制的注解是@HystrixCommand ,Hystrix会找到有这个的注解,并将这类方法关联到和熔断器连在一起的代理上,@HystrixCommand仅当类的注解为@Service和@Component时才会发挥作用。


微服务之间的调用有两种方式,一种是一个是RestTemplate,另一个是Feign。相对应,在这两种调用方式下,都有Hystrix调用方法


  • 数据量大的在数据库做集成处理

对于微服务项目开发中,多个微服务之间不仅是相对独立的,而且也是相对关联的。也就是说,微服务之间需要相互访问,多个微服务之间的接口可能会被互相调用多次,我们称之为微服务之间的通信。


  • 微服务之间的通信方式有很多种, 一般都是使用RestTemplate 或者Feign

RestTemplate,是Spring中方便使用rest资源的一个对象,交互访问的资源通过URL进行识别和定位。每次调用都使用模板方法的设计模式,模板方法依赖于具体的接口调用,从而实现了资源交互和调用。它的交互方法有30多种,大多数都是基于HTTP的方法,


例如:delete(),getForEntity(),getForObject(),put(),headForHeaders()

添加对应依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

启动添加负载均衡标识

@LoadBalanced
@Bean
public RestTemplate getRestTemplate() {
  return new RestTemplate();
}

服务提供类,服务名称:SERVICE1,端口:7082

@RestController
@RequestMapping("/service1")
public class TestController {
    
  @RequestMapping(value = "test", method = {RequestMethod.POST,RequestMethod.GET})
  public String testService(@RequestParam(value = "testParam") String testParam) {
    System.println.out(testParam);
    return "success";
  }
    
}

服务消费类

@RestController
@RequestMapping("/serviceFront")
public class ServiceFrontController {
 
  private final static String SERVICE1_URL = "http://SERVICE1:7082";
 
  private final static String SERVICE1 = "SERVICE1";
 
  @Autowired  
  LoadBalancerClient loadBalancerClient;
 
  @Autowired
  RestTemplate restTemplate;
 
  @RequestMapping(value = "testFront", method = RequestMethod.POST)
  public HashMap<String,Object> testFront(@RequestParam String testParam) {
    this.loadBalancerClient.choose(SERVICE1);// 随机访问策略
    String result = restTemplate.getForObject(SERVICE1_URL + "/service1/test?testParam={1}", String.class, testParam);
    HashMap<String,Object> map = new HashMap<String,Object>();
    map.put("result", "测试结果!"+result);
    return map;
  }
}

RestTemplate发送post请求,主要的参数有如下几种


  • String url : 请求的路径
  • Object request:请求体【@RequestBody 注解接收】,或者是一个HttpEntity对象(包含请求参数,请求头)
  • Class< T> responseType:接收返回数据的类型
  • Map<String,?> uriVariables: uri 变量, 这是放置变量的地方
  • Object… uriVariables:可变长 Object 类型 参数
restTemplate.postForObject("http://XXXXXXXX?name={name}&age={age}", request, JSONObject.class, name,age);

Feign,是声明式的伪HTTP客户端,使得编写HTTP客户端更新容易,只需要创建一个接口,并且使用注解的方式去配置,即可完成对服务提供方接口的绑定,大大简化了代码量,同时它还具有可拔插的注解特性,而且支持feign自定义的注解和springMvc的注解。

添加具体的Feign依赖

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>

在启动类Application添加feign注解,声明启动feign客户端

@EnableFeignClients

服务提供类,服务名称:SERVICE2 端口7083

@RestController
@RequestMapping("/service2")
public class TestController{
  
  @RequestMapping(value = "test2", method = {RequestMethod.POST,RequestMethod.GET})
  public String test2(@RequestParam(value = "testParam2") String testParam2) {
    System.println.out(testParam2);
    return "success";
  }
  
}

服务消费接口类

@FeignClient(name = "SERVICE2")
public interface TestFeignClient { 
  
  @RequestMapping(value="/service2/test2",method = RequestMethod.GET)
  public String test2(@RequestParam("testParam2") String testParam2);
    
}

服务消费控制层

@RestController
@RefreshScope
@RequestMapping("/serviceFront2")
public class TestFeignController {
  
  @Autowired
  private TestFeignClient testFeignClient;
 
  @RequestMapping(value = "test2", method = { RequestMethod.POST })
  public HashMap<String,Object> test2(@RequestParam String testParam2) {    
    String result = testFeignClient.test2(testParam2);
    HashMap<String,Object> map = new HashMap<String,Object>();
    map.put("result", "测试结果!"+result);
    return map;
  }
}

总之,微服务之间的通讯方式可以多种并存,各有优势,在项目实践中可具体情况具体分析

目录
相关文章
|
4天前
|
XML 安全 Java
Java反射机制:解锁代码的无限可能
Java 反射(Reflection)是Java 的特征之一,它允许程序在运行时动态地访问和操作类的信息,包括类的属性、方法和构造函数。 反射机制能够使程序具备更大的灵活性和扩展性
15 5
Java反射机制:解锁代码的无限可能
|
3天前
|
存储 缓存 安全
🌟Java零基础:深入解析Java序列化机制
【10月更文挑战第20天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
13 3
|
3天前
|
安全 Java UED
深入理解Java中的异常处理机制
【10月更文挑战第25天】在编程世界中,错误和意外是不可避免的。Java作为一种广泛使用的编程语言,其异常处理机制是确保程序健壮性和可靠性的关键。本文通过浅显易懂的语言和实际示例,引导读者了解Java异常处理的基本概念、分类以及如何有效地使用try-catch-finally语句来处理异常情况。我们将从一个简单的例子开始,逐步深入到异常处理的最佳实践,旨在帮助初学者和有经验的开发者更好地掌握这一重要技能。
9 2
|
5天前
|
Java 数据库连接 开发者
Java中的异常处理机制####
本文深入探讨了Java语言中异常处理的核心概念,通过实例解析了try-catch语句的工作原理,并讨论了finally块和throws关键字的使用场景。我们将了解如何在Java程序中有效地管理错误,提高代码的健壮性和可维护性。 ####
|
8天前
|
安全 Java 程序员
深入浅出Java中的异常处理机制
【10月更文挑战第20天】本文将带你一探Java的异常处理世界,通过浅显易懂的语言和生动的比喻,让你在轻松阅读中掌握Java异常处理的核心概念。我们将一起学习如何优雅地处理代码中不可预见的错误,确保程序的健壮性和稳定性。准备好了吗?让我们一起踏上这段旅程吧!
20 6
|
5天前
|
存储 运维 Java
💻Java零基础:深入了解Java内存机制
【10月更文挑战第18天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
17 1
|
8天前
|
存储 Java 程序员
Java面试加分点!一文读懂HashMap底层实现与扩容机制
本文详细解析了Java中经典的HashMap数据结构,包括其底层实现、扩容机制、put和查找过程、哈希函数以及JDK 1.7与1.8的差异。通过数组、链表和红黑树的组合,HashMap实现了高效的键值对存储与检索。文章还介绍了HashMap在不同版本中的优化,帮助读者更好地理解和应用这一重要工具。
25 5
|
6天前
|
缓存 监控 Java
Java 线程池在高并发场景下有哪些优势和潜在问题?
Java 线程池在高并发场景下有哪些优势和潜在问题?
|
8天前
|
Java
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件成立时被唤醒,从而有效解决数据一致性和同步问题。本文通过对比其他通信机制,展示了 `wait()` 和 `notify()` 的优势,并通过生产者-消费者模型的示例代码,详细说明了其使用方法和重要性。
15 1
|
1天前
|
SQL Java
探索Java中的异常处理机制
【10月更文挑战第26天】 在本文中,我们将深入探讨Java编程语言的异常处理机制。通过分析不同类型的异常、异常的捕获与抛出方式,以及如何自定义异常类,读者将能够更好地理解并应用Java中的异常处理机制来提高代码的健壮性和可读性。
7 0