Mercurial > hg > Members > nobuyasu > tightVNCClient
view src/myVncClient/EchoClient.java @ 56:9f8463fb1d4d
merge
author | Yu Taninari <you@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 28 Jul 2011 18:07:21 +0900 |
parents | f2f4b0398f04 |
children | e65934744da8 |
line wrap: on
line source
package myVncClient; import java.io.*; import java.net.*; import myVncClient.MulticastQueue.Client; public class EchoClient { String name; BufferedReader is = null; DataOutputStream os = null; Socket echoSocket = null; boolean runflag = false; WaitReply waitReply; String responseLine; String parent;// 親の番号 String treenum;// 自分の番号 String leaderflag;// リーダフラグ Socket clientSocket = null; MyVncClient client; // WaitReplyに自分自身を渡している public EchoClient() { } // VncViewerから引数をもらってきてproxy役を認識する public EchoClient(String _name,MyVncClient client) { this.client = client; name = _name; } public EchoClient(EchoClient echo,MyVncClient client) { this.client = client; name = echo.name; leaderflag = echo.leaderflag; parent = echo.parent; treenum = echo.treenum; } // void hostn(String args){ void openport() { // ソケットや入出力用のストリームの宣言 /* Random rnd = new Random(); long ran = rnd.nextInt(1000) + 1000; */ // ポート9999番に接続 try { if (name != null) { echoSocket = new Socket(name, 9999); } else { echoSocket = new Socket("133.13.48.18", 9999); } os = new DataOutputStream(echoSocket.getOutputStream()); is = new BufferedReader(new InputStreamReader(echoSocket.getInputStream())); } catch (UnknownHostException e) { System.err.println("Don't know about host: localhost"); } catch (IOException e) { System.out.println("接続に失敗しました"); System.err .println("Couldn't get I/O for the connection to: localhost"); } } /** * @param args * select connect port * @return */ EchoClient hostn(String args) { // サーバーにメッセージを送る if (echoSocket != null && os != null && is != null) { try { // ip情報を取得する InetAddress addr = InetAddress.getLocalHost(); // System.out.println(addr.getHostAddress()); String add = new String(addr.getHostAddress()); // メッセージを送ります os.writeBytes(add + "\n"); os.writeBytes(args + "\n"); if ((responseLine = is.readLine()) != null) { System.out.println("Server: " + responseLine); } if ((parent = is.readLine()) != null) { System.out.println("parent: " + parent); } if ((treenum = is.readLine()) != null) { System.out.println("treenum: " + treenum); } if ((leaderflag = is.readLine()) != null) { System.out.println("leaderflag: " + leaderflag); } // 開いたソケットなどをクローズ os.close(); is.close(); echoSocket.close(); } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { System.err.println("IOException: " + e); } waitReply = new WaitReply(treenum,client); waitReply.start(); } return this; } /** * Call at lost host */ boolean losthost() { if (echoSocket != null && os != null && is != null) { try { if(runflag){ return true; } // echoSocketの情報を呼び出す if ("1".equals(leaderflag)) { senddataProxy("1",parent); } else { senddataProxy("3",parent); } if ((responseLine = is.readLine()) != null) { System.out.println("Server: " + responseLine); } if ((parent = is.readLine()) != null) { System.out.println("parent: " + parent); } /** * if ((value.treenum = is.readLine()) != null) { * System.out.println("treenum: " + value.treenum); } */ Thread.sleep(1000); client.init(this); client.start_threads(); client.start(); // MyVncClient.main(this); // 開いたソケットなどをクローズ os.close(); is.close(); echoSocket.close(); //runflag = true; } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { return false; /* while (true) { try { Thread.sleep(1000); System.out.println("once connection proxy"); } catch (InterruptedException e1) { e1.printStackTrace(); } openport(); losthost(); System.out.println("faild in this area"); System.err.println("IOException: " + e); if(runflag == true){ break; } } */ } catch (InterruptedException e) { e.printStackTrace(); } } return true; } boolean notfoundParent() { if (echoSocket != null && os != null && is != null) { runflag = true; try { senddataProxy("2", parent); if ((responseLine = is.readLine()) != null) { System.out.println("Server: " + responseLine); } if ((parent = is.readLine()) != null) { System.out.println("parent: " + parent); } if ((treenum = is.readLine()) != null) { System.out.println("Server: " + treenum); } if ((leaderflag = is.readLine()) != null) { System.out.println("parent: " + leaderflag); } client.init(this); client.start_threads(); client.start(); os.close(); is.close(); echoSocket.close(); } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { System.err.println("IOException: " + e); } } return true; } /* void lostchild() { // ßSystem.out.println(name); if (echoSocket != null && os != null && is != null) { try { // echoSocketなどの情報を呼び出す(追加) // 自分の番号を報告 os.writeBytes("4\n"); os.writeBytes(treenum + "\n"); os.close(); is.close(); echoSocket.close(); } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { System.err.println("IOException: " + e); } } } */ EchoClient Interruption(Socket _clientSocket) { clientSocket = _clientSocket; BufferedReader lostis = null;//あとで修正する try { lostis = new BufferedReader(new InputStreamReader( clientSocket.getInputStream())); // while (true){ // line = lostis.readLine(); // System.out.println(line); try { if ((responseLine = lostis.readLine()) != null) { System.out.println("newServer: " + responseLine); } if ((parent = lostis.readLine()) != null) { System.out.println("newtparent: " + parent); } if ((treenum = lostis.readLine()) != null) { System.out.println("newtreenum: " + treenum); } if ((leaderflag = lostis.readLine()) != null) { System.out.println("newreaderflag: " + leaderflag); } } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { System.err.println("IOException: " + e); } // } } catch (IOException e) { System.out.println(e); } try { clientSocket.close();// WaitReplyのacceptを終了させる } catch (IOException e) { System.out.println(e); } return this; } void senddataProxy(String type,String num) { try { os.writeBytes(type + "\n"); os.writeBytes(num + "\n"); } catch (UnknownHostException e) { System.err.println("Trying to connect to unknown host: " + e); } catch (IOException e) { System.err.println("IOException: " + e); } } }