apiroute/apiroute-service/src/main/java/org/openo/msb/resources/MicroServiceResource.java

   1 /**\r
   2 * Copyright (C) 2016 ZTE, Inc. and others. All rights reserved. (ZTE)\r
   3 *\r
   4 * Licensed under the Apache License, Version 2.0 (the "License");\r
   5 * you may not use this file except in compliance with the License.\r
   6 * You may obtain a copy of the License at\r
   7 *\r
   8 * http://www.apache.org/licenses/LICENSE-2.0\r
   9 *\r
  10 * Unless required by applicable law or agreed to in writing, software\r
  11 * distributed under the License is distributed on an "AS IS" BASIS,\r
  12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  13 * See the License for the specific language governing permissions and\r
  14 * limitations under the License.\r
  15 */\r
  16 \r
  17 package org.openo.msb.resources;\r
  18 \r
  19 import io.swagger.annotations.Api;\r
  20 import io.swagger.annotations.ApiOperation;\r
  21 import io.swagger.annotations.ApiParam;\r
  22 import io.swagger.annotations.ApiResponse;\r
  23 import io.swagger.annotations.ApiResponses;\r
  24 \r
  25 import java.net.URI;\r
  26 \r
  27 import javax.servlet.http.HttpServletRequest;\r
  28 import javax.ws.rs.DELETE;\r
  29 import javax.ws.rs.DefaultValue;\r
  30 import javax.ws.rs.GET;\r
  31 import javax.ws.rs.POST;\r
  32 import javax.ws.rs.PUT;\r
  33 import javax.ws.rs.Path;\r
  34 import javax.ws.rs.PathParam;\r
  35 import javax.ws.rs.Produces;\r
  36 import javax.ws.rs.QueryParam;\r
  37 import javax.ws.rs.core.Context;\r
  38 import javax.ws.rs.core.MediaType;\r
  39 import javax.ws.rs.core.Response;\r
  40 import javax.ws.rs.core.UriInfo;\r
  41 \r
  42 import org.apache.commons.lang3.StringUtils;\r
  43 import org.apache.http.HttpStatus;\r
  44 import org.openo.msb.api.MicroServiceFullInfo;\r
  45 import org.openo.msb.api.MicroServiceInfo;\r
  46 import org.openo.msb.wrapper.MicroServiceWrapper;\r
  47 import org.openo.msb.wrapper.util.MicroServiceUtil;\r
  48 import org.slf4j.Logger;\r
  49 import org.slf4j.LoggerFactory;\r
  50 \r
  51 import com.codahale.metrics.annotation.Timed;\r
  52 \r
  53 @Path("/services")\r
  54 @Api(tags = {"MSB-Service Resource"})\r
  55 @Produces(MediaType.APPLICATION_JSON)\r
  56 public class MicroServiceResource {\r
  57 \r
  58     @Context\r
  59     UriInfo uriInfo; // actual uri info\r
  60 \r
  61 \r
  62     private static final Logger LOGGER = LoggerFactory.getLogger(MicroServiceResource.class);\r
  63 \r
  64     @GET\r
  65     @Path("/")\r
  66     @ApiOperation(value = "get all microservices ", code = HttpStatus.SC_OK, response = MicroServiceFullInfo.class, responseContainer = "List")\r
  67     @ApiResponses(value = {@ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "get microservice List  fail", response = String.class)})\r
  68     @Produces(MediaType.APPLICATION_JSON)\r
  69     @Timed\r
  70     public MicroServiceFullInfo[] getMicroService() {\r
  71         return MicroServiceWrapper.getInstance().getAllMicroServiceInstances();\r
  72     }\r
  73 \r
  74     @POST\r
  75     @Path("/")\r
  76     @ApiOperation(value = "add one microservice ", code = HttpStatus.SC_CREATED, response = MicroServiceFullInfo.class)\r
  77     @ApiResponses(value = {\r
  78             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
  79             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "add microservice fail", response = String.class),\r
  80             @ApiResponse(code = HttpStatus.SC_BAD_REQUEST, message = "Unprocessable MicroServiceInfo JSON REQUEST", response = String.class)})\r
  81     @Produces(MediaType.APPLICATION_JSON)\r
  82     @Timed\r
  83     public Response addMicroService(\r
  84             @ApiParam(value = "MicroServiceInfo Instance Info", required = true) MicroServiceInfo microServiceInfo,\r
  85             @Context HttpServletRequest request,\r
  86             @ApiParam(value = "createOrUpdate", required = false) @QueryParam("createOrUpdate") @DefaultValue("true") boolean createOrUpdate,\r
  87             @ApiParam(value = "port", required = false) @QueryParam("port") @DefaultValue("") String port) {\r
  88        \r
  89        String ip=MicroServiceUtil.getRealIp(request);\r
  90         \r
  91         MicroServiceFullInfo microServiceFullInfo =\r
  92                 MicroServiceWrapper.getInstance().saveMicroServiceInstance(microServiceInfo,\r
  93                     createOrUpdate,ip,port);\r
  94         URI returnURI =\r
  95                 uriInfo.getAbsolutePathBuilder()\r
  96                         .path("/" + microServiceInfo.getServiceName() + "/version/"\r
  97                                 + microServiceInfo.getVersion()).build();\r
  98         return Response.created(returnURI).entity(microServiceFullInfo).build();\r
  99     }\r
 100 \r
 101 \r
 102 \r
 103     @GET\r
 104     @Path("/{serviceName}/version/{version}")\r
 105     @ApiOperation(value = "get one microservice ", code = HttpStatus.SC_OK, response = MicroServiceFullInfo.class)\r
 106     @ApiResponses(value = {\r
 107             @ApiResponse(code = HttpStatus.SC_NOT_FOUND, message = "microservice not found", response = String.class),\r
 108             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 109             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "get microservice fail", response = String.class)})\r
 110     @Produces(MediaType.APPLICATION_JSON)\r
 111     @Timed\r
 112     public MicroServiceFullInfo getMicroService(\r
 113             @ApiParam(value = "microservice serviceName") @PathParam("serviceName") String serviceName,\r
 114             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"") @PathParam("version") @DefaultValue("") String version,\r
 115             @ApiParam(value = "port", required = false) @QueryParam("port") @DefaultValue("") String port) {\r
 116 \r
 117 \r
 118         return MicroServiceWrapper.getInstance().getMicroServiceInstance(serviceName, version,port);\r
 119 \r
 120 \r
 121     }\r
 122 \r
 123     @PUT\r
 124     @Path("/{serviceName}/version/{version}")\r
 125     @ApiOperation(value = "update one microservice by serviceName and version", code = HttpStatus.SC_CREATED, response = MicroServiceFullInfo.class)\r
 126     @ApiResponses(value = {\r
 127             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 128             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "update microservice fail", response = String.class),\r
 129             @ApiResponse(code = HttpStatus.SC_BAD_REQUEST, message = "Unprocessable MicroServiceInfo JSON REQUEST", response = String.class)})\r
 130     @Produces(MediaType.APPLICATION_JSON)\r
 131     @Timed\r
 132     public Response updateMicroService(\r
 133             @ApiParam(value = "microservice serviceName") @PathParam("serviceName") String serviceName,\r
 134             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"") @PathParam("version") @DefaultValue("") String version,\r
 135             @ApiParam(value = "microservice Instance Info", required = true) MicroServiceInfo microServiceInfo) {\r
 136 \r
 137         MicroServiceFullInfo microServiceFullInfo = MicroServiceWrapper.getInstance().updateMicroServiceInstance(serviceName, version,\r
 138                 microServiceInfo);\r
 139         return Response.created(uriInfo.getAbsolutePathBuilder().build()).entity(microServiceFullInfo).build();\r
 140 \r
 141     }\r
 142 \r
 143     @PUT\r
 144     @Path("/{serviceName}/version/{version}/nodes/{ip}/{port}")\r
 145     @ApiOperation(value = "update  single node by serviceName and version and node", code = HttpStatus.SC_CREATED, response = MicroServiceFullInfo.class)\r
 146     @ApiResponses(value = {\r
 147             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 148             @ApiResponse(code = HttpStatus.SC_NOT_FOUND, message = "microservice not found", response = String.class),\r
 149             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "update node fail", response = String.class)})\r
 150     @Produces(MediaType.APPLICATION_JSON)\r
 151     @Timed\r
 152     public Response updateNode(\r
 153             @ApiParam(value = "microservice serviceName", required = true) @PathParam("serviceName") String serviceName,\r
 154             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"", required = false) @PathParam("version") @DefaultValue("") String version,\r
 155             @ApiParam(value = "ip") @PathParam("ip") String ip,\r
 156             @ApiParam(value = "port") @PathParam("port") String port,\r
 157             @ApiParam(value = "ttl") @QueryParam("ttl") int ttl) {\r
 158 \r
 159         MicroServiceFullInfo microServiceFullInfo = MicroServiceWrapper.getInstance().updateMicroServiceNode(serviceName, version, ip,port, ttl);\r
 160 \r
 161         return Response.created(uriInfo.getAbsolutePathBuilder().build()).entity(microServiceFullInfo).build();\r
 162 \r
 163     }\r
 164 \r
 165 \r
 166 \r
 167     @DELETE\r
 168     @Path("/{serviceName}/version/{version}/nodes/{ip}/{port}")\r
 169     @ApiOperation(value = "delete single node by serviceName and version and node", code = HttpStatus.SC_NO_CONTENT)\r
 170     @ApiResponses(value = {\r
 171             @ApiResponse(code = HttpStatus.SC_NO_CONTENT, message = "delete node succeed "),\r
 172             @ApiResponse(code = HttpStatus.SC_NOT_FOUND, message = "node not found", response = String.class),\r
 173             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 174             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "delete node fail", response = String.class)})\r
 175     @Produces(MediaType.APPLICATION_JSON)\r
 176     @Timed\r
 177     public void deleteNode(\r
 178             @ApiParam(value = "microservice serviceName", required = true) @PathParam("serviceName") String serviceName,\r
 179             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"", required = false) @PathParam("version") @DefaultValue("") String version,\r
 180             @ApiParam(value = "ip") @PathParam("ip") String ip,\r
 181             @ApiParam(value = "port") @PathParam("port") String port) {\r
 182 \r
 183         MicroServiceWrapper.getInstance().deleteMicroServiceInstance(serviceName, version, ip,port);\r
 184 \r
 185     }\r
 186 \r
 187 \r
 188     @DELETE\r
 189     @Path("/{serviceName}/version/{version}")\r
 190     @ApiOperation(value = "delete one full microservice by serviceName and version", code = HttpStatus.SC_NO_CONTENT)\r
 191     @ApiResponses(value = {\r
 192             @ApiResponse(code = HttpStatus.SC_NO_CONTENT, message = "delete microservice succeed "),\r
 193             @ApiResponse(code = HttpStatus.SC_NOT_FOUND, message = "microservice not found", response = String.class),\r
 194             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 195             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "delete microservice fail", response = String.class)})\r
 196     @Produces(MediaType.APPLICATION_JSON)\r
 197     @Timed\r
 198     public void deleteMicroService(\r
 199             @ApiParam(value = "microservice serviceName", required = true) @PathParam("serviceName") String serviceName,\r
 200             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"", required = false) @PathParam("version") @DefaultValue("") String version,\r
 201             @ApiParam(value = "port", required = false) @QueryParam("port") @DefaultValue("") String port) {\r
 202 \r
 203 \r
 204          MicroServiceWrapper.getInstance().deleteMicroService(serviceName, version,port);\r
 205 \r
 206     }\r
 207 \r
 208     @PUT\r
 209     @Path("/{serviceName}/version/{version}/status/{status}")\r
 210     @ApiOperation(value = "update  microservice status by serviceName and version", code = HttpStatus.SC_CREATED, response = MicroServiceFullInfo.class)\r
 211     @ApiResponses(value = {\r
 212             @ApiResponse(code = HttpStatus.SC_UNSUPPORTED_MEDIA_TYPE, message = "Unprocessable MicroServiceInfo Entity ", response = String.class),\r
 213             @ApiResponse(code = HttpStatus.SC_NOT_FOUND, message = "microservice not found", response = String.class),\r
 214             @ApiResponse(code = HttpStatus.SC_INTERNAL_SERVER_ERROR, message = "update status fail", response = String.class)})\r
 215     @Produces(MediaType.APPLICATION_JSON)\r
 216     @Timed\r
 217     public Response updateServiceStatus(\r
 218             @ApiParam(value = "microservice serviceName", required = true) @PathParam("serviceName") String serviceName,\r
 219             @ApiParam(value = "microservice version,if the version is empty, please enter \"null\"", required = false) @PathParam("version") @DefaultValue("") String version,\r
 220             @ApiParam(value = "status,1：abled  0：disabled") @PathParam("status") String status) {\r
 221 \r
 222         MicroServiceFullInfo microServiceFullInfo = MicroServiceWrapper.getInstance().updateMicroServiceStatus(serviceName, version,status);\r
 223 \r
 224         return Response.created(uriInfo.getAbsolutePathBuilder().build()).entity(microServiceFullInfo).build();\r
 225 \r
 226     }\r
 227 \r
 228 //    @PUT\r
 229 //    @Path("/ttl")\r
 230 //    @ApiOperation(value = "test json date iso8601 ", code = 200, response = String.class)\r
 231 //    @Produces(MediaType.APPLICATION_JSON)\r
 232 //    @Timed\r
 233 //    public String testIso8601(\r
 234 //              @ApiParam(value = "microservice Instance Info", required = true) MicroServiceFullInfo microServiceInfo) {\r
 235 //        Set<NodeInfo> nodes=microServiceInfo.getNodes();\r
 236 //        String rtn="rtn:";\r
 237 //        for(NodeInfo node:nodes){\r
 238 //            Date date=node.getExpiration();\r
 239 //            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX");\r
 240 //            String datettl=sdf.format(date);\r
 241 //            rtn+=datettl;\r
 242 //        }\r
 243 //        \r
 244 //    \r
 245 //        return rtn;\r
 246 //    }\r
 247 }\r