添加模块基于netty的rpc调用

Author: wearewin

demo/pom.xml

@@ -28,6 +28,10 @@
             <artifactId>watermark</artifactId>
             <version>1.3</version>
         </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

netty/netty-rpc/pom.xml

@@ -65,6 +65,12 @@
             <artifactId>commons-lang</artifactId>
             <version>2.6</version>
         </dependency>
+        <dependency>
+            <groupId>commons-lang</groupId>
+            <artifactId>commons-lang</artifactId>
+            <version>2.6</version>
+            <scope>compile</scope>
+        </dependency>
 
     </dependencies>
 

persist/persist-mybatisplus/src/main/java/com/salk/lib/persist/User.java

@@ -0,0 +1,67 @@
+package com.salk.lib.persist;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+/**
+ * 用户
+ *
+ * @author salkli
+ * @date 2022/10/11
+ * @since 2022/10/11
+ */
+
+@TableName(value = "user")
+public class UserPo {
+    private Long id;
+    private String name;
+    @TableField(value = "age")
+    private String age1;
+    private String email;
+
+    public UserPo(Long id, String name, String age1, String email) {
+        this.id = id;
+        this.name = name;
+        this.age1 = age1;
+        this.email = email;
+    }
+
+    public UserPo() {}
+
+    public Long getId() {
+        return id;
+    }
+
+    public UserPo setId(Long id) {
+        this.id = id;
+        return this;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public UserPo setName(String name) {
+        this.name = name;
+        return this;
+    }
+
+    public String getAge1() {
+        return age1;
+    }
+
+    public UserPo setAge1(String age1) {
+        this.age1 = age1;
+        return this;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public UserPo setEmail(String email) {
+        this.email = email;
+
+        return this;
+    }
+}

persist/persist-mybatisplus/src/main/java/com/salk/lib/persist/UserPo.java

@@ -1,14 +1,14 @@
 package com.salk.lib.persist.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.salk.lib.persist.User;
+import com.salk.lib.persist.UserPo;
 
 /**
  * 用户映射器
  *
  * @author salkli
  * @date 2022/10/11
  */
-public interface UserMapper extends BaseMapper<User> {
+public interface UserMapper extends BaseMapper<UserPo> {
 
 }

persist/persist-mybatisplus/src/main/java/com/salk/lib/persist/mapper/UserMapper.java

@@ -2,11 +2,11 @@
 
 import java.util.List;
 
+import com.salk.lib.persist.mapper.UserMapper;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
-import com.salk.lib.persist.mapper.UserMapper;
 
 
 /**
@@ -19,16 +19,30 @@
 public class UserTest {
 
 @Autowired
-private  UserMapper userMapper;
+private UserMapper userMapper;
+
+    /**
+     * 测试查询
+     */
+    @Test
+    public void testSelect(){
+        List<UserPo> users = userMapper.selectList(null);
+        System.out.println("姓名"+users.get(0).getName());
+
+    }
 
     /**
      * 测试插入
      */
     @Test
     public void testInsert(){
-        List<User> users = userMapper.selectList(null);
-        System.out.println(users);
-
+        //List<UserPo> users = userMapper.selectList(null);
+        //System.out.println("记录数1=========="+users.size());
+        UserPo user = new UserPo(10L, "salk", "20", "[email protected]");
+        int insert = userMapper.insert(user);
+        List<UserPo> users2 = userMapper.selectList(null);
+        System.out.println("记录数=========="+users2.size());
     }
 
+
 }