一些LVS实验配置、工具和方案

vip=172.16.0.113
r1ip=172.16.0.114
r2ip=172.16.0.115
port=$1
if [ -z "$port" ]
then
 port=2100
fi

ipvsadm -C
ipvsadm -A -t ${vip}:${port} -s wrr
ipvsadm -a -t ${vip}:${port} -r ${r1ip}:${port} -g
ipvsadm -a -t ${vip}:${port} -r ${r2ip}:${port} -g

#!/bin/sh
VIP=172.16.0.113
BROADCAST=172.16.0.255 #vip's broadcast

Usage ()
{
 echo "Usage:`basename $0` (start|stop)"
 exit 1
}

if [ $# -ne 1 ];then
 Usage
fi

case $1 in
start)
 echo "reparing for Real Server"
 echo "1" >/proc/sys/net/ipv4/conf/lo/arp_ignore
 echo "2" >/proc/sys/net/ipv4/conf/lo/arp_announce
 echo "1" >/proc/sys/net/ipv4/conf/all/arp_ignore
 echo "2" >/proc/sys/net/ipv4/conf/all/arp_announce
 /sbin/ifconfig lo:0 $VIP netmask 255.255.255.255 broadcast $BROADCAST up
 /sbin/route add -host $VIP dev lo:0
;;
stop)
 /sbin/ifconfig lo:0 down
 echo "0" >/proc/sys/net/ipv4/conf/lo/arp_ignore
 echo "0" >/proc/sys/net/ipv4/conf/lo/arp_announce
 echo "0" >/proc/sys/net/ipv4/conf/all/arp_ignore
 echo "0" >/proc/sys/net/ipv4/conf/all/arp_announce
 echo "stop Real Server"
;;
*)
 Usage
esac

package com;

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

public class Server
{

    public static void main(String[] args) throws IOException
    {

        if (args.length <; 1)
        {
            System.out.println("arguments error!\nusage: java -jar tcpser.jar server port");
            System.exit(0);
        }

        int serverport = Integer.parseInt(args[0]);

        System.out.println("==============TCP SERVER==============");

        ServerSocket server = null;
        try
        {
            server = new ServerSocket(serverport);
            System.out.println("Listening Port is " + server.getLocalPort() + "...");
            while (true)
            {
                Socket connectedCli = server.accept();
                System.out.println("a new client: " + connectedCli.getInetAddress() + ":" + connectedCli.getPort());
                new DataProcesser(connectedCli).start();
            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            if (server != null)
            {
                server.close();
            }
        }
    }
}

 

package com;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;

public class DataProcesser extends Thread
{
    private Socket cli;

    public DataProcesser(Socket clientsocket)
    {
        cli = clientsocket;
    }

    @Override
    public void run()
    {
        BufferedReader reader = null;
        BufferedWriter writer = null;
        try
        {
            reader = new BufferedReader(new InputStreamReader(cli.getInputStream()));
            writer = new BufferedWriter(new OutputStreamWriter(cli.getOutputStream()));
            while (true)
            {
                String receivedString = reader.readLine();
                if (receivedString != null)
                {
                    System.out.println(cli.getInetAddress() + ":" + cli.getPort() + " " + receivedString);
                    String hostname = InetAddress.getLocalHost().getHostName();
                    writer.write("it's from the host: " + hostname);
                    writer.write("\n");
                    writer.flush();
                }
                if ("shutdown".equals(receivedString))
                {
                    break;
                }
            }

        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            if (reader != null)
            {
                try
                {
                    reader.close();
                }
                catch (Exception e2)
                {
                    e2.printStackTrace();
                }
            }

            if (cli != null)
            {
                try
                {
                    cli.close();
                }
                catch (Exception e2)
                {
                    e2.printStackTrace();
                }
            }

        }
    }
}

将上面的服务端代码导出为jar包：server.jar，部署到两台RealServer上面：

root@ceph1:~# java -jar server.jar 2100
==============TCP SERVER==============
Listening Port is 2100...
a new client: /172.16.0.100:49314
a new client: /172.16.0.100:49316

ipvsadm -e -t 172.16.0.113:2100 -r 172.16.0.114:2100 -w 0