server/com/company/guestServer.java

   1 package com.company;
   2
   3 import java.io.*;
   4
   5 import javax.net.ssl.*;
   6
   7 class guestServer implements Runnable
   8 {
   9         private SSLSocket socket;
  10
  11         guestServer(SSLSocket client)
  12         {
  13                 socket=client;
  14         }
  15
  16         public void run()
  17         {
  18                 try
  19         {
  20
  21                         //Reading the message from the client
  22                         InputStream is = socket.getInputStream();
  23                         InputStreamReader isr = new InputStreamReader(is);
  24                         BufferedReader br = new BufferedReader(isr);
  25                         String requestMessage = br.readLine();
  26                         System.out.println("ho ricevuto: "+requestMessage);
  27                         if(requestMessage!=null)
  28                         {
  29                                 String returnQuery;
  30                                 if (    requestMessage.charAt(0) == '0' ||
  31                                                 requestMessage.charAt(0) == '1' ||
  32                                                 requestMessage.charAt(0) == '2' ||
  33                                                 (requestMessage.charAt(0) == 'a' && requestMessage.charAt(1) == '0')) {
  34                                         returnQuery = global.request.dbQuery(requestMessage);
  35                                         OutputStream os = socket.getOutputStream();
  36                                         OutputStreamWriter osw = new OutputStreamWriter(os);
  37                                         BufferedWriter bw = new BufferedWriter(osw);
  38                                         bw.write(returnQuery + "\n");
  39                                         bw.flush();
  40                                         System.out.println("ho inviato: " + returnQuery);
  41                                 }
  42                                 else
  43                                 {
  44                                         returnQuery =global.request.dbQuery("5/" + requestMessage);
  45                                         if (returnQuery.contains("request-login") || returnQuery.contains("request-error"))
  46                                         {
  47                                                 OutputStream os = socket.getOutputStream();
  48                                                 OutputStreamWriter osw = new OutputStreamWriter(os);
  49                                                 BufferedWriter bw = new BufferedWriter(osw);
  50                                                 bw.write(returnQuery + "\n");
  51                                                 bw.flush();
  52                                                 System.out.println("ho inviato: " + returnQuery);
  53                                         }
  54                                         else if (returnQuery.contains("loggato"))
  55                                         {
  56                                                 personalServer nuovaConnessione = new personalServer(socket, requestMessage);
  57                                                 Thread t = new Thread(nuovaConnessione);
  58                                                 t.start();
  59                                         }
  60                                 }
  61                         }
  62
  63         }
  64         catch (Exception e)
  65         {
  66             e.printStackTrace();
  67         }
  68
  69     }
  70 }