Java JSON Example
import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.PrintWriter; import java.io.StringReader; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.util.HashMap; import java.util.Map;
import javax.xml.bind.JAXBContext; import javax.xml.bind.Unmarshaller; import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlElement; import javax.xml.bind.annotation.XmlRootElement; import javax.xml.transform.stream.StreamSource;
import org.eclipse.persistence.jaxb.JAXBContextProperties; import org.eclipse.persistence.jaxb.xmlmodel.ObjectFactory;
public class TestUpsideRESTAPIJSON {
public static final String APIEndPoint = "https://secureapi.upsidewireless.com"; // or "http://api.upsidewireless.com" public static final String APICredential_Token ="xxxxxxxx-8e4b-405b-998c-a580bf593b76"; public static final String APICredential_Signature = "xxxxxxxxfyqQx95Gxxxxxxxx";
private static String SMSMsgUrl = String.format("%s/RESTv1/%s/Message", APIEndPoint, APICredential_Token);
public static void main(String[] argv) throws Exception { HttpURLConnection connection = null;
boolean acceptJSON = true; System.out.println("SMS Message URL: " + SMSMsgUrl); try { URL smsMessageUrl = new URL(SMSMsgUrl); connection = (HttpURLConnection)smsMessageUrl.openConnection();
connection.setRequestMethod("POST"); connection.setRequestProperty("Content-Type", "application/json"); connection.setRequestProperty("Accept", acceptJSON ? "application/json" : "application/xml"); connection.setRequestProperty("User-Agent", "UpsideJavaAgent"); connection.setConnectTimeout(100 * 1000); // 100 seconds connection.setReadTimeout(300 * 1000); // 300 seconds connection.setDoOutput(true); String type = "sms"; // see type list on wiki String message = "test sms message"; String recipient = "16047891236"; // number in E.164 format String encoding = "7"; // 7, 8 or 16 String jsonObject = "{signature:\"" + APICredential_Signature + "\""; jsonObject += ",type:\"" + type + "\""; jsonObject += ",message:\"" + message + "\""; jsonObject += ",recipient:\"" + recipient + "\""; jsonObject += ",encoding:\"" + encoding + "\"}"; PrintWriter pw = new PrintWriter(connection.getOutputStream()); pw.println(jsonObject); pw.close();
InputStream input = null; try { input = connection.getInputStream(); } catch (Exception e) { input = connection.getErrorStream(); } StringBuffer sbResponse = new StringBuffer(1024); BufferedReader reader = new BufferedReader(new InputStreamReader(input)); String inputLine = null; while ((inputLine = reader.readLine()) != null) { sbResponse.append(inputLine); } reader.close();
String responseString = sbResponse.toString(); System.out.println("REST Response: " + responseString);
RestResponse restResponse = null; if (acceptJSON) { Map<String, Object> properties = new HashMap<String, Object>(2); properties.put(JAXBContextProperties.MEDIA_TYPE, "application/json"); properties.put(JAXBContextProperties.JSON_INCLUDE_ROOT, false); JAXBContext jaxbContext = JAXBContext.newInstance(new Class[] {RestResponse.class, ObjectFactory.class}, properties); Unmarshaller unmarshaller = jaxbContext.createUnmarshaller(); StringReader sr = new StringReader(responseString); StreamSource json = new StreamSource(sr); restResponse = unmarshaller.unmarshal(json, RestResponse.class).getValue();
// or use your favourite method to parse JSON object } else { JAXBContext jaxbContext = JAXBContext.newInstance(RestResponse.class); Unmarshaller unmarshaller = jaxbContext.createUnmarshaller(); StringReader sr = new StringReader(responseString); restResponse = (RestResponse) unmarshaller.unmarshal(sr);
// or use your favourite method to parse XML object }
if (restResponse != null) { System.out.println("Rest Response - HasException: " + restResponse.isHasException()); System.out.println("Rest Response - Token: " + restResponse.getToken()); if (restResponse.isHasException()) { System.out.println("Rest Response - RestException.ErrorCode: " + restResponse.getRestException().getErrorCode()); System.out.println("Rest Response - RestException.Message: " + restResponse.getRestException().getMessage()); if (restResponse.getRestException().getStatus() != null) System.out.println("Rest Response - RestException.Status: " + restResponse.getRestException().getStatus()); } else { System.out.println("Rest Response - SMSMessage.Status: " + restResponse.getSMSMessage().getStatus()); System.out.println("Rest Response - SMSMessage.Recipient: " + restResponse.getSMSMessage().getRecipient()); System.out.println("Rest Response - SMSMessage.Body: " + restResponse.getSMSMessage().getBody()); System.out.println("Rest Response - SMSMessage.Type: " + restResponse.getSMSMessage().getType()); System.out.println("Rest Response - SMSMessage.TrackingId: " + restResponse.getSMSMessage().getTrackingId()); if ("REJECTED".equals(restResponse.getSMSMessage().getStatus())) System.out.println("Rest Response - SMSMessage.RejectReason: " + restResponse.getSMSMessage().getRejectReason()); } } else { System.out.println("Can't get rest response object"); }
} catch (Exception e) { System.out.println("Error in calling API - " + e.getMessage()); e.printStackTrace(); } finally {
if (connection != null) { connection.disconnect(); }
}
} }
@XmlRootElement(name="RestResponse")
@XmlAccessorType(XmlAccessType.FIELD)
class RestResponse
{
@XmlElement(name = "HasException")
private boolean HasException;
@XmlElement(name = "Token")
private String Token;
@XmlElement(name = "SMSMessage")
private SMSMessage SMSMessage;
@XmlElement(name = "RestException")
private RestException RestException;
public boolean isHasException() { return HasException; }
public void setHasException(boolean hasException) { HasException = hasException; }
public String getToken() { return Token; }
public void setToken(String token) { Token = token; }
public SMSMessage getSMSMessage() { return SMSMessage; }
public void setSMSMessage(SMSMessage sMSMessage) { SMSMessage = sMSMessage; }
public RestException getRestException() { return RestException; }
public void setRestException(RestException restException) { RestException = restException; } }
@XmlAccessorType(XmlAccessType.FIELD) class SMSMessage { @XmlElement(name = "Status")
private String Status;
@XmlElement(name = "Recipient")
private String Recipient;
@XmlElement(name = "Body")
private String Body;
@XmlElement(name = "Type")
private String Type;
@XmlElement(name = "TrackingId")
private String TrackingId;
@XmlElement(name = "RejectReason")
private String RejectReason;
public String getStatus() { return Status; }
public void setStatus(String status) { Status = status; }
public String getRecipient() { return Recipient; }
public void setRecipient(String recipient) { Recipient = recipient; }
public String getBody() { return Body; }
public void setBody(String body) { Body = body; }
public String getType() { return Type; }
public void setType(String type) { Type = type; }
public String getTrackingId() { return TrackingId; }
public void setTrackingId(String trackingId) { TrackingId = trackingId; }
public String getRejectReason() { return RejectReason; }
public void setRejectReason(String rejectReason) { RejectReason = rejectReason; }
}
@XmlAccessorType(XmlAccessType.FIELD) class RestException { @XmlElement(name = "ErrorCode")
private int ErrorCode;
@XmlElement(name = "Message")
private String Message;
@XmlElement(name = "Status")
private String Status;
public int getErrorCode() { return ErrorCode; }
public void setErrorCode(int errorCode) { ErrorCode = errorCode; }
public String getMessage() { return Message; }
public void setMessage(String message) { Message = message; }
public String getStatus() { return Status; }
public void setStatus(String status) { Status = status; } }