spring boot 怎么实现集群

Posted 2023-02-16

Helloworld使用传统的springmvc,需要配置web.xml,applicationContext.xml,然后打包为war在tomcat中运行，而如果使用springboot，一切都变得简单起来了。下面使用Maven来创建springboot的webapp工程pom.xml4.0.0org.springframeworkgs-spring-boot0.1.0org.springframework.bootspring-boot-starter-parent1.3.3.RELEASEorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-testtest1.8org.springframework.bootspring-boot-maven-pluginHelloControllerpackagehello;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;@RestControllerpublicclassHelloController@RequestMapping("/")publicStringindex()return"GreetingsfromSpringBoot!";其中：@RestController表示使用springmvc来接收request请求@RequestMapping映射到主页当请求返回的时候，是纯文本，那是因为@RestController是由@Controller和@ResponseBody组成Application@SpringBootApplicationpublicclassApplicationpublicstaticvoidmain(String[]args)ApplicationContextctx=SpringApplication.run(Application.class,args);System.out.println("Let'sinspectthebeansprovidedbySpringBoot:");其中：@SpringBootApplication代表了其有四个注解组成：@Configuration，@EnableAutoConfiguration，@EnableWebMvc，@ComponentScan在SpringApplication.run中会去自动启动tomcatrun方法返回上下文，在这个上下文中可以拿到所有的bean没有一行配置代码、也没有web.xml。基于SpringBoot的应用在大多数情况下都不需要我们去显式地声明各类配置，而是将最常用的默认配置作为约定，在不声明的情况下也能适应大多数的开发场景。总体而言springboot是对javawebapp开发的简化单元测试@RunWith(SpringJUnit4ClassRunner.class)@SpringApplicationConfiguration(classes=MockServletContext.class)@WebAppConfigurationpublicclassHelloControllerTestprivateMockMvcmvc;@Beforepublicvoidbefore()throwsExceptionmvc=MockMvcBuilders.standaloneSetup(newHelloController()).build();@Afterpublicvoidafter()throwsException/****Method:index()**/@TestpublicvoidtestIndex()throwsException//TODO:Testgoesheremvc.perform(MockMvcRequestBuilders.get("/").accept(MediaType.APPLICATION_JSON)).andExpect(status().isOk()).andExpect(content().string(equalTo("GreetingsfromSpringBoot!")));建立restfullweb服务器接上，使用srpingboot建立web服务器就非常简单了，首先建立一个pojo类publicclassGreetingprivatefinallongid;privatefinalStringcontent;然后使用control来handlehttp请求@RestControllerpublicclassGreetingControllerprivatestaticfinalStringtemplate="Hello,%s!";privatefinalAtomicLongcounter=newAtomicLong();@RequestMapping("/greeting")publicGreetinggreeting(@RequestParam(value="name",defaultValue="World")Stringname)returnnewGreeting(counter.incrementAndGet(),String.format(template,name));其中：@RequestParam表明了参数要求，如果要必填则设置required=true返回是一个对象，会被自动转换为json当我们访问：greeting时候返回"id":1,"content":"Hello,World!"greeting?name=User时候返回"id":2,"content":"Hello,User!"数据库访问另一个非常常用的问题。在传统开发中，我们需要配置：类路径上添加数据访问驱动实例化DataSource对象，指定url,username,password注入JdbcTemplate对象，如果使用Mybatis,还要配置框架信息下面一个例子讲述用用springboot来代替。数据访问层我们将使用SpringDataJPA和Hibernate（JPA的实现之一）。开始之前先介绍两个概念springdata为了简化程序与数据库交互的代码，spring提供了一个现成的dao层框架，spring家族提供的spring-data适用于关系型数据库和nosql数据库；例如SpringDataJPA,SpringDataHadoop,SpringDataMongoDB，SpringDataSolr等；具体的可以参考官网：.mysql.jdbc.Driverspring.datasource.password=xxx#SpecifytheDBMSspring.jpa.database=MYSQL#Showornotlogforeachsqlqueryspring.jpa.show-sql=true#Hibernateddlauto(create,create-drop,update)spring.jpa.hibernate.ddl-auto=update#Namingstrategyspring.jpa.hibernate.naming-strategy=org.hibernate.cfg.ImprovedNamingStrategy#strippedbeforeaddingthemtotheentitymanager)spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect其中，hibernate的ddl-auto=update配置表名，数据库的表和列会自动创建写下实体类：@Entity@Table(name="student")publicclassStudent@Id@GeneratedValue(strategy=GenerationType.AUTO)privatelongid;@NotNullprivateStringname;privateStringage;@Entity，说明被这个注解修饰的类应该与一张数据库表相对应，表的名称可以由类名推断，当然了，也可以明确配置，只要加上@Table(name="books")即可。需要特别注意，每个Entity类都应该有一个protected访问级别的无参构造函数，用于给Hibernate提供初始化的入口。@Idand@GeneratedValue：@Id注解修饰的属性应该作为表中的主键处理、@GeneratedValue修饰的属性应该由数据库自动生成，而不需要明确指定。@ManyToOne,@ManyToMany表明具体的数据存放在其他表中，在这个例子里，书和作者是多对一的关系，书和出版社是多对一的关系，因此book表中的author和publisher相当于数据表中的外键；并且在Publisher中通过@OneToMany（mapped="publisher"）定义一个反向关联（1——>n），表明book类中的publisher属性与这里的books形成对应关系。@Repository用来表示访问数据库并操作数据的接口，同时它修饰的接口也可以被componentscan机制探测到并注册为bean，这样就可以在其他模块中通过@Autowired织入。dao:@RepositorypublicinterfaceCustomerRepositoryextendsCrudRepositoryListfindByLastName(StringlastName);详细的可以看springjpa的具体介绍。最后使用：@RestControllerpublicclassDbController@AutowiredprivateStudentDaodao;@RequestMapping("/get-student-counts")@ResponseBodypublicStringgetAllStudents()Liststudents=(List)dao.findAll();returnString.format("%d",students.size());主要一点是：我在CustomerRepository实现中每天添加方法：findByLastName，@Autowired就会一直报错。 参考技术A

这个问题比较模糊，集群本身就是一个复杂的话题，你想在那一层实现集群（web？services？data？等等），你要达到的目的是什么？（负载均衡？宕机会话复制？性能要求？等等）

那么我只能就一些常见的场景，简单介绍Spring boot相关的集群技术

你的微服务如果是无状态的，你可以将它们部署在多个服务器实例上，在前端使用负载均衡器（例如nginx）。

如果你需要session复制，针对动态容错和部署，你可以看看spring-session

如果需要数据库集群，请参考数据库集群的相关技术，mongoDB，reddis都有自己的方案，

如果是数据缓存集群，也有很多参考，如memcache，Hazelcast等等，

如果你喜欢更不动脑子的套餐，可以看看spring cloud