一、實驗要求
兩人一組結對編程:html
import javax.xml.bind.annotation.XmlType; import java.lang.Integer; import java.util.StringTokenizer; import java.util.Stack; public class MyDC { /** constant for addition symbol */ private final String ADD="+"; /** constant for subtraction symbol */ private final String SUBTRACT="-"; /** constant for multiplication symbol */ private final String MULTIPLY="*"; /** constant for division symbol */ private final String DIVIDE="/"; /** the stack */ private Stack<Integer>stack; public MyDC(){ stack=new Stack<Integer>(); } public int evaluate(String expr) { int op1,op2,result=0; String token; StringTokenizer tokenizer=new StringTokenizer(expr); while(tokenizer.hasMoreTokens()) { token = tokenizer.nextToken(); //若是是運算符,調用isOperator if (isOperator(token)) { //從棧中彈出操做數2 op2 = stack.pop(); //從棧中彈出操做數1 op1 = stack.pop(); //根據運算符和兩個操做數調用evalSingleOp計算result; result = evalSingleOp(token, op1, op2); //計算result入棧; stack.push(result); } else//若是是操做數 { stack.push(Integer.parseInt(token)); //操做數入棧; } } return result; } private boolean isOperator(String token) { return(token.equals("+")||token.equals("-")|| token.equals("*")||token.equals("/")); } private int evalSingleOp(String operation,int op1,int op2) { int result=0; switch(operation) { case ADD: result=op1+op2; break; case SUBTRACT: result=op1-op2; break; case MULTIPLY: result=op1*op2; break; case DIVIDE: result=op1/op2; default: break; } return result; } }
MyBC:java
import java.util.StringTokenizer; import java.util.Stack; public class MyBC{ private Stack<Character> stack1; public char Precede(char a,char b) { if(a=='#') if(b!='#') return '<'; else return '='; if(a==')') return '>'; if(a=='(') if(b!=')') return '<'; else return '='; if(a=='/'||a=='*') if(b!='(') return '>'; else return '<'; if(a=='-'||a=='+') if(b!='*'&&b!='/'&&b!='(') return '>'; else return '<'; return '>'; } public MyBC() { stack1 = new Stack<Character>(); stack1.push('#'); } public String turn(String expr) { int result = 0; String token; char topelem,optr; char[] exper1 = new char[100]; int i = 0; StringTokenizer tokenizer = new StringTokenizer (expr); /*while (tokenizer.hasMoreTokens()) { System.out.println(tokenizer.nextToken()); }*/ while (tokenizer.hasMoreTokens()) { token = tokenizer.nextToken(); //若是是運算符,調用isOperator if (isOperator(token)) { //調用Precede比較優先級 topelem=stack1.peek(); optr = token.charAt(0); if(Precede(topelem,optr)=='<') { stack1.push(optr); } else if(Precede(topelem,optr)=='=') { /*if(optr==')'){ optr=stack1.pop(); while(optr!='('){ exper1[i++]=optr; exper1[i++]=' '; optr=stack1.pop(); } }*/ optr =stack1.pop(); exper1[i++] = optr; exper1[i++] = ' '; } else if(Precede(topelem,optr)=='>') { optr =stack1.pop(); //從運算符棧中退出棧頂元素並放入後綴表達式exper1 exper1[i++] = optr; exper1[i++] = ' '; } }//若是是(則入棧 else if(token.equals("(")) { optr = token.charAt(0); stack1.push(optr); }//若是是)則退棧直到出現第一個( else if(token.equals(")")) { optr = stack1.pop(); while(optr!='(') { exper1[i++] = optr; exper1[i++] = ' '; optr = stack1.pop(); } } else//若是是操做數 //操做數放入後綴表達式exper1 { optr = token.charAt(0); //System.out.println(optr); exper1[i++]=optr; exper1[i++] = ' '; } } while(!stack1.isEmpty()) { optr = stack1.pop(); if(optr!='#'){ exper1[i++] = optr; exper1[i++] = ' '; } } //System.out.println(exper1); return ToString(exper1); } //@Override private boolean isOperator(String token) { return (token.equals("+") || token.equals("-") ||token.equals("*") || token.equals("/") ); } public static String ToString(char[] exper1){ int length = exper1.length; String str=" "; for(int i=0;i<length;i++) { str=str+exper1[i]; } //System.out.println(str); return str; } /*public static void main(String[] args) { String pp=null; MyBC turner = new MyBC(); pp=turner.turn("( 1 + 2 ) * ( ( 8 - 2 ) / ( 7 - 4 ) )"); System.out.println(pp); }*/ }
import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class Client { public static final String IP_ADDR = "127.0.0.1";//服務器地址 public static final int PORT = 12345;//服務器端口號 public static void main(String[] args) { System.out.println("客戶端啓動..."); System.out.println("當接收到服務器端字符爲 \"OK\" 的時候, 客戶端將終止\n"); while (true) { Socket socket = null; try { //建立一個流套接字並將其鏈接到指定主機上的指定端口號 socket = new Socket(IP_ADDR, PORT); //讀取服務器端數據 DataInputStream input = new DataInputStream(socket.getInputStream()); //向服務器端發送數據 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); System.out.print("請輸入: \t"); String str = new BufferedReader(new InputStreamReader(System.in)).readLine(); MyBC turner = new MyBC(); String str1 = turner.turn(str); int length=0,i=0; while(str1.charAt(i)!='\0'){ length++; i++; } String str2 = str1.substring(1,length-1); out.writeUTF(str2); String ret = input.readUTF(); System.out.println("服務器端返回過來的是: " + ret); // 如接收到 "OK" 則斷開鏈接 /*if ("OK".equals(ret)) { System.out.println("客戶端將關閉鏈接"); Thread.sleep(500); break; }*/ out.close(); input.close(); } catch (Exception e) { System.out.println("客戶端異常:" + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (IOException e) { socket = null; System.out.println("客戶端 finally 異常:" + e.getMessage()); } } } } } }
import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class Server { public static final int PORT = 12345;//監聽的端口號 public static void main(String[] args) { System.out.println("服務器啓動...\n"); Server server = new Server(); server.init(); } public void init() { try { ServerSocket serverSocket = new ServerSocket(PORT); while (true) { // 一旦有堵塞, 則表示服務器與客戶端得到了鏈接 Socket client = serverSocket.accept(); // 處理此次鏈接 new HandlerThread(client); } } catch (Exception e) { System.out.println("服務器異常: " + e.getMessage()); } } private class HandlerThread implements Runnable { private Socket socket; public HandlerThread(Socket client) { socket = client; new Thread(this).start(); } public void run() { try { // 讀取客戶端數據 DataInputStream input = new DataInputStream(socket.getInputStream()); String clientInputStr = input.readUTF();//這裏要注意和客戶端輸出流的寫方法對應,不然會拋 EOFException // 處理客戶端數據 System.out.println("客戶端發過來的內容:" + clientInputStr); MyDC evalute = new MyDC(); int result = evalute.evaluate(clientInputStr); // 向客戶端回覆信息 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); System.out.print("計算結果:\t"); // 發送鍵盤輸入的一行 //String s = new BufferedReader(new InputStreamReader(System.in)).readLine(); out.writeUTF(String.valueOf(result)); out.close(); input.close(); } catch (Exception e) { System.out.println("服務器 run 異常: " + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (Exception e) { socket = null; System.out.println("服務端 finally 異常:" + e.getMessage()); } } } } } }
加密結對編程:1人負責客戶端,一人負責服務器git
import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class Client2 { public static final String IP_ADDR = "127.0.0.1";//服務器地址 public static final int PORT = 12345;//服務器端口號 public static void main(String[] args) { System.out.println("客戶端啓動..."); System.out.println("當接收到服務器端字符爲 \"OK\" 的時候, 客戶端將終止\n"); while (true) { Socket socket = null; try { //建立一個流套接字並將其鏈接到指定主機上的指定端口號 socket = new Socket(IP_ADDR, PORT); //讀取服務器端數據 DataInputStream input = new DataInputStream(socket.getInputStream()); //向服務器端發送數據 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); System.out.print("請輸入: \t"); String str = new BufferedReader(new InputStreamReader(System.in)).readLine(); MyBC turner = new MyBC(); Skey_DES skey_des = new Skey_DES(); skey_des.key_DES(); Skey_kb skey_kb = new Skey_kb(); skey_kb.key(); /*產生密鑰*/ SEnc sEnc = new SEnc(); String str1 = turner.turn(str); int length=0,i=0; while(str1.charAt(i)!='\0'){ length++; i++; } String str2 = str1.substring(1,length-1); out.writeUTF(str2); String ret = input.readUTF(); System.out.println("服務器端返回過來的是: " + ret); // 如接收到 "OK" 則斷開鏈接 /*if ("OK".equals(ret)) { System.out.println("客戶端將關閉鏈接"); Thread.sleep(500); break; }*/ out.close(); input.close(); } catch (Exception e) { System.out.println("客戶端異常:" + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (IOException e) { socket = null; System.out.println("客戶端 finally 異常:" + e.getMessage()); } } } } } }
服務器算法
import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class Server2 { public static final int PORT = 12345;//監聽的端口號 public static void main(String[] args) { System.out.println("服務器啓動...\n"); Server server = new Server(); server.init(); } public void init() { try { ServerSocket serverSocket = new ServerSocket(PORT); while (true) { // 一旦有堵塞, 則表示服務器與客戶端得到了鏈接 Socket client = serverSocket.accept(); // 處理此次鏈接 new HandlerThread(client); } } catch (Exception e) { System.out.println("服務器異常: " + e.getMessage()); } } private class HandlerThread implements Runnable { private Socket socket; public HandlerThread(Socket client) { socket = client; new Thread(this).start(); } public void run() { try { // 讀取客戶端數據 DataInputStream input = new DataInputStream(socket.getInputStream()); String clientInputStr = input.readUTF();//這裏要注意和客戶端輸出流的寫方法對應,不然會拋 EOFException // 處理客戶端數據 System.out.println("客戶端發過來的內容:" + clientInputStr); MyDC evalute = new MyDC(); SDec sDec = new SDec(); int result = evalute.evaluate(clientInputStr); // 向客戶端回覆信息 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); System.out.print("計算結果:\t"); // 發送鍵盤輸入的一行 //String s = new BufferedReader(new InputStreamReader(System.in)).readLine(); out.writeUTF(String.valueOf(result)); out.close(); input.close(); } catch (Exception e) { System.out.println("服務器 run 異常: " + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (Exception e) { socket = null; System.out.println("服務端 finally 異常:" + e.getMessage()); } } } } } }
運行截圖
編程
密鑰分發結對編程:1人負責客戶端,一人負責服務器數組
import java.io.*; import java.math.*; import java.security.*; import java.security.spec.*; import javax.crypto.*; import javax.crypto.spec.*; import javax.crypto.interfaces.*; public class Key_DH{ private static final byte skip1024ModulusBytes[] = { (byte)0xF4, (byte)0x88, (byte)0xFD, (byte)0x58, (byte)0x4E, (byte)0x49, (byte)0xDB, (byte)0xCD, (byte)0x20, (byte)0xB4, (byte)0x9D, (byte)0xE4, (byte)0x91, (byte)0x07, (byte)0x36, (byte)0x6B, (byte)0x33, (byte)0x6C, (byte)0x38, (byte)0x0D, (byte)0x45, (byte)0x1D, (byte)0x0F, (byte)0x7C, (byte)0x88, (byte)0xB3, (byte)0x1C, (byte)0x7C, (byte)0x5B, (byte)0x2D, (byte)0x8E, (byte)0xF6, (byte)0xF3, (byte)0xC9, (byte)0x23, (byte)0xC0, (byte)0x43, (byte)0xF0, (byte)0xA5, (byte)0x5B, (byte)0x18, (byte)0x8D, (byte)0x8E, (byte)0xBB, (byte)0x55, (byte)0x8C, (byte)0xB8, (byte)0x5D, (byte)0x38, (byte)0xD3, (byte)0x34, (byte)0xFD, (byte)0x7C, (byte)0x17, (byte)0x57, (byte)0x43, (byte)0xA3, (byte)0x1D, (byte)0x18, (byte)0x6C, (byte)0xDE, (byte)0x33, (byte)0x21, (byte)0x2C, (byte)0xB5, (byte)0x2A, (byte)0xFF, (byte)0x3C, (byte)0xE1, (byte)0xB1, (byte)0x29, (byte)0x40, (byte)0x18, (byte)0x11, (byte)0x8D, (byte)0x7C, (byte)0x84, (byte)0xA7, (byte)0x0A, (byte)0x72, (byte)0xD6, (byte)0x86, (byte)0xC4, (byte)0x03, (byte)0x19, (byte)0xC8, (byte)0x07, (byte)0x29, (byte)0x7A, (byte)0xCA, (byte)0x95, (byte)0x0C, (byte)0xD9, (byte)0x96, (byte)0x9F, (byte)0xAB, (byte)0xD0, (byte)0x0A, (byte)0x50, (byte)0x9B, (byte)0x02, (byte)0x46, (byte)0xD3, (byte)0x08, (byte)0x3D, (byte)0x66, (byte)0xA4, (byte)0x5D, (byte)0x41, (byte)0x9F, (byte)0x9C, (byte)0x7C, (byte)0xBD, (byte)0x89, (byte)0x4B, (byte)0x22, (byte)0x19, (byte)0x26, (byte)0xBA, (byte)0xAB, (byte)0xA2, (byte)0x5E, (byte)0xC3, (byte)0x55, (byte)0xE9, (byte)0x2F, (byte)0x78, (byte)0xC7 }; private static final BigInteger skip1024Modulus = new BigInteger(1, skip1024ModulusBytes); private static final BigInteger skip1024Base = BigInteger.valueOf(2); public static void fun(String s1,String s2) throws Exception{ DHParameterSpec DHP= new DHParameterSpec(skip1024Modulus,skip1024Base); KeyPairGenerator kpg= KeyPairGenerator.getInstance("DH"); kpg.initialize(DHP); KeyPair kp=kpg.genKeyPair(); PublicKey pbk=kp.getPublic(); PrivateKey prk=kp.getPrivate(); // 保存公鑰 FileOutputStream f1=new FileOutputStream(s1); ObjectOutputStream b1=new ObjectOutputStream(f1); b1.writeObject(pbk); // 保存私鑰 FileOutputStream f2=new FileOutputStream(s2); ObjectOutputStream b2=new ObjectOutputStream(f2); b2.writeObject(prk); } }
import java.io.*; import java.math.*; import java.security.*; import java.security.spec.*; import javax.crypto.*; import javax.crypto.spec.*; import javax.crypto.interfaces.*; public class Key_Agree{ public static void main(String args[ ]) throws Exception{ // 讀取對方的DH公鑰 FileInputStream f1=new FileInputStream(args[0]); ObjectInputStream b1=new ObjectInputStream(f1); PublicKey pbk=(PublicKey)b1.readObject( ); //讀取本身的DH私鑰 FileInputStream f2=new FileInputStream(args[1]); ObjectInputStream b2=new ObjectInputStream(f2); PrivateKey prk=(PrivateKey)b2.readObject( ); // 執行密鑰協定 KeyAgreement ka=KeyAgreement.getInstance("DH"); ka.init(prk); ka.doPhase(pbk,true); //生成共享信息 byte[ ] sb=ka.generateSecret(); for(int i=0;i<sb.length;i++){ System.out.print(sb[i]+","); } SecretKeySpec k=new SecretKeySpec(sb,"DESede"); } public static void fun(String s, String s1) { } }
完整性校驗結對編程:1人負責客戶端,一人負責服務器安全
import java.io.*; import java.net.*; import java.applet.Applet; import java.security.MessageDigest; public class Server3 { public static void main(String args[]) { MyDC evalute = new MyDC(); SDec sDec = new SDec(); try { ServerSocket server = null; try { server = new ServerSocket(4700); //建立一個ServerSocket在端口4700監聽客戶請求 } catch (Exception e) { System.out.println("can not listen to:" + e); //出錯,打印出錯信息 } Socket socket = null; try { socket = server.accept(); //使用accept()阻塞等待客戶請求,有客戶 //請求到來則產生一個Socket對象,並繼續執行 } catch (Exception e) { System.out.println("Error." + e); //出錯,打印出錯信息 } String line; BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream())); //由Socket對象獲得輸入流,並構造相應的BufferedReader對象 PrintWriter os = new PrintWriter(socket.getOutputStream()); //由Socket對象獲得輸出流,並構造PrintWriter對象 BufferedReader sin = new BufferedReader(new InputStreamReader(System.in)); //由系統標準輸入設備構造BufferedReader對象 //使用Hash函數檢測明文完整性 String x = sin.readLine(); MessageDigest m2 = MessageDigest.getInstance("MD5"); //使用MD5算法返回實現指定摘要算法的 MessageDigest對象 m2.update(x.getBytes()); byte a[] = m2.digest(); String result = ""; for (int i = 0; i < a.length; i++) { result += Integer.toHexString((0x000000ff & a[i]) | 0xffffff00).substring(6); } System.out.println(result); String match = is.readLine(); if (match.equals(result)) { System.out.println("匹配成功"); } System.out.println("Client:" + is.readLine()); //在標準輸出上打印從客戶端讀入的字符串 line = sin.readLine(); //從標準輸入讀入一字符串 while (!line.equals("bye")) { //若是該字符串爲 "bye",則中止循環 os.println(evalute.evaluate(line)); //向客戶端輸出該字符串 os.flush(); //刷新輸出流,使Client立刻收到該字符串 System.out.println("Server:" + evalute.evaluate(line)); //在系統標準輸出上打印讀入的字符串 System.out.println("Client:" + is.readLine()); //從Client讀入一字符串,並打印到標準輸出上 line = sin.readLine(); //從系統標準輸入讀入一字符串 } //繼續循環 os.close(); //關閉Socket輸出流 is.close(); //關閉Socket輸入流 socket.close(); //關閉Socket server.close(); //關閉ServerSocket } catch (Exception e) { System.out.println("Error:" + e); //出錯,打印出錯信息 } } }
import java.io.*; import java.net.*; import java.security.MessageDigest; public class Client3 { public static void main(String args[]) throws Exception { MyBC turner = new MyBC(); Skey_DES skey_des = new Skey_DES(); skey_des.key_DES(); Skey_kb skey_kb = new Skey_kb(); skey_kb.key(); /*產生密鑰*/ SEnc sEnc = new SEnc(); try { Socket socket = new Socket("127.0.0.1", 4700); //向本機的4700端口發出客戶請求 BufferedReader sin = new BufferedReader(new InputStreamReader(System.in)); //由系統標準輸入設備構造BufferedReader對象 PrintWriter os = new PrintWriter(socket.getOutputStream()); //由Socket對象獲得輸出流,並構造PrintWriter對象 BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream())); //由Socket對象獲得輸入流,並構造相應的BufferedReader對象 String readline; readline =sin.readLine(); //從系統標準輸入讀入一字符串 String x = readline; // 將客戶端明文的Hash值傳送給服務器 MessageDigest m2 = MessageDigest.getInstance("MD5"); m2.update(x.getBytes()); byte a[] = m2.digest(); String result = ""; for (int i = 0; i < a.length; i++) { result += Integer.toHexString((0x000000ff & a[i]) | 0xffffff00).substring(6); } System.out.println("明文MD5值爲:" + result); os.println(result);//經過網絡將明文的Hash函數值傳送到服務器 // String str = is.readLine();// 從網絡輸入流讀取結果 System.out.println("從服務器接收到的結果爲:" + result); // 輸出服務器返回的結果 while (!readline.equals("bye")) { //若從標準輸入讀入的字符串爲 "bye"則中止循環 readline = SEnc.Enc(turner.turn(readline)); os.println(readline); /*把中綴表達式調用MyBC.java的功能轉化爲後綴表達式,把後綴表達式用3DES加密後經過網絡發送給服務器*/ //將從系統標準輸入讀入的字符串輸出到Server os.flush(); //刷新輸出流,使Server立刻收到該字符串 System.out.println("Client:" + readline); //在系統標準輸出上打印讀入的字符串 System.out.println("Server:" + is.readLine()); //從Server讀入一字符串,並打印到標準輸出上 readline = sin.readLine(); //從系統標準輸入讀入一字符串 } //繼續循環 os.close(); //關閉Socket輸出流 is.close(); //關閉Socket輸入流 socket.close(); //關閉Socket } catch (Exception e) { System.out.println("Error" + e); //出錯,則打印出錯信息 } } }
代碼連接服務器