2. 程式人生 > 實用技巧 >十次方微服務專案開發實踐,交友微服務

十次方微服務專案開發實踐,交友微服務

阿新 • • 發佈：2020-09-16

一、需求分析

交友微服務本身的功能:
（1）當用戶登陸後在推薦好友列表中點選“心”，表示喜歡此人 ，在資料庫tb_friend表中插入一條資料，islike 為0
（2）當你點選了喜歡過的人，也喜歡了你 , 表示互粉成功！也向tb_friend表中插入一條資料，islike為1 ，並且將你喜歡她的資料islike也修改為1
（3）當你點選了不喜歡某人（點選了叉），向tb_nofriend新增記錄.
（4）當兩個人互粉後，其中一人不喜歡對方了，刪除好友表中的記錄 ，向非好友表中新增記錄
什麼場景下使用springCloud呢？
我們來看使用者表，有兩列： fanscount 表示粉絲數 ，followcount表示關注數

（1）當用戶點選了喜歡：
比如小寶關注了楚楚，小寶的followcount（關注數）加1 ， 楚楚的fanscount （粉絲數）加1
（2）當用戶刪除了好友：
比如楚楚刪除了好友小寶，小寶的fanscount （粉絲數）減1 ，楚楚的followcount（關注數）減1

二、交友微服務-新增與刪除好友

1.搭建模組

（1）建立工程tensquare_friend，pom.xml引入依賴

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.tensquare</groupId>
            <artifactId>tensquare_common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27

（2）建立application.yml

server:
  port: 9010
spring:
  application:
    name: tensquare-friend #指定服務名
  datasource:
    driverClassName: com.mysql.jdbc.Driver
    url: jdbc:mysql://192.168.192.130:3306/tensquare_friend?characterEncoding=UTF8&&useSSL=false
    username: root
    password: 123456
  jpa:
    database: MySQL
    show-sql: true
jwt:
  config:
    key: eknaij
    ttl: 360000
eureka:
  client:
    service-url:
      defaultZone: http://localhost:6868/eureka
  instance:
    prefer-ip-address: true
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

（3）編寫啟動類

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@EnableFeignClients
public class FriendApplication {
    public static void main(String[] args) {
        SpringApplication.run(FriendApplication.class, args);
    }
    @Bean
    public IdWorker idWorkker(){
        return new IdWorker(1, 1);
    }
    @Bean
    public JwtUtil jwtUtil(){
        return new util.JwtUtil();
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17

（4）建立JwtFilter（參見User工程）
（5）建立ApplicationConfig（參見User工程）

2.新增好友
（1）建立實體類

@Entity
@Table(name="tb_friend")
@IdClass(Friend.class)
public class Friend implements Serializable {
    @Id
    private String userid;
    @Id
    private String friendid;
    private String islike;
    public String getUserid() {
        return userid;
    }
    public void setUserid(String userid) {
        this.userid = userid;
    }
    public String getFriendid() {
        return friendid;
    }
    public void setFriendid(String friendid) {
        this.friendid = friendid;
    }

    public String getIslike() {
        return islike;
    }

    public void setIslike(String islike) {
        this.islike = islike;
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30

（2）新建dao包，建立FriendDao介面

/**
 * 交友資料訪問層
 */
public interface FriendDao extends JpaRepository<Friend,String> {
    /**
     * 根據使用者ID與被關注使用者ID查詢記錄個數
     * @param userid
     * @param friendid
     * @return
     */
    @Query("select count(f) from Friend f where f.userid=?1 and f.friendid=?2")
    public int selectCount(String userid,String friendid);
    /**
     * 更新為互相喜歡
     * @param userid
     * @param friendid
     */
    @Modifying
    @Query("update Friend f set f.islike=?3 where f.userid=?1 and f.friendid=?2")
    public void updateLike(String userid,String friendid,String islike);
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21

（3）建立業務邏輯類
建立com.tensquare.friend.service包，包下建立類FriendService

@Service
public class FriendService {
    @Autowired
    private FriendDao friendDao;
    @Transactional
    public int addFriend(String userid,String friendid){
        //判斷如果使用者已經添加了這個好友，則不進行任何操作,返回0
        if(friendDao.selectCount(userid, friendid)>0){
            return 0;
        }
        //向喜歡錶中新增記錄
        Friend friend=new Friend();
        friend.setUserid(userid);
        friend.setFriendid(friendid);
        friend.setIslike("0");
        friendDao.save(friend);
        //判斷對方是否喜歡你，如果喜歡，將islike設定為1
        if(friendDao.selectCount( friendid,userid)>0){
            friendDao.updateLike(userid,friendid,"1");
            friendDao.updateLike(friendid,userid,"1");
        }
        return 1;
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

（4）控制器類
建立包com.tensquare.friend.controller，包下建立FriendController

@RestController
@RequestMapping("/friend")
public class FriendController {
    @Autowired
    private FriendService friendService;
    @Autowired
    private HttpServletRequest request;
    /**
     * 新增好友
     * @param friendid 對方使用者ID
     * @param type 1：喜歡 0：不喜歡
     * @return
     */
    @RequestMapping(value="/like/{friendid}/{type}",method= RequestMethod.PUT)
    public Result addFriend(@PathVariable String friendid , @PathVariable String type){
        Claims claims=(Claims)request.getAttribute("user_claims");
        if(claims==null){
            return new Result(false, StatusCode.ACCESSERROR,"無權訪問",null);
        }
        //如果是喜歡
        if(type.equals("1")){
            if(friendService.addFriend(claims.getId(),friendid)==0){
                return new Result(false, StatusCode.REPERROR,"已經新增此好友",null);
            }
        }else{
        //不喜歡
        }
        return new Result(true, StatusCode.OK, "操作成功",null);
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30

（5）測試：
啟動使用者微服務，登陸使用者獲取token
啟動交友微服務，通過postMan測試http://localhost:9010/friend/like/1/1,新增頭資訊Authorization 內容為Bearer 加上獲取的token.

三、新增非好友

需求：當用戶點選不喜歡某人，將對方的ID記錄不喜歡列表中
（1）構建實體類

@Entity
@Table(name="tb_nofriend")
@IdClass(NoFriend.class)
public class NoFriend implements Serializable {
    @Id
    private String userid;
    @Id
    private String friendid;
    public String getUserid() {
        return userid;
    }
    public void setUserid(String userid) {
        this.userid = userid;
    }
    public String getFriendid() {
        return friendid;
    }
    public void setFriendid(String friendid) {
        this.friendid = friendid;
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

（2）建立資料訪問介面

/**
 * 不喜歡列表資料訪問層
 */
public interface NoFriendDao extends JpaRepository<NoFriend,String> {
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6

（3）修改業務邏輯類FriendService

    @Autowired
    private NoFriendDao noFriendDao;
    /**
     * 向不喜歡列表中新增記錄
     * @param userid
     * @param friendid
     */
    public void addNoFriend(String userid,String friendid){
        NoFriend noFriend=new NoFriend();
        noFriend.setUserid(userid);
        noFriend.setFriendid(friendid);
        noFriendDao.save(noFriend);
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13

（2）修改FriendController的addFriend方法
在else中新增：

  friendService.addNoFriend(claims.getId(),friendid);//向不喜歡列表中新增記錄
  • 1

四、刪除好友

（1）FriendDao新增方法定義

    /**
     * 刪除喜歡
     * @param userid
     * @param friendid
     */
    @Modifying
    @Query("delete from Friend f where f.userid=?1 and f.friendid=?2")
    public void deleteFriend(String userid,String friendid);
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（2）FriendService新增方法


    /**
     * 刪除好友
     * @param userid
     * @param friendid
     */
    @Transactional
    public void deleteFriend(String userid,String friendid){
        friendDao.deleteFriend(userid,friendid);
        friendDao.updateLike(friendid,userid,"0");
        addNoFriend(userid,friendid);//向不喜歡錶中新增記錄
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12

（3）FriendController新增方法


    /**
     * 刪除好友
     * @param friendid
     * @return
     */
    @RequestMapping(value="/{friendid}",method=RequestMethod.DELETE)
    public Result remove(@PathVariable String friendid){
        Claims claims=(Claims)request.getAttribute("user_claims");
        if(claims==null){
            return new Result(false, StatusCode.ACCESSERROR,"無權訪問",null);
        }
        friendService.deleteFriend(claims.getId(), friendid);
        return new Result(true, StatusCode.OK, "刪除成功",null);
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16

五、粉絲數與關注數的變更

1.變更粉絲數

（1）修改tensquare_user工程的UserDao，增加方法定義

    /**
     * 更新粉絲數
     * @param userid 使用者ID
     * @param x 粉絲數
     */
    @Modifying
    @Query("update User u set u.fanscount=u.fanscount+?2 where u.id=?1")
    public void incFanscount(String userid,int x);
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（2）UserService增加方法

	/**
	 * 更新粉絲數
	 * @param x
	 */
	@Transactional
	public void incFanscount(String userid,int x){
		userDao.incFanscount(userid,x);
	}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（3）UserController增加方法

	/**
	 * 增加粉絲數
	 * @param userid
	 * @param x
	 */
	@RequestMapping(value="/incfans/{userid}/{x}",method= RequestMethod.POST)
	public void incFanscount(@PathVariable String userid,@PathVariable int x){
		userService.incFanscount(userid,x);
	}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

2.變更關注數

（1）修改tensquare_user工程的UserDao，增加方法定義

    /**
     * 更新關注數
     * @param userid 使用者ID
     * @param x 粉絲數
     */
    @Modifying
    @Query("update User u set u.followcount=u.followcount+?2 where u.id=?1")
    public void incFollowcount(String userid,int x);
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（2）UserService增加方法

	/**
	 * 更新關注數
	 * @param x
	 */
	@Transactional
	public void incFollowcount(String userid,int x){
		userDao.incFollowcount(userid,x);
	}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（3）UserController增加方法

	/**
	 * 增加關注數
	 * @param userid
	 * @param x
	 */
	@RequestMapping(value="/incfollow/{userid}/{x}",method= RequestMethod.POST)
	public void incFollowcount(@PathVariable String userid,@PathVariable int x){
		userService.incFollowcount(userid,x);
	}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

六、呼叫使用者微服務

1.喜歡某人更新使用者資料

（1）在tensquare_friend模組建立 com.tensquare.friend.client包，包下建立介面

/**
 * 使用者客戶端
 */
@FeignClient("tensquare-user")
public interface UserClient {
    
    /**
     * 增加粉絲數
     * @param userid
     * @param x
     */
    @RequestMapping(value="/user/incfans/{userid}/{x}",method= RequestMethod.POST)
    public void incFanscount(@PathVariable("userid") String userid, @PathVariable("x") int x);

    /**
     * 增加關注數
     * @param userid
     * @param x
     */
    @RequestMapping(value="/user/incfollow/{userid}/{x}",method= RequestMethod.POST)
    public void incFollowcount(@PathVariable("userid") String userid,@PathVariable("x") int x);
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

@FeignClient註解用於指定從哪個服務中呼叫功能
@RequestMapping註解用於對被呼叫的微服務進行地址對映。
注意 @PathVariable註解一定要指定引數名稱，否則出錯
（2）修改FriendService ，注入UserClient

@Autowired
private UserClient userClient;
  • 1
  • 2

修改addFriend方法,增加對userClient方法的呼叫

    @Autowired
    private UserClient userClient;
    ........
    ........
        //如果是喜歡
        userClient.incFollowcount(claims.getId(),1);//增加自己的關注數
        userClient.incFanscount(friendid,1);//增加對方的粉絲數
        return new Result(true, StatusCode.OK, "操作成功",null);
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

2.刪除好友更新使用者資料

修改FriendService的deleteFriend方法 ,增加呼叫

        userClient.incFollowcount(claims.getId(),-1);//減少自己的關注數
        userClient.incFanscount(friendid,-1);//減少對方的粉絲數

相關推薦

十次方微服務專案開發實踐,交友微服務

一、需求分析 交友微服務本身的功能:（1）當用戶登陸後在推薦好友列表中點選“心”，表示喜歡此人 ，在資料庫tb_friend表中插入一條資料，islike 為0（2）當你點選了喜歡過的人，也喜歡了你 , 表示互粉成功

SpringCloud 微服務最佳開發實踐

Maven規範 所有專案必須要有一個統一的parent模組 所有微服務工程都依賴這個parent，parent用於管理依賴版本，maven倉庫，jar版本的統一升級維護

Python + Flask 專案開發實踐系列《一》

歡迎關注【無量測試之道】公眾號，回覆【領取資源】,Python程式設計學習資源乾貨、Python+Appium框架APP的UI自動化、Python+Selenium框架Web的UI自動化、Python+Unittest框架API自動化、

Python + Flask 專案開發實踐系列《二》

歡迎關注【無量測試之道】公眾號，回覆【領取資源】,Python程式設計學習資源乾貨、Python+Appium框架APP的UI自動化、Python+Selenium框架Web的UI自動化、Python+Unittest框架API自動化、

Python + Flask 專案開發實踐系列《五》

歡迎關注【無量測試之道】公眾號，回覆【領取資源】,Python程式設計學習資源乾貨、Python+Appium框架APP的UI自動化、Python+Selenium框架Web的UI自動化、Python+Unittest框架API自動化、

Python + Flask 專案開發實踐系列《六》

歡迎關注【無量測試之道】公眾號，回覆【領取資源】,Python程式設計學習資源乾貨、Python+Appium框架APP的UI自動化、Python+Selenium框架Web的UI自動化、Python+Unittest框架API自動化、

Python + Flask 專案開發實踐系列《七》

歡迎關注【無量測試之道】公眾號，回覆【領取資源】,Python程式設計學習資源乾貨、Python+Appium框架APP的UI自動化、Python+Selenium框架Web的UI自動化、Python+Unittest框架API自動化、

Dapr微服務應用開發系列3：服務呼叫構件塊

題記：這篇開始逐一深入介紹各個構件塊，從服務呼叫開始 原理 所謂服務呼叫，就是通過這個構件塊讓你方便的通過HTTP或者gRPC協議同步呼叫其他服務的方法，這些方法也是通過HTTP或者gRPC來暴露的。而方便的含義在於，

使用雲伺服器ECS搭建DoH服務的開發實踐

本文來自於雲伺服器ECS徵文活動投稿，已獲得作者（暱稱紹羽）授權釋出。  

美團點評境外度假團隊前端專案開發實踐總結

前言 隨著前端專案數量和規模越來越大，參與的人員也越來越多，如何在前端專案開發過程中保證優質的開發者體驗和專案的可維護性，同時確保極致的使用者體驗將會是一個非常大的挑戰。

【十次方微服務後臺開發】Day01：環境、快取（吐槽）、ES搜尋文章、MQ註冊時傳送驗證碼

一、系統設計與工程搭建 1、需求分析 程式設計師的專屬社交平臺，包括頭條、問答、活動、交友、吐槽、招聘

【微服務社交平臺十次方】【前端01】前端環境搭建

〇、學習目標： 瞭解十次方需求、技術架構，理解前後端分離開發模式 掌握Node.js基本使用方法，理解模組化程式設計

SpringCloud微服務實戰——搭建企業級開發框架（十九）：Gateway使用knife4j聚合微服務文件

  本章介紹Spring Cloud Gateway閘道器如何整合knife4j,通過閘道器聚合所有的Swagger微服務文件

SpringCloud微服務實戰——搭建企業級開發框架（三十五）：SpringCloud + Docker + k8s實現微服務叢集打包部署-叢集環境部署

一、叢集環境規劃配置 生產環境不要使用一主多從，要使用多主多從。這裡使用三臺主機進行測試一臺Master（172.16.20.111），兩臺Node（172.16.20.112和172.16.20.113）

【SpringCloud技術專題】「Gateway網關係列」（3）微服務閘道器服務的Gateway全流程開發實踐指南（2.2.X）

開發指南須知 本次實踐主要在版本：2.2.0.BUILD-SNAPSHOT上進行構建，這個專案提供了構建在Spring生態系統之上API閘道器。

十四、Docker入門系列--Docker搭建部署SpringCloud微服務專案Demo

十四、Docker入門系列--Docker搭建部署SpringCloud微服務專案Demo 系列文章地址：一、Docker入門系列--Docker 簡介二、Docker入門系列--Docker安裝三、Docker入門系列--Docker常用命令四、Docker入門系列--Docker映象

java開發面試問答----微服務篇

java開發面試問答----基礎篇 java開發面試問答----多執行緒篇 java開發面試問答----spring框架及資料庫快取篇

SpringBoot專案開發(二十一)：Gzip壓縮

為了減少資料在網路中的傳輸量，從而減少傳輸時長，增加使用者體驗，瀏覽器大都是支援Gzip壓縮技術的，http的請求頭 Accept-Encoding:gzip, deflate 就表示這次請求可以接受Gzip壓縮後的資料，圖片不要進行壓縮，因為

Spring Boot 服務端開發專案目錄結構

後端伺服器的組成： pom.xml（Maven專案配置檔案） + java資料夾 + resource資料夾 程式碼層（java）,根目錄com.xxx：XxxApplication.java + 對應模組程式碼（domain + controller + service + mapper等）

第十講：企業級監控資料採集指令碼開發實踐

　　第十講內容 　　• pushgateway 的介紹 　　• pushgateway 的安裝和運⾏和配置