1 files changed, 114 insertions, 0 deletions
diff --git a/client/activity-demo/Piztor/src/com/example/piztor/SocketClient.java b/client/activity-demo/Piztor/src/com/example/piztor/SocketClient.java
new file mode 100644
index 0000000..e66b5bc
--- /dev/null
+++ b/client/activity-demo/Piztor/src/com/example/piztor/SocketClient.java
@@ -0,0 +1,114 @@
+package com.example.piztor;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.PrintStream;
+import java.net.Socket;
+import java.net.UnknownHostException;
+
+public class SocketClient {
+	static PrintStream cout = System.out;
+	static Socket client;
+
+	public SocketClient(String site, int port) throws UnknownHostException,
+			IOException {
+		try {
+			cout.println(site + "   " + port);
+			client = new Socket(site, port);
+			cout.println("connected successfully!!!");
+		} catch (UnknownHostException e) {
+			cout.println("unknownhostexception!!");
+			throw e;
+		} catch (IOException e) {
+			cout.println("IOException!!");
+			throw e;
+		}
+	}
+
+	public Myrespond sendMsg(Myrequest req) throws IOException {
+		try {
+			DataOutputStream out = new DataOutputStream(
+					client.getOutputStream());
+			int tmp = (Integer) req.contain.get(0);
+			out.writeByte(tmp);
+			switch (tmp) {
+			case 0:
+				String id = (String) req.contain.get(1);
+				String pass = (String) req.contain.get(2);
+				out.writeUTF(id);
+				out.writeUTF(pass);
+				break;
+			case 1:
+				int tk1 = (Integer) req.contain.get(1);
+				int acc = (Integer) req.contain.get(2);
+				String mess = (String) req.contain.get(3);
+				out.writeInt(tk1);
+				out.writeInt(acc);
+				out.writeUTF(mess);
+				break;
+			case 2:
+				int tk2 = (Integer) req.contain.get(1);
+				double slot = (Double) req.contain.get(2);
+				double slat = (Double) req.contain.get(3);
+				out.writeInt(tk2);
+				out.writeDouble(slot);
+				out.writeDouble(slat);
+				break;
+			case 3:
+				int tk3 = (Integer) req.contain.get(1);
+				int gid = (Integer) req.contain.get(2);
+				out.writeInt(tk3);
+				out.writeInt(gid);
+				break;
+			}
+			out.flush();
+			client.shutdownOutput();
+			DataInputStream in = new DataInputStream(client.getInputStream());
+			int type = in.readUnsignedByte();
+			Myrespond r = new Myrespond();
+			switch (type) {
+			case 0:
+				int id = in.readInt();
+				int status = in.readUnsignedByte();
+				r.contain.add(0);
+				r.contain.add(id);
+				r.contain.add(status);
+				break;
+			case 1:
+				r.contain.add(1);
+				// reserved
+				break;
+			case 2:
+				r.contain.add(2);
+				// reserved
+				break;
+			case 3:
+				int n = in.readInt();
+				r.contain.add(3);
+				r.contain.add(n);
+				for (int i = 1; i <= n; i++) {
+					int tid = in.readInt();
+					double lot = in.readDouble();
+					double lat = in.readDouble();
+					r.contain.add(tid);
+					r.contain.add(lot);
+					r.contain.add(lat);
+				}
+				break;
+			}
+			return r;
+		} catch (IOException e) {
+			throw e;
+		}
+	}
+
+	public void closeSocket() {
+		try {
+			client.close();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+	}
+
+}