summaryrefslogtreecommitdiff
path: root/client/Socket-demo/Transam.java
diff options
context:
space:
mode:
authorMyth Yang <[email protected]>2013-08-23 09:12:50 +0800
committerMyth Yang <[email protected]>2013-08-23 09:13:01 +0800
commitc4d4831297d97ff2d0330858951579ad49884a96 (patch)
treea7d7eef3a046568053156c45f86cfa3544176cf3 /client/Socket-demo/Transam.java
parentd622bf0bd855f4d2f0600a52aba1faa015f91ac6 (diff)
new
Diffstat (limited to 'client/Socket-demo/Transam.java')
-rw-r--r--client/Socket-demo/Transam.java98
1 files changed, 98 insertions, 0 deletions
diff --git a/client/Socket-demo/Transam.java b/client/Socket-demo/Transam.java
new file mode 100644
index 0000000..d809be1
--- /dev/null
+++ b/client/Socket-demo/Transam.java
@@ -0,0 +1,98 @@
+package com.example.test;
+
+import java.io.IOException;
+import java.net.UnknownHostException;
+import java.util.Timer;
+import java.util.TimerTask;
+
+import android.annotation.SuppressLint;
+import android.os.Handler;
+import android.os.Message;
+
+public class Transam implements Runnable {
+ public static String outmsg = "";
+ public Timer timer;
+ public boolean flag = true;
+ public int cnt = 4;
+ public int port;
+ public String ip;
+ Thread thread;
+ Myrequest req;
+ Myrespond res;
+ Controller core;
+
+ Transam(String i,int p,Myrequest r,Controller c){
+ port = p;
+ ip = i;
+ req = r;
+ core = c;
+ }
+
+ public void run() {
+ final thd t = new thd();
+ flag = false;
+ thread = new Thread(t);
+ cnt = 4;
+ thread.start();
+ timer = new Timer();
+ TimerTask task = new Timertk();
+ timer.schedule(task,2000,2000);
+ }
+
+ class thd implements Runnable {
+ @Override
+ public void run() {
+ try{
+ SocketClient client = new SocketClient(ip,port);
+ Myrespond res = client.sendMsg(req);
+ core.recieveInfo(res);
+ Message msg = new Message();
+ msg.what = 1;
+ handler.sendMessage(msg);
+ client.closeSocket();
+ }catch (UnknownHostException e){
+ }catch (IOException e){
+ }
+
+ }
+ }
+
+ @SuppressLint("HandlerLeak")
+ Handler handler = new Handler(){
+ public void handleMessage(Message msg) {
+ switch (msg.what) {
+ case 1:
+ flag = true;
+ break;
+ case 2:
+ res.wrong = msg.obj.toString();
+ core.recieveInfo(res);
+ break;
+ case 3:
+ final thd t = new thd();
+ thread = new Thread(t);
+ thread.start();
+ break;
+ }
+ super.handleMessage(msg);
+ }
+ };
+
+ class Timertk extends TimerTask {
+ public void run() {
+ if(flag==false&&cnt>0){
+ cnt--;
+ }
+ else if(cnt==0) {
+ Message msg = new Message();
+ msg.obj = "connecting failed";
+ msg.what = 2;
+ handler.sendMessage(msg);
+ timer.cancel();
+ }
+ else if(flag==true){
+ timer.cancel();
+ }
+ }
+ };
+} \ No newline at end of file