- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我使用 Spring for Android 作为 Android 应用程序中远程调用的 REST 模板。
目前正在努力将图片上传到服务器。
我想到了类似的东西:
public Picture uploadPicture(String accessToken, String fileToUpload) throws RestClientException {
RestTemplate rest = new RestTemplate();
FormHttpMessageConverter formConverter = new FormHttpMessageConverter();
formConverter.setCharset(Charset.forName("UTF8"));
CustomGsonHttpMessageConverter jsonConverter = new CustomGsonHttpMessageConverter();
rest.getMessageConverters().add(formConverter);
rest.getMessageConverters().add(jsonConverter);
String uploadUri = AppConfig.ROOT_URL.concat(AppConfig.ADD_PHOTO);
HashMap<String, Object> urlVariables = new HashMap<String, Object>();
urlVariables.put("accessToken", accessToken);
HttpHeaders httpHeaders = new HttpHeaders();
httpHeaders.setAccept(Collections.singletonList(MediaType.parseMediaType("application/json")));
MultiValueMap<String, Object> parts = new LinkedMultiValueMap<String, Object>();
parts.add("picture", new FileSystemResource(fileToUpload));
Picture response = rest.postForObject(uploadUri, parts, Picture.class, urlVariables);
return response;
}
工作正常,但现在我想从中获取进度更新。
有谁知道这是否可能以及如何做到这一点?
提前致谢:)
最佳答案
所以我遇到了同样的问题并决定查看 Spring-Android 源代码。经过大量挖掘,我发现了我需要扩展的内容。从中得到一些灵感 link .
进度监听器
public interface ProgressListener {
void transferred(long num);
}
计数输入流
public class CountingInputStream extends FileInputStream {
private final ProgressListener listener;
private long transferred;
public CountingInputStream(File file, ProgressListener listener) throws FileNotFoundException {
super(file);
this.listener = listener;
this.transferred = 0;
}
@Override
public int read(byte[] buffer) throws IOException {
int bytesRead = super.read(buffer);
if (bytesRead != -1) {
this.transferred += bytesRead;
}
this.listener.transferred(this.transferred);
return bytesRead;
}
}
ListenerFileSystemResource
public class ListenerFileSystemResource extends FileSystemResource {
private final ProgressListener listener;
public ListenerFileSystemResource(File file, ProgressListener listener) {
super(file);
this.listener = listener;
}
@Override
public InputStream getInputStream() throws IOException {
return new CountingInputStream(super.getFile(), listener);
}
}
发送文件任务
private class SendFileTask extends AsyncTask<String, Integer, Boolean> {
private ProgressListener listener;
private long totalSize;
@Override
protected Boolean doInBackground(String... params) {
File file = new File(filePath);
totalSize = file.length();
listener = new ProgressListener() {
@Override
public void transferred(long num) {
publishProgress((int) ((num / (float) totalSize) * 100));
}
};
ListenerFileSystemResource resource = new ListenerFileSystemResource(file, listener);
MyResult result = new MyService().uploadFile(resource);
}
我的服务
public FileResult uploadFile(ListenerFileSystemResource resource, Long userId, FileType type) {
String[] pathParams = {ConnectorConstants.FILE_RESOURCE };
String[] headerKeys = {"manager_user_id"};
String[] headerValues = {String.valueOf(userId)};
String[] formKeys = {ConnectorConstants.FILE_FORM_PARAM};
Object[] formValues = {resource};
MultiValueMap<String, Object> body = createMultiValueMap(formKeys, formValues);
HttpConnector<FileResult> connector = new HttpConnector<FileResult>(FileResult.class);
return connector.path(pathParams).header(createValuePairs(headerKeys, headerValues)).multipart().body(body).post();
}
HttpConnector
public final class HttpConnector<T> {
public static String API_URL = "https://myapi.com";
private UriComponentsBuilder builder;
private RestTemplate template;
private Class<T> generic;
private HttpEntity<?> requestEntity;
private HttpHeaders headers;
/**
*
* @param generic
*/
protected HttpConnector(Class<T> generic)
{
this.builder = UriComponentsBuilder.fromUriString(API_URL);
this.template = new RestTemplate();
this.template.setRequestFactory(new HttpComponentsClientHttpRequestFactory());
this.generic = generic;
this.template.getMessageConverters().add(new GsonHttpMessageConverter(getGson()));
this.headers = new HttpHeaders();
}
/**
*
* @param pathSegments
* @return
*/
protected HttpConnector<T> path(String[] pathSegments)
{
this.builder = builder.pathSegment(pathSegments);
return this;
}
/**
*
* @param headerParams
* @return
*/
protected HttpConnector<T> header(List<NameValuePair> headerParams)
{
for (NameValuePair param : headerParams)
{
headers.add(param.getName(), param.getValue());
}
return this;
}
/**
*
* @param queryParams
* @return
*/
protected HttpConnector<T> query(List<NameValuePair> queryParams)
{
for (NameValuePair param : queryParams)
{
this.builder = builder.queryParam(param.getName(), param.getValue());
}
return this;
}
/**
*
* @param body
* @return
*/
protected HttpConnector<T> body(MultiValueMap<String, ? extends Object> body)
{
this.requestEntity = new HttpEntity<Object>(body, headers);
return this;
}
/**
*
* @param body
* @return
*/
protected HttpConnector<T> body(Object body)
{
this.requestEntity = new HttpEntity<Object>(body, headers);
headers.setContentType(MediaType.APPLICATION_JSON);
return this;
}
/**
*
* @return
*/
protected HttpConnector<T> form()
{
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
return addFormConverter();
}
/**
*
* @return
*/
protected HttpConnector<T> multipart()
{
headers.setContentType(MediaType.MULTIPART_FORM_DATA);
return addFormConverter();
}
/**
*
* @return
*/
private HttpConnector<T> addFormConverter()
{
this.template.getMessageConverters().add(new FormHttpMessageConverter());
return this;
}
/**
*
* @return
* @throws MeplisNotFoundException
*/
protected T post() throws MeplisNotFoundException
{
return sendRequest(HttpMethod.POST);
}
/**
*
* @return
* @throws MeplisNotFoundException
*/
protected T put() throws MeplisNotFoundException
{
return sendRequest(HttpMethod.PUT);
}
/**
*
* @return
* @throws MeplisNotFoundException
*/
protected T get() throws MeplisNotFoundException
{
return sendRequest(HttpMethod.GET);
}
/**
*
* @param method
* @return
* @throws MeplisNotFoundException
*/
private T sendRequest(HttpMethod method) throws MyServiceNotFoundException
{
HttpStatus status = null;
ResponseEntity<T> response;
try
{
response = template.exchange(toUri(), method, getRequestEntity(), generic);
status = response.getStatusCode();
if (HttpStatus.OK.equals(status))
{
return response.getBody();
}
} catch (HttpClientErrorException e)
{
if (HttpStatus.NOT_FOUND.equals(e.getStatusCode()))
{
throw new MyServiceNotFoundException();
}
else
{
Log.e(getClass().toString(), String.format("Error %s request, status[%s]", method.toString(), e.getStatusCode()), e);
}
} catch (Exception e)
{
Log.e(getClass().toString(), String.format("Error %s request, status: %s", method.toString(), status), e);
}
return null;
}
/**
*
* @return
*/
private HttpEntity<?> getRequestEntity()
{
if (this.requestEntity == null)
{
this.requestEntity = new HttpEntity<Object>(headers);
}
return requestEntity;
}
/**
*
* @return
*/
private URI toUri()
{
return this.builder.build().toUri();
}
/**
*
* @return
*/
private Gson getGson()
{
return new GsonBuilder().create();
}
/**
*
* @return
*/
public HttpHeaders getHeaders()
{
return headers;
}
}
而且我使用 ListenerFileSystemResource 而不是 FileSystemResource 并且可以正常工作。希望这对以后的人有帮助,因为我没有找到任何关于 Spring 框架的信息。
关于android - Spring for Android,文件上传进度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14412773/
我最近在/ drawable中添加了一些.gifs,以便可以将它们与按钮一起使用。这个工作正常(没有错误)。现在,当我重建/运行我的应用程序时,出现以下错误: Error: Gradle: Execu
Android 中有返回内部存储数据路径的方法吗? 我有 2 部 Android 智能手机(Samsung s2 和 s7 edge),我在其中安装了一个应用程序。我想使用位于这条路径中的 sqlit
这个问题在这里已经有了答案: What's the difference between "?android:" and "@android:" in an android layout xml f
我只想知道 android 开发手机、android 普通手机和 android root 手机之间的实际区别。 我们不能从实体店或除 android marketplace 以外的其他地方购买开发手
自Gradle更新以来,我正在努力使这个项目达到标准。这是一个团队项目,它使用的是android-apt插件。我已经进行了必要的语法更改(编译->实现和apt->注释处理器),但是编译器仍在告诉我存在
我是android和kotlin的新手,所以请原谅要解决的一个非常简单的问题! 我已经使用导航体系结构组件创建了一个基本应用程序,使用了底部的导航栏和三个导航选项。每个导航选项都指向一个专用片段,该片
我目前正在使用 Facebook official SDK for Android . 我现在正在使用高级示例应用程序,但我不知道如何让它获取应用程序墙/流/状态而不是登录的用户。 这可能吗?在那种情
我在下载文件时遇到问题, 我可以在模拟器中下载文件,但无法在手机上使用。我已经定义了上网和写入 SD 卡的权限。 我在服务器上有一个 doc 文件,如果用户单击下载。它下载文件。这在模拟器中工作正常但
这个问题在这里已经有了答案: What is the difference between gravity and layout_gravity in Android? (22 个答案) 关闭 9
任何人都可以告诉我什么是 android 缓存和应用程序缓存,因为当我们谈论缓存清理应用程序时,它的作用是,缓存清理概念是清理应用程序缓存还是像内存管理一样主存储、RAM、缓存是不同的并且据我所知,缓
假设应用程序 Foo 和 Eggs 在同一台 Android 设备上。任一应用程序都可以获取设备上所有应用程序的列表。一个应用程序是否有可能知道另一个应用程序是否已经运行以及运行了多长时间? 最佳答案
我有点困惑,我只看到了从 android 到 pc 或者从 android 到 pc 的例子。我需要制作一个从两部手机 (android) 连接的 android 应用程序进行视频聊天。我在想,我知道
用于使用 Android 以编程方式锁定屏幕。我从 Stackoverflow 之前关于此的问题中得到了一些好主意,并且我做得很好,但是当我运行该代码时,没有异常和错误。而且,屏幕没有锁定。请在这段代
文档说: android:layout_alignParentStart If true, makes the start edge of this view match the start edge
我不知道这两个属性和高度之间的区别。 以一个TextView为例,如果我将它的layout_width设置为wrap_content,并将它的width设置为50 dip,会发生什么情况? 最佳答案
这两个属性有什么关系?如果我有 android:noHistory="true",那么有 android:finishOnTaskLaunch="true" 有什么意义吗? 最佳答案 假设您的应用中有
我是新手,正在尝试理解以下 XML 代码: 查看 developer.android.com 上的文档,它说“starStyle”是 R.attr 中的常量, public static final
在下面的代码中,为什么当我设置时单选按钮的外观会发生变化 android:layout_width="fill_parent" 和 android:width="fill_parent" 我说的是
很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开,visit the help center . 关闭 9
假设我有一个函数 fun myFunction(name:String, email:String){},当我调用这个函数时 myFunction('Ali', 'ali@test.com ') 如何
我是一名优秀的程序员,十分优秀!