消息化服務自實現設計_ZenDei技術網路在線

該項目主要將每個服務都配置一個消息隊列，服務間通過消息進行傳遞，同時提供了控制台指令，進行服務的管理，實現一些後臺的工作 git地址:https://coding.net/u/mich/p/MiniServer/git ...

背景

一直想自己試試設計一個只屬於自己的小框架，於是就有了這個項目。

代碼地址

https://coding.net/u/mich/p/MiniServer/git

項目說明

該項目主要將每個服務都配置一個消息隊列，服務間通過消息進行傳遞，同時提供了控制台指令，進行服務的管理，實現一些後臺的工作（主要web太麻煩了，所以控制台輸入最省力），該項目只處理過一些小型後臺任務，未在正式大型項目中實際使用過！

未來展望

1. 以後估計會將以往做過的微博用戶數據抓取，tower對接，股票數據抓取及分析等已開發的項目在該框架的基礎上實現（事實是原來以有一套類似小框架，但是後來被我嫌棄，現在重寫了）

2.可能會將該項目分散式，通過zookeeper分散式管理所有的服務

3.加入實時熱更新的功能，這也是服務消息化的主要原因

模塊介紹

主要模塊介紹就在上方的git地址看吧，此處省略

使用介紹

git上貼圖不方便，說明什麼的還是這裡介紹吧。這裡簡單介紹一下example文件夾內容。

主要實現功能就是抽獎功能，在獎池中設置幾個獎品，然後玩家多線程的去同時獲取獎品

1. PrizeServer

該類就設置一個prize屬性，作為獎品的數量，由於只有一個獎池，所以此服務設置為MiniServerType.SINGLETON，同時設置一下服務的名稱name（其實不設置也可以預設為類名），然後設置一個初始化函數打上 @MiniServerInit註解，把獎品的數量設置為2。對外，我設置了一個抽獎的方法drawPrize()判斷是不是有獎品，如果沒有就返回-1

package example.server;


import com.basic.stableserver.MenuMethod;
import com.basic.stableserver.MiniServerInfo;
import com.basic.stableserver.MiniServerInit;
import com.basic.stableserver.MiniServerType;
import com.basic.utils.Utils;

/**
 * Created by Mich on 17/7/7.
 */
@MiniServerInfo(value = MiniServerType.SINGLETON, name = "PrizeServer")
public class PrizeServer {
    private int prize;

    @MenuMethod
    public int drawPrize() {
        if (prize == 0) {
            return -1;
        }
        prize -= 1;
        return Utils.getRandom();
    }

    @MenuMethod
    public int getPrize() {
        return prize;
    }

    @MiniServerInit
    public void init() {
        this.prize = 2;
    }
}

2. PlayerServer

玩家服務，由於玩家不同於獎池只有一個，玩家會有很多個，所以設置了@MiniServerInfo(value = MiniServerType.PROTOTYPE, name = "PlayerServer", id = "id")，同樣為了區分每個玩家的信息，加入了id="id",除了id，同時設置了money.同樣我對玩家做了些初始化的操作，設置了錢，同時輸出了便於測試識別，退出時，我也輸出了日誌。對外，我也設置了幾個方法，主要為draw()抽獎方法，通過獲取獎池服務，call("drawPrize")來阻塞住消息，最後判斷返回獲得了什麼獎品，同時輸出獎品

package example.server;

import com.basic.stableserver.*;

/**
 * Created by Mich on 17/7/7.
 */
@MiniServerInfo(value = MiniServerType.PROTOTYPE, name = "PlayerServer", id = "id")
public class PlayerServer {
    private int id;
    private int money;

    @MenuMethod
    public int removeMoney(Integer money) {
        this.money -= money;
        System.out.println("id : " + id + " rest " + this.money);
        return this.money;
    }

    @MenuMethod
    public int draw() {
        MiniServer prizeServer = MiniServerController.getInstance().getMiniServer(PrizeServer.class);
        this.money -= 100;
        int prize = (Integer) prizeServer.call("drawPrize");
        if (prize == -1) {
            this.money += 100;
            System.out.println("id : " + id + " not get prize,rest money:" + this.money);
        } else {
            System.out.println("id : " + id + " get prize " + prize + ",rest money:" + this.money);
        }
        return prize;
    }

    @MenuMethod
    public void logout() {
        MiniServerController.getInstance().unregister(this.getClass(), this.id);
    }

    @MenuMethod
    public int getMoney() {
        return money;
    }

    public void setMoney(int money) {
        this.money = money;
    }

    public void setId(int id) {
        this.id = id;
    }

    public int getId() {
        return id;
    }

    @MiniServerInit
    public void init() {
        this.money = 10000;
        System.out.println("id : " + id + " coming, rest " + this.money);
    }

    @MiniServerDestroy
    public void destroy() {
        System.out.println("id : " + id + " leave, rest " + this.money);
    }
}

3.Start

在玩家和獎池都設計完後，就是啟動類了。首先我先初始化最核心的管理類MiniServerController，然後再管理類載入完之後初始化控制台管理服務，此時會將所有的服務載入到此InputServer中，便於控制台管理（其實此樣例有沒有無所謂）。先獲得玩家服務，然後初始化5個玩家，加入到玩家服務中（事實上是可以多線程添加的，但是為了展示抽獎的效果，就同步添加了）。然後多線程的對玩家服務傳遞info的抽獎消息，最後玩家在退出，此處由於是非同步的，所以有可能玩家會先退出再抽獎，但是沒關係，系統做了處理，對於離開的玩家有兩種特殊處理情形，一種為玩家呼叫退出時，還有一部分消息滯留在消息隊列中，此時玩家並不會直接退出，而是等此部分消息處理完再退出，同時在呼叫退出時，此時隊列不再接受此玩家的所有消息，另一種為玩家退出後，過一會兒又回來了（可能是斷線重連），此時如果玩家由於之前退出時還有消息沒處理完而沒有退出的，那就像什麼事都沒發生過一樣，繼續保留。由於不知道玩家哪一條消息式最後一條消息，而每個服務只有一個消息隊列，所以我採取的策略是在處理下一條指令時判斷指令接受時間與退出時間作對比，所以為了示例，我最後添加了玩家30的消息處理，以防玩家沒有退出（此處以後會改）

package example;

import com.basic.stableserver.InputServer;
import example.server.PlayerServer;
import com.basic.stableserver.MiniServer;
import com.basic.stableserver.MiniServerController;

/**
 * Created by Mich on 17/7/7.
 */
public class Start {
    public static void main(String[] args) {
        MiniServerController miniServerController = MiniServerController.getInstance();
        miniServerController.init();
        InputServer inputServer = new InputServer();
        inputServer.start();
        MiniServer playerMiniServer = miniServerController.getMiniServer(PlayerServer.class);
        int playersNum = 5;
        for (int i = 0; i < playersNum; i++) {
            PlayerServer playerServer = new PlayerServer();
            playerServer.setId(i);
            playerMiniServer.addSubject(playerServer);
        }
        for (int i = 0; i < 5; i++) {
            final int tmp = i;
            Thread thread = new Thread(new Runnable() {
                @Override
                public void run() {
                    playerMiniServer.info(tmp, "draw");
                }
            });
            thread.start();
        }
        for (int i = 0; i < playersNum; i++) {
            miniServerController.unregister(PlayerServer.class, i);
        }
        PlayerServer playerServer = new PlayerServer();
        playerServer.setId(30);
        playerMiniServer.addSubject(playerServer);
        playerMiniServer.info(30, "draw");
    }
}