JSONConnection.java
3fe5097d6c65ms_access_migration

JSONConnection.java
View Options

			package io;

			import java.io.IOException;
			import java.net.Socket;
			import java.net.UnknownHostException;
			import java.util.logging.Level;
			import java.util.logging.Logger;

			import org.json.JSONObject;

			import com.cedarsoftware.util.io.JsonReader;
			import com.cedarsoftware.util.io.JsonWriter;

			public class JSONConnection {

			private static final Logger LOGGER = Logger.getLogger(JSONConnection.class.getName());

			private JsonReader jsr = null;
			private JsonWriter jsw = null;

			private Socket socket = null;
			private String ip;
			private int port;

			public JSONConnection(String ip, int port) {
			this.ip = ip;
			this.port = port;
			}

			public void connect() {
			try {
			socket = new Socket(ip, port);
			System.out.println("Socket to " + ip + " ok");

			jsw = new JsonWriter(socket.getOutputStream());
			jsr = new JsonReader(socket.getInputStream());

			} catch (UnknownHostException e) {
			LOGGER.log(Level.SEVERE, null, e);
			e.printStackTrace();
			} catch (IOException e) {
			LOGGER.log(Level.SEVERE, null, e);
			e.printStackTrace();
			}
			}

			public void send(JSONObject obj) {
			try {
			jsw.write(obj);
			jsw.flush();
			} catch (IOException e) {
			LOGGER.log(Level.SEVERE, null, e);
			e.printStackTrace();
			}
			}

			public JSONObject receive() {
			JSONObject json = null;

			try {
			json = (JSONObject) jsr.readObject();
			} catch (IOException e) {
			LOGGER.log(Level.SEVERE, null, e);
			e.printStackTrace();
			}
			return json;
			}

			public void close() {
			jsr.close();
			jsw.close();

			try {
			socket.close();
			} catch (IOException e) {
			LOGGER.log(Level.SEVERE, null, e);
			e.printStackTrace();
			socket = null;
			}

			jsr = null;
			jsw = null;
			}

			}