REST协议可以传文件流吗

OSI应用层协议标准：MHS——报文处理系统（Mail）FTAM——文件传送、存取和管理（FTP）VTP——虚终端协议（Telnet）DS——目录服务TP——事务处理JTM——作业传送与 *** 纵RDA——远程数据库访问文件传送协议FTP（FileTransferProtocol）是Internet文件传送的基础。通过该协议，用户可以从一个Internet主机向另一个Internet主机拷贝文件。FTP曾经是Internet中的一种重要的交流形式。目前，我们常常用它来从远程主机中拷贝所需的各类软件。

服务器端程序：

@POST

@Path("/getZip")

@Produces("application/zip")

public Response getZip(String message) throws FileNotFoundException {

FileInputStream fis = new FileInputStream(new File("E:/src/1.zip"))

Response.ResponseBuilder responseBuilder = null

Response response = null

responseBuilder = Response.ok(fis, MediaType.APPLICATION_OCTET_STREAM_TYPE)

responseBuilder.type(MediaType.APPLICATION_OCTET_STREAM_TYPE)

response = responseBuilder.header("content-disposition", "inlinefilename= file.zip").build()

return response

}

客户端程序：

RestClient restClient = new RestClient()

Resource resource = restClient.resource("your url")

final ClientResponse response = resource.post(message)

System.out.println("服务器返回状态: " + response.getStatusCode())

InputStream is = response.getEntity(new EntityType<InputStream>(){})

System.out.println("服务器返回文件大小: " + is.available())

定义一个简单的restful接口

@RestController

public class TestController

{

@RequestMapping(value = "testPost", method = RequestMethod.POST)

public ResponseBean testPost(@RequestBody RequestBean requestBean)

{

ResponseBean responseBean = new ResponseBean()

responseBean.setRetCode("0000")

responseBean.setRetMsg("succ")

return responseBean

}

}

使用RestTemplate访问该服务

//请求地址

String url = ""

//入参

RequestBean requestBean = new RequestBean()

requestBean.setTest1("1")

requestBean.setTest2("2")

requestBean.setTest3("3")

RestTemplate restTemplate = new RestTemplate()

ResponseBean responseBean = restTemplate.postForObject(url, requestBean, ResponseBean.class)

从这个例子可以看出，使用restTemplate访问restful接口非常的简单粗暴无脑。(url,

requestMap, ResponseBean.class)这三个参数分别代表 请求地址、请求参数、HTTP响应转换被转换成的对象类型。

RestTemplate方法的名称遵循命名约定，第一部分指出正在调用什么HTTP方法，第二部分指示返回的内容。本例中调用了restTemplate.postForObject方法，post指调用了HTTP的post方法，Object指将HTTP响应转换为您选择的对象类型。还有其他很多类似的方法，有兴趣的同学可以参考官方api。

三.手动指定转换器(HttpMessageConverter)

我们知道，调用reseful接口传递的数据内容是json格式的字符串，返回的响应也是json格式的字符串。然而restTemplate.postForObject方法的请求参数RequestBean和返回参数ResponseBean却都是java类。是RestTemplate通过HttpMessageConverter自动帮我们做了转换的 *** 作。

默认情况下RestTemplate自动帮我们注册了一组HttpMessageConverter用来处理一些不同的contentType的请求。

如StringHttpMessageConverter来处理text/plainMappingJackson2HttpMessageConverter来处理application/jsonMappingJackson2XmlHttpMessageConverter来处理application/xml。

你可以在org.springframework.http.converter包下找到所有spring帮我们实现好的转换器。

如果现有的转换器不能满足你的需求，你还可以实现org.springframework.http.converter.HttpMessageConverter接口自己写一个。详情参考官方api。

选好了HttpMessageConverter后怎么把它注册到我们的RestTemplate中呢。

RestTemplate restTemplate = new RestTemplate()

//获取RestTemplate默认配置好的所有转换器

List<HttpMessageConverter>messageConverters = restTemplate.getMessageConverters()

//默认的MappingJackson2HttpMessageConverter在第7个 先把它移除掉

messageConverters.remove(6)

//添加上GSON的转换器

messageConverters.add(6, new GsonHttpMessageConverter())

这个简单的例子展示了如何使用GsonHttpMessageConverter替换掉默认用来处理application/json的MappingJackson2HttpMessageConverter。

四.设置底层连接方式

要创建一个RestTemplate的实例，您可以像上述例子中简单地调用默认的无参数构造函数。这将使用java.NET包中的标准Java类作为底层实现来创建HTTP请求。

但很多时候我们需要像传统的HttpClient那样设置HTTP请求的一些属性。RestTemplate使用了一种很偷懒的方式实现了这个需求，那就是直接使用一个HttpClient作为底层实现......

//生成一个设置了连接超时时间、请求超时时间、异常最大重试次数的httpClient

RequestConfig config = RequestConfig.custom().setConnectionRequestTimeout(10000).setConnectTimeout(10000).setSocketTimeout(30000).build()

HttpClientBuilder builder = HttpClientBuilder.create().setDefaultRequestConfig(config).setRetryHandler(new DefaultHttpRequestRetryHandler(5, false))

HttpClient httpClient = builder.build()

//使用httpClient创建一个ClientHttpRequestFactory的实现

ClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(httpClient)

//ClientHttpRequestFactory作为参数构造一个使用作为底层的RestTemplate

RestTemplate restTemplate = new RestTemplate(requestFactory)

五.设置拦截器(ClientHttpRequestInterceptor)

有时候我们需要对请求做一些通用的拦截设置，这就可以使用拦截器进行处理。拦截器需要我们实现org.springframework.http.client.ClientHttpRequestInterceptor接口自己写。

举个简单的例子，写一个在header中根据请求内容和地址添加令牌的拦截器。

public class TokenInterceptor implements ClientHttpRequestInterceptor

{

@Override

public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException

{

//请求地址

String checkTokenUrl = request.getURI().getPath()

//token有效时间

int ttTime = (int) (System.currentTimeMillis() / 1000 + 1800)

//请求方法名 POST、GET等

String methodName = request.getMethod().name()

//请求内容

String requestBody = new String(body)

//生成令牌 此处调用一个自己写的方法，有兴趣的朋友可以自行google如何使用ak/sk生成token，此方法跟本教程无关，就不贴出来了

String token = TokenHelper.generateToken(checkTokenUrl, ttTime, methodName, requestBody)

//将令牌放入请求header中

request.getHeaders().add("X-Auth-Token",token)

return execution.execute(request, body)

}

}

创建RestTemplate实例的时候可以这样向其中添加拦截器

RestTemplate restTemplate = new RestTemplate()

//向restTemplate中添加自定义的拦截器

restTemplate.getInterceptors().add(new TokenInterceptor())

---