这里基于 spring boot 开发一个服务提供者和一个服务消费者。没有服务发现组件,服务消费者直接通过 url 来访问服务提供者对外提供的服务。
使用 spring boot 创建项目 simple-provider-user。
引入依赖:
<dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-data-jpa</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency> <groupid>com.h2database</groupid> <artifactid>h2</artifactid> <scope>runtime</scope> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-test</artifactid> <scope>test</scope> </dependency> </dependencies>
准备数据 schema.sql:
drop table user if exists; create table user ( id bigint generated by default as identity, username varchar(40), name varchar(20), age int(3), balance decimal(10,2), primary key (id) ); insert into user (id, username, name, age, balance) values (1, 'account1', '张三', 20, 100.00); insert into user (id, username, name, age, balance) values (2, 'account2', '李四', 28, 180.00); insert into user (id, username, name, age, balance) values (3, 'account3', '王五', 32, 280.00);
实体类 user:
@entity public class user { @id @generatedvalue(strategy = generationtype.auto) private long id; @column private string username; @column private string name; @column private integer age; @column private bigdecimal balance; // setters getters }
创建 dao:
@repository public interface userrepository extends jparepository<user, long> { }
创建 controller:
@restcontroller public class usercontroller { @autowired private userrepository userrepository; @getmapping("/{id}") public user findbyid(@pathvariable long id) { user user = userrepository.findone(id); return user; } }
编写配置文件 application.yml:
server: port: 8000 spring: jpa: generate-ddl: false show-sql: true hibernate: ddl-auto: none datasource: platform: h2 logging: level: root: info org.hibernate: info
测试。访问 , 获得结果:
{ "id": 1, "username": "account1", "name": "张三", "age": 20, "balance": 100 }
使用 spring boot 创建一个引来如 web starter 的项目。
添加 resttemplate bean :
@springbootapplication public class simpleconsumermovieapplication { public static void main(string[] args) { springapplication.run(simpleconsumermovieapplication.class, args); } @bean public resttemplate resttemplate() { return new resttemplate(); } }
通过 resttemplate 访问服务提供者的 api:
@restcontroller public class moviecontroller { @autowired private resttemplate resttemplate; @getmapping("/user/{id}") public user findbyid(@pathvariable long id) { string url = "http://localhost:8000/" + id; return resttemplate.getforobject(url, user.class); } }
配置服务消费者启动端口:
server: port: 8010
测试:
分别启动服务提供者进程和服务消费者进行。访问:localhost:8010/user/1,结果如下:
{ "id": 1, "username": "account1", "name": "张三", "age": 20, "balance": 100 }
本示例中只有服务提供者和服务消费者两个角色,没有引入服务发现组件,存在一些缺点:
我们在访问服务提供者 api 时,是将将服务提供者的网络地址硬编码在代码中的(即使编写在配置文件中也算)。
如果服务提供者的网络地址发生变化,我们就需要去修改服务消费者的代码,然后重新发布。
为了构建一个良好的微服务系统,我们需要引入服务发现组件,这样服务提供者可以将自己的提供的服务信息注册到服务发现组件中,服务消费者可以通过服务发现组建获取到需要访问的服务信息,然后再去访问相关的服务。
如对本文有疑问, 点击进行留言回复!!
Springboot项目因为kackson版本问题启动报错解决方案
Java多线程下的其他组件之CyclicBarrier、Callable、Future和FutureTask详解
网友评论