第四次考核

 1 import java.net.*;
 2 import java.io.*;
 3 import java.util.*;
 4 
 5 public class Client_Main {
 6 
 7     private static String file;
 8 
 9     /**
10      * @param args
11      */
12 
13     @SuppressWarnings("resource")
14     public static void main(String[] args) {
15         // TODO Auto-generated method stub
16         Scanner input = new Scanner(System.in);
17         Socket mysocket = null;
18         DataInputStream in = null;
19         DataOutputStream out = null;
20 
21         try {
22             mysocket = new Socket();
23             System.out.print("please input the ip of Server:");
24             String ip = input.nextLine();
25             System.out.print("please input the port of Server:");
26             int port = input.nextInt();
27             if (mysocket.isConnected()) {
28             } else {
29                 InetAddress address = InetAddress.getByName(ip);
30                 InetSocketAddress socketAddress = new InetSocketAddress(address, port);
31                 mysocket.connect(socketAddress);
32                 in = new DataInputStream(mysocket.getInputStream());
33                 out = new DataOutputStream(mysocket.getOutputStream());
34                 
35                 
36                 System.out.print(in.readUTF());
37                 System.out.print("please input your numberofyou:");
38                 
39                 for (int z = 0; z < 2; z++) {
40                     String s = input.nextLine();
41                     File file = new File(s + ".txt");
42                     file.createNewFile();
43                     out.writeUTF(s);
44                 }
45                 
46                 System.out.println("please input your question");
47 
48                 for (int i = 0; i < 4; i++) {
49                     //System.out.print(in.readUTF());
50                     
51                     Date nowTime = new Date();
52                     //System.out.print("The answer of Servert:"+in.readUTF());
53                     String question = input.nextLine();
54                     out.writeUTF(question);
55                     System.out.println(in.readUTF());
56                     //String answer = in.readUTF();
57                     File fwrite = new File(file);
58                     Writer outfile = new FileWriter(fwrite);
59                     BufferedWriter bufferwrite = new BufferedWriter(outfile);
60                     bufferwrite.write(in.readUTF() + ":" + nowTime);
61                     bufferwrite.newLine();
62                     bufferwrite.close();
63                 }
64 
65                 out.close();
66 
67             }
68         } catch (Exception e) {
69             System.out.print("");
70 
71         }
72 
73     }
74 
75 }

  1 import java.net.*;
  2 import java.io.*;
  3 import java.util.*;
  4 
  5 public class Server_Main {
  6 
  7     /**
  8      * @param args
  9      */
 10 
 11     @SuppressWarnings("resource")
 12     public static void main(String[] args) {
 13         // TODO Auto-generated method stub
 14 
 15         try {
 16             // 1.创建服务器端socket,即ServerSocket,并绑定指定的端口，并在端口进行监听
 17             ServerSocket serverSocket = new ServerSocket(8888);
 18             Socket socket = null;
 19             // 记录客户端的数量
 20             int count = 0;
 21             System.out.println("***服务器即将启动,等待客户端的连接***");
 22             // 循环监听等待客户端的连接
 23             while (true) {
 24                 // 2.通过accept()方法对客户端进行监听,等待客户端的连接
 25                 socket = serverSocket.accept();// 返回的实例用来与客户端进行通信
 26                 serverThread serverThread = new serverThread(socket);
 27                 // 启动线程
 28                 serverThread.start();
 29                 count++;
 30                 System.out.println("客户端数量: " + count);
 31                 InetAddress address = socket.getInetAddress();
 32 
 33                 System.out.println("当前客户端的IP: " + address.getHostAddress());
 34                 new bianliang().ip = address.getHostAddress();
 35             }
 36 
 37         } catch (IOException e) {
 38             e.printStackTrace();
 39         }
 40     }
 41 
 42 }
 43 
 44 class bianliang {
 45     public static String ip;
 46 }
 47 
 48 class xuehao {
 49     public static String xuehao;
 50 }
 51 
 52 class serverThread extends Thread {
 53     InetAddress ip = null;
 54     Socket socket;
 55     Scanner input = new Scanner(System.in);
 56     ServerSocket serverForClient = null;
 57     DataOutputStream out = null;
 58     DataInputStream in = null;
 59     private String xuehao;
 60     private String dd;
 61 
 62     serverThread(Socket t) {
 63         socket = t;
 64         try {
 65             out = new DataOutputStream(socket.getOutputStream());
 66             in = new DataInputStream(socket.getInputStream());
 67         } catch (IOException e) {
 68             System.out.println("aa");
 69         }
 70 
 71     }
 72 
 73     public void run() {
 74         bianliang ss = new bianliang();
 75         String xuehao = null ;
 76         try {
 77             out.writeUTF("The Link is connected!!\n");
 78         } catch (IOException e) {
 79             // TODO Auto-generated catch block
 80             e.printStackTrace();
 81         }
 82         
 83     
 84         for (int i = 0; i <2; i++) {
 85             try {
 86                 xuehao = in.readUTF();
 87                 File aa = new File(xuehao+ "_" + ss.ip + ".txt");
 88                 aa.createNewFile();
 89             } catch (Exception e) {
 90                 System.out.print("Fail!!!");
 91             }
 92             
 93         }        
 94         
 95         String name = xuehao+"_" + ss.ip + ".txt";
 96         for (int z = 0; z < 4; z++) {
 97             Date nowTime = new Date();
 98             try {
 99                 String question = in.readUTF();
100                 
101                 System.out.println("The question of Client:"+question);
102                 
103                 System.out.println("The answer of Server:");
104                 String qwer = input.nextLine();
105                 out.writeUTF(qwer);
106                 
107                 File fwrite = new File(name);
108                 try {
109                     Writer out = new FileWriter(fwrite);
110                     BufferedWriter bufferwrite = new BufferedWriter(out);
111                     bufferwrite.write(question + ":" + nowTime);
112                     String answer = input.nextLine();
113                     bufferwrite.write(answer);
114                     bufferwrite.close();
115                 } catch (Exception e) {
116                 }
117                 
118                 
119             } catch (IOException e) {
120                 // TODO Auto-generated catch block
121                 e.printStackTrace();
122             }
123         }
124     }
125 }