Zookeeper實現負載均衡原理

時間  2020-05-11
標籤 zookeeper 實現 負載 均衡 原理 欄目 Zookeeper 简体版
原文   原文鏈接

先玩個正常的，好玩的socket編程：

服務端：html

首先公共的這個Handler：java

package com.toov5.zkDubbo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerHandler implements Runnable {
    private Socket socket;

    public ServerHandler(Socket socket) {
        this.socket = socket;
    }

    public void run() {
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            out = new PrintWriter(this.socket.getOutputStream(), true);
            String body = null;
            while (true) {
                body = in.readLine();
                if (body == null)
                    break;
                System.out.println("Receive : " + body);
                out.println("Hello, " + body);
            }

        } catch (Exception e) {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
            }
            if (out != null) {
                out.close();
            }
            if (this.socket != null) {
                try {
                    this.socket.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
                this.socket = null;
            }
        }
    }
}

 

package com.toov5.zkDubbo;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import org.I0Itec.zkclient.ZkClient;

//##ServerScoekt服務端
public class ZkServerScoekt implements Runnable {
    private static int port = 18080;  //socket 服務啓動後的所使用的 端口號

    public static void main(String[] args) throws IOException {
        ZkServerScoekt server = new ZkServerScoekt(port);  //構造函數傳入port
    //    regServer();  //去zk註冊
        Thread thread = new Thread(server);
        thread.start();
    }

    public ZkServerScoekt(int port) {
        this.port = port;
    }
//  //註冊服務
//    public static void regServer(){
//        //一、創建zk鏈接
//    ZkClient zkClient = new ZkClient("192.168.91.5",5000,10000);
//        //2.先建立父節點
//    String root = "/toov5";
//    if (!zkClient.exists(root)) {
//        //若是父節點不存，直接建立父節點
//        zkClient.createPersistent(root);  //持久節點
//    }
//       //三、建立子節點
//     String nodeName = root+"/service_"+port;      
//     String nodeValue="127.0.0.1:"+port;
//     if (zkClient.exists(nodeName)) {  //若是存在 直接刪除掉
//        zkClient.delete(nodeName);
//    }
//     zkClient.createEphemeral(nodeName); //字節的 臨時節點  若是服務宕機了 找不到了就
//     System.out.println("服務註冊成功"+nodeName);
//     
//    }
//    
//    
    
    public void run() {
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(port);
            System.out.println("Server start port:" + port);
            Socket socket = null;
            while (true) {
                socket = serverSocket.accept();
                new Thread(new ServerHandler(socket)).start();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (Exception e2) {

            }
        }
    }

}

客戶端：node

package com.toov5.zkDubbo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class ZkServerClient {
    public static List<String> listServer = new ArrayList<String>();

    public static void main(String[] args) {
        initServer();
        ZkServerClient     client= new ZkServerClient();
        BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
        while (true) {
            String name;
            try {
                name = console.readLine();
                if ("exit".equals(name)) {
                    System.exit(0);
                }
                client.send(name);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // 註冊全部server 
    public static void initServer() {
        listServer.clear();
        listServer.add("127.0.0.1:18080"); //鏈接服務 放到list中   存放集羣地址 作負載均衡用的
    }

    // 獲取當前server信息
    public static String getServer() {
        return listServer.get(0);
    }
    
    public void send(String name) {

        String server = ZkServerClient.getServer();
        String[] cfg = server.split(":"); 

        Socket socket = null;
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            socket = new Socket(cfg[0], Integer.parseInt(cfg[1]));
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);

            out.println(name);
            while (true) {
                String resp = in.readLine();
                if (resp == null)
                    break;
                else if (resp.length() > 0) {
                    System.out.println("Receive : " + resp);
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (out != null) {
                out.close();
            }
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket != null) {
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

運行結果：算法

 

引伸思路

使用Zookeeper實現負載均衡原理，服務器端將啓動的服務註冊到，zk註冊中心上，採用臨時節點。客戶端從zk節點上獲取最新服務節點信息，本地使用負載均衡算法，隨機分配服務器。編程

 

 

 

一、會員服務 項目啓動時候 會在zk上面建立臨時節點  /toov5 對應的value是127.0.0.1   後端

       若是是集羣  /toov5 下面會會以 節點形式存儲 節點名字就是IP+端口    value 分別也是 IP+端口   有些是沒有用到value的哦  服務器

二、訂單直接去使用 /toov5 查詢下面的子節點信息，獲取到以後。在本地使用負載均衡算法實現調用，決定使用哪一個。   負載均衡

      127.0.0.1:8080 socket

      127.0.0.1:8081      函數

 

PS： 任何服務的底層都是 socke 技術

 

 socket客戶端 （ 客戶端去獲取註冊信息）                                                          socket服務器端

 

廢話很少說，項目：

          <dependencies>
		<dependency>
			<groupId>com.101tec</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.8</version>
		</dependency>
	</dependencies>　　

  這個不是Apache的哦注意         

 服務端代碼：

package com.toov5.zkDubbo;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import org.I0Itec.zkclient.ZkClient;

//##ServerScoekt服務端
public class ZkServerScoekt implements Runnable {
    private static int port = 18081;  //socket 服務啓動後的所使用的 端口號

    public static void main(String[] args) throws IOException {
        ZkServerScoekt server = new ZkServerScoekt(port);  //構造函數傳入port
        regServer();  //去zk註冊
        Thread thread = new Thread(server);
        thread.start();
    }

    public ZkServerScoekt(int port) {
        this.port = port;
    }
  //註冊服務
    public static void regServer(){
        //一、創建zk鏈接
    ZkClient zkClient = new ZkClient("192.168.91.5",5000,10000);
        //2.先建立父節點
    String root = "/toov5";
    if (!zkClient.exists(root)) {
        //若是父節點不存，直接建立父節點
        zkClient.createPersistent(root);  //持久節點
    }
       //三、建立子節點
     String nodeName = root+"/service_"+port;      
     String nodeValue="127.0.0.1:"+port;
     if (zkClient.exists(nodeName)) {  //若是存在 直接刪除掉
        zkClient.delete(nodeName);
    }
     zkClient.createEphemeral(nodeName); //字節的 臨時節點  若是服務宕機了 找不到了就
     System.out.println("服務註冊成功"+nodeName);
     
    }
    
    
    
    public void run() {
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(port);
            System.out.println("Server start port:" + port);
            Socket socket = null;
            while (true) {
                socket = serverSocket.accept();
                new Thread(new ServerHandler(socket)).start();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (Exception e2) {

            }
        }
    }

}

客戶端代碼：

package com.toov5.zkDubbo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class ZkServerClient {
    public static List<String> listServer = new ArrayList<String>();

    public static void main(String[] args) {
        initServer();
        ZkServerClient     client= new ZkServerClient();
        BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
        while (true) {
            String name;
            try {
                name = console.readLine();
                if ("exit".equals(name)) {
                    System.exit(0);
                }
                client.send(name);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // 註冊全部server 
    public static void initServer() {
        listServer.clear();
        listServer.add("127.0.0.1:18080"); //鏈接服務 放到list中   存放集羣地址 作負載均衡用的
    }

    // 獲取當前server信息
    public static String getServer() {
        return listServer.get(0);
    }
    
    public void send(String name) {

        String server = ZkServerClient.getServer();
        String[] cfg = server.split(":"); 

        Socket socket = null;
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            socket = new Socket(cfg[0], Integer.parseInt(cfg[1]));
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);

            out.println(name);
            while (true) {
                String resp = in.readLine();
                if (resp == null)
                    break;
                else if (resp.length() > 0) {
                    System.out.println("Receive : " + resp);
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (out != null) {
                out.close();
            }
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket != null) {
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

 

啓動服務端後的結果：

能夠看到 去zk註冊了信息。服務的名字 和子節點 

 其中子節點是 臨時節點 至關於若是服務宕機了 就查不到了哦

 

啓動三次服務端後：

 

 而後 去zk讀取節點信息：

客戶端  負載均衡輪訓算法   

請求次數 %  服務端數 = 服務器端口號的奇數偶數

客戶端：

package com.toov5.zkDubbo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

import org.I0Itec.zkclient.ZkClient;

public class ZkServerClient {
    public static List<String> listServer = new ArrayList<String>();

    public static void main(String[] args) {
        initServer();
        ZkServerClient     client= new ZkServerClient();
        BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
        while (true) {
            String name;
            try {
                name = console.readLine();
                if ("exit".equals(name)) {
                    System.exit(0);
                }
                client.send(name);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // 註冊全部server 
    public static void initServer() {
        listServer.clear();
//        listServer.add("127.0.0.1:18080"); //鏈接服務 放到list中   存放集羣地址 作負載均衡用的   
        //創建zk鏈接
        ZkClient zkClient = new ZkClient("192.168.91.5",5000,10000);
        //讀取父節點信息
        String root = "/toov5";
        List<String> children=zkClient.getChildren(root);
        for(String pString : children){
            //父+子 =完整的路徑
            String path = root+"/"+pString;
            String nodeValue =zkClient.readData(path);
            //把值放到集合中去
            listServer.add(nodeValue);
        }
        //服務發現成功
         System.out.println("服務發現:"+listServer.toString());
         //而後給 serverCount賦值
         serverCount=listServer.size();
         
    }
 
  //請求總數
    private static  int  reqCount = 1;
  //服務個數    
    private static int  serverCount = 0; //初始值是0
    
    // 獲取當前server信息
    public static String getServer() {
//        return listServer.get(0);  不能寫死  本地負載均衡輪詢算法
    String serverName = listServer.get(reqCount%serverCount );
    System.out.println("客戶端請求次數："+reqCount+"對應服務器"+serverName);
    reqCount++;
    return serverName;    
    }
    
    public void send(String name) {

        String server = ZkServerClient.getServer();
        String[] cfg = server.split(":"); 

        Socket socket = null;
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            socket = new Socket(cfg[0], Integer.parseInt(cfg[1]));
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);

            out.println(name);
            while (true) {
                String resp = in.readLine();
                if (resp == null)
                    break;
                else if (resp.length() > 0) {
                    System.out.println("Receive : " + resp);
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (out != null) {
                out.close();
            }
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket != null) {
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

啓動後（後端服務啓動三個）：

 

訪問一次：取模算法後的結果

第二次、第三次：

 

 看到結果 太美妙了！

美妙集中在此：

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程