spring 完结

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/Client.java

@@ -0,0 +1,23 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09;
+
+import com.example.shangguigu09.entity.User;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author yinkanglong
+ * @version : Client, v 0.1 2022-10-14 09:53 yinkanglong Exp $
+ */
+public class Client {
+
+    public static void main(String[] args) {
+        WebClient webClient = WebClient.create("http://127.0.0.1:62418");
+        User userMono = webClient.get().uri("/users/{id}", "1").accept(MediaType.APPLICATION_JSON).retrieve().bodyToMono(User.class).block();
+        System.out.println(userMono.getName());
+    }
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/Server.java

@@ -0,0 +1,55 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09;
+
+import com.example.shangguigu09.handler.UserHandler;
+import com.example.shangguigu09.service.UserService;
+import com.example.shangguigu09.service.impl.UserServiceImpl;
+import org.springframework.http.MediaType;
+import org.springframework.http.server.reactive.HttpHandler;
+import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter;
+import org.springframework.web.reactive.function.server.RouterFunction;
+import org.springframework.web.reactive.function.server.RouterFunctions;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.netty.http.server.HttpServer;
+
+
+import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
+import static org.springframework.web.reactive.function.server.RequestPredicates.accept;
+import static org.springframework.web.reactive.function.server.RouterFunctions.toHttpHandler;
+
+/**
+ * @author yinkanglong
+ * @version : Server, v 0.1 2022-10-14 07:59 yinkanglong Exp $
+ */
+public class Server {
+    //创建路由
+    public RouterFunction<ServerResponse> route(){
+        UserService userService = new UserServiceImpl();
+        UserHandler handler = new UserHandler(userService);
+
+        return RouterFunctions.route(GET("/users/{id}").and(accept(MediaType.APPLICATION_JSON)),handler::getUserById);
+//                .andRoute(GET("users").and(accept(MediaType.APPLICATION_JSON)),handler::getAllUsers)
+//                .andRoute(GET("saveuser").and(accept(MediaType.APPLICATION_JSON)),handler::saveUser);
+
+    }
+
+    public void createReactorServer(){
+        RouterFunction<ServerResponse> route = route();
+        HttpHandler httpHandler = toHttpHandler(route);
+
+        ReactorHttpHandlerAdapter reactorHttpHandlerAdapter = new ReactorHttpHandlerAdapter(httpHandler);
+
+        HttpServer httpServer = HttpServer.create();
+        httpServer.handle(reactorHttpHandlerAdapter).bindNow();
+    }
+
+    public static void main(String[] args) throws Exception{
+        Server server = new Server();
+        server.createReactorServer();
+        System.out.println("enter to exit");
+        System.in.read();
+    }
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/Shangguigu09Application.java

@@ -0,0 +1,13 @@
+package com.example.shangguigu09;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class Shangguigu09Application {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Shangguigu09Application.class, args);
+    }
+
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/entity/User.java

@@ -0,0 +1,78 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09.entity;
+
+/**
+ * @author yinkanglong
+ * @version : User, v 0.1 2022-10-13 19:01 yinkanglong Exp $
+ */
+public class User {
+    private String name;
+    private String gender;
+    private Integer age;
+
+    public User() {
+    }
+
+    public User(String name, String gender, Integer age) {
+        this.name = name;
+        this.gender = gender;
+        this.age = age;
+    }
+
+    /**
+     * Getter method for property <tt>name</tt>.
+     *
+     * @return property value of name
+     */
+    public String getName() {
+        return name;
+    }
+
+    /**
+     * Setter method for property <tt>counterType</tt>.
+     *
+     * @param name value to be assigned to property name
+     */
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    /**
+     * Getter method for property <tt>gender</tt>.
+     *
+     * @return property value of gender
+     */
+    public String getGender() {
+        return gender;
+    }
+
+    /**
+     * Setter method for property <tt>counterType</tt>.
+     *
+     * @param gender value to be assigned to property gender
+     */
+    public void setGender(String gender) {
+        this.gender = gender;
+    }
+
+    /**
+     * Getter method for property <tt>age</tt>.
+     *
+     * @return property value of age
+     */
+    public Integer getAge() {
+        return age;
+    }
+
+    /**
+     * Setter method for property <tt>counterType</tt>.
+     *
+     * @param age value to be assigned to property age
+     */
+    public void setAge(Integer age) {
+        this.age = age;
+    }
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/handler/UserHandler.java

@@ -0,0 +1,56 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09.handler;
+
+import com.example.shangguigu09.entity.User;
+import com.example.shangguigu09.service.UserService;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import static org.springframework.web.reactive.function.BodyInserters.fromObject;
+
+/**
+ * @author yinkanglong
+ * @version : UserHandler, v 0.1 2022-10-13 22:47 yinkanglong Exp $
+ */
+public class UserHandler {
+
+    private final UserService userService;
+    public UserHandler(UserService userService){
+        this.userService = userService;
+    }
+
+    //根据id
+    public Mono<ServerResponse> getUserById(ServerRequest request){
+        //获取id值
+        int  userid = Integer.valueOf( request.pathVariable("id"));
+        Mono<ServerResponse> notFound = ServerResponse.notFound().build();
+        //调用service方法取得数据
+        Mono<User> userMono = this.userService.getUserById(userid);
+
+        //UserMono进行转换返回。Reactor操作符
+        return userMono.flatMap(person->ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
+                .body(fromObject(person)))
+                .switchIfEmpty(notFound);
+
+    }
+
+    //所有用户
+    public Mono<ServerResponse> getAllUsers(){
+        Flux<User> users = this.userService.getAllUser();
+        return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(users,User.class);
+
+    }
+
+
+    //添加
+    public Mono<ServerResponse> saveUser(ServerRequest request){
+        Mono<User> userMono = request.bodyToMono(User.class);
+        return ServerResponse.ok().build(this.userService.savaUserInfo(userMono));
+    }
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/service/UserService.java

@@ -0,0 +1,24 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09.service;
+
+import com.example.shangguigu09.entity.User;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author yinkanglong
+ * @version : UserService, v 0.1 2022-10-13 19:02 yinkanglong Exp $
+ */
+public interface UserService {
+    //id查询用户
+    Mono<User> getUserById(int id);
+
+    //查询所有的用户
+    Flux<User> getAllUser();
+
+    //添加用户
+    Mono<Void> savaUserInfo(Mono<User> user);
+}

Spring/Spring5/code/shangguigu10/src/main/java/com/example/shangguigu09/service/impl/UserServiceImpl.java

@@ -0,0 +1,49 @@
+/**
+ * Alipay.com Inc.
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package com.example.shangguigu09.service.impl;
+
+import com.example.shangguigu09.entity.User;
+import com.example.shangguigu09.service.UserService;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author yinkanglong
+ * @version : UserServiceImpl, v 0.1 2022-10-13 19:02 yinkanglong Exp $
+ */
+@Service
+public class UserServiceImpl implements UserService {
+    private final Map<Integer,User> users = new HashMap<>();
+
+    public UserServiceImpl() {
+
+        this.users.put(1,new User("lucy","nan",10));
+        this.users.put(2,new User("mary","nv",38));
+        this.users.put(3,new User("jack","nv",32));
+
+    }
+
+    @Override
+    public Mono<User> getUserById(int id) {
+        return Mono.justOrEmpty(this.users.get(id));
+    }
+
+    @Override
+    public Flux<User> getAllUser() {
+        return Flux.fromIterable(this.users.values());
+    }
+
+    @Override
+    public Mono<Void> savaUserInfo(Mono<User> userMono) {
+        return userMono.doOnNext(person->{
+            int id = users.size() + 1;
+            users.put(id,person);
+        }).thenEmpty(Mono.empty());
+    }
+}

Spring/Spring5/code/shangguigu10/src/main/resources/application.properties

@@ -0,0 +1,2 @@
+
+server.port=8085

Spring/Spring5/code/shangguigu10/src/test/java/com/example/shangguigu09/Shangguigu09ApplicationTests.java

@@ -0,0 +1,13 @@
+package com.example.shangguigu09;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class Shangguigu09ApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}