Difference between revisions of "Java JSON Example"

Revision as of 15:57, 9 February 2018

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; } }