Форум программистов [Powered by Invision Power Board]

Код

import java.awt.*;
import java.awt.List;
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.Timer;
import java.lang.*;
import javax.swing.*;

public class server extends Panel
{
    //function which generate the random number between a(min) and b(max)
    public static int RNG(int a,int b){
        int k;
        boolean error1 = false;
        //we check. if our max will be smaller than min or equal then we have error
        //our return value will be negative or 0 and in the main function our programm
        //will not work...
        if(a<=b){
            
            System.err.println("Your max must be bigger min...");
            error1 = true;
            return a-b;    
        }
        else{
        //if max is bigger then min it will be work and generate random number.    
            k = (int) ((a-b)*Math.random()+b);
            
            //or we can write like this. it is similar with code which is written above    
            
            //Random random = new Random();
            //k = random.nextInt(a-b) + b;
            
            return k;
        }
        
    }

    public static int RandomNumber1(){
        int r;
        //random numbers
        Random random = new Random();
        r = random.nextInt(100);
        System.out.println("RandomNumber1:"+r);
        return r;
        }
    public static int RandomNumber2(){
        int r1;
        //random numbers
        Random random = new Random();
        r1 = (int) (100*Math.random());
        System.out.println("RandomNumber2:"+r1);
        return r1;
    }
    public static void main(String args[])throws Exception 
    {
        
        
        // Create a socket object from the ServerSocket to listen and accept 
        // connections.
        try 
        {        
                Socket client = null;
                int n = 100;
                int NUM_OF_INTEGERS = 1000;
                //read and then buffered from file...
                FileReader file = new FileReader("in.txt");
                BufferedReader fileInput = new BufferedReader(file);
         
                //we construct the array, which can inckude 1000 int
                ArrayList nums = new ArrayList(NUM_OF_INTEGERS);
                
                String line = null;
                while ((line = fileInput.readLine()) != null) {
                    nums.add(line);
                }
                // Close file
                fileInput.close();
                // construct an array of strings
                String[] numbers = new String[nums.size()];
                // populate that array
                nums.toArray(numbers);
                
                //we save all everything from file to some string variables
                //each line in the file have own value
                 
                String remoteport1 = numbers[0]; //first line in in.txt is remoteport
                String localport1 = numbers[1];  //second line in in.txt is localport
                String host = numbers[2];        //third line in in.txt is host
                String min1 = numbers[3];        //fourth line in in.txt is minimum number
                String max1 = numbers[4];        //fifth line in in.txt is maximum number
                String per1 = numbers[5];        //sixth line in in.txt is percentage of disconnecting
                String per2 = numbers[6];        //sixth line in in.txt is percentage of disconnecting
                
                //we change from String to Integer some variables which must be Integer
                int remoteport = Integer.parseInt(remoteport1);
                int localport = Integer.parseInt(localport1);
                int min = Integer.parseInt(min1);
                int max = Integer.parseInt(max1);
                int per = Integer.parseInt(per1);
                int per3 = Integer.parseInt(per2);
                boolean error = false;
                 
            //function which generate random number
            int RandomNumberGeneration = RNG(max,min); 
            
            if( localport <= 0 || host==null || remoteport <= 0 || RandomNumberGeneration<0)
              {
                  System.err.println("Error: Invalid Specification ");
               System.err.print("Port value out of range (negative or null)");
               System.err.println("or maximum number smaller then minimum");
                  error = true;
              }    
              else {
            System.out.println("Starting proxy for " + host + ":" + remoteport + " on port " + localport);}
            
            System.out.println("Time delay is (random number) :" + RandomNumberGeneration);
            
            ServerSocket ss = new ServerSocket(localport);
                //connection with proxy server    
                
            for(int i=0;i<n;i++)
                {   
                    int RN1 = RandomNumber1();
                    int RN2 = RandomNumber2();
                    client = ss.accept();
                    //go to connection function
                    connection cc = new connection(client,i,host,remoteport,RandomNumberGeneration,per,per3,ss,RN1,RN2);
                }            
        }
        catch (Exception e) 
        {
            
            System.err.println(e);
        }
    }
}

class connection extends Thread 
{
    Socket client=null;
    int id;
    String host;
    int remoteport;
    long ranum;
    long max;
    int percentage;
    int percentage1;
    ServerSocket ss;
    int RandomNumber1;
    int RandomNumber2;
    
    public connection(Socket s,int i, String h, int port , long a ,int per,int per1, ServerSocket o, int r, int r1) 
    { 
        id=i;
        client=s;
        host=h;
        remoteport=port;
        ranum=a;
        percentage=per;
        percentage1=per1;
        ss=o;
        RandomNumber1=r;
        RandomNumber2=r1;
        this.start(); 
    }
    
    
    public void run()
    {
        final byte[] request = new byte[1024];
        byte[] reply = new byte[4096];
        int i=0;
        
        boolean error = false;
        final int ADP = 100-percentage;
        final int ADP1 = 100-percentage1;
        System.out.println("ID:"+id);
        Socket server = null;
        try 
        {
            
            final InputStream streamFromclient = client.getInputStream();
            final OutputStream streamToclient= client.getOutputStream();
            
            if(RandomNumber1>ADP){
                streamFromclient.close();
                streamToclient.close();
                System.err.println("Error: transformation canceled");
            }
            else{
            try 
            {
                server = new Socket(host, remoteport); 
            } 
            catch (IOException e) 
            {
                PrintWriter out = new PrintWriter(new OutputStreamWriter(streamToclient));
                out.println("Proxy server cannot connect to " + host + ":" + remoteport + ":\n" + e);
                out.flush();
                client.close();
            }
            
            final InputStream streamFromserver = server.getInputStream();
            final OutputStream streamToserver = server.getOutputStream();
            
            
            TimerTask timerTask = new TimerTask()
            {
                public void run() 
                {
                    int bytes_read;
                    
                    try 
                    {
                        while((bytes_read = streamFromclient.read(request)) != -1) 
                        {
                            //request
                            streamToserver.write(request, 0, bytes_read);
                            streamToserver.flush();
                        }
                    }
                    catch (IOException e) {}
                    try {streamToserver.close();} catch (IOException e) {}
                }
            };
            Timer timer = new Timer();
            timer.schedule( timerTask, ranum );
            
            if(RandomNumber2>ADP1){
             streamToclient.close();
             streamFromclient.close();
             System.err.println("Error: Transformation canceled");
             
            }
            else{
             int bytes_read;
                 try 
                 {                
                         while((bytes_read = streamFromserver.read(reply)) != -1) 
                         {
                             //response
                             streamToclient.write(reply, 0, bytes_read);
                             streamToclient.flush();
                         }        
                 }        
            
                 catch(IOException e) {}
                 streamToclient.close();
                 }
            }
        }
        
        catch (IOException e) { System.err.println(e); }
        finally 
        { 
            try 
            { 
                if (server != null) 
                    server.close(); 
                if (client != null) 
                    client.close(); 
            }
            catch(IOException e) {}
        }
      
    }
}