java文件上传到某一台指定服务器怎么弄?
使用Java中的Socket类或Java NIO(New IO)库来建立网络连接。
在连接上发送文件,可以使用Java中的FileInputStream或FileReader类从本地文件系统读取文件内容,然后使用OutputStream或Writer类将文件内容写入网络连接。
在服务器端,使用Java中的ServerSocket类或Java NIO库来接收网络连接。
在服务器端,读取网络连接中的文件内容,可以使用Java中的InputStream或Reader类从网络连接中读取文件内容,然后使用Java中的FileOutputStream或FileWriter类将文件内容写入服务器本地文件系统。
关闭网络连接和文件流。
需要注意的是,要确保服务器端有足够的权限来访问文件系统,并且要正确处理文件名和路径,以避免安全问题和文件冲突。
很简单,就是把多个文件“变成”一个文件传送就可以了,每个文件都是一个流,把这些流输入到一个流中合并流传输即可,这个是基本思路。实现差不多以下两个方法
1、直接流拼接,循环要传输的文件列表,多个InputStream,然后输出到一个OutputStream,这个out就是发送数据的端口,为了接收端能够识别每个文件从而分割流,需要每个流中结尾添加分隔符。其实这就是HTTP文件上传的做法。
2、就比较简单了,职业使用ZIP工具包吧需要传输的多文件压缩成一个文件传输,接收端直接解压缩就完事。
需要注意的是,发送多文件上传你需要提取计算好总传输量字节大小放在传输报文头部告诉接收端你要发送的数据有多大,不然接收端可能无法完整接收数据。
据我的能力理解不太能同时实现。
我讲下我的实现思路:
1,你有一台作为接收,文件上传至此, 得到file1;
2,file1,输出到另一台机器 建议采用(ftp协议),至于是同步还是异步执行无关紧要。
3,其他逻辑。
给一种方式做参考,我这边类似。是将A作为客户端,上传文件到服务器B,服务器B以struts接受请求做处理。使用httpclient。
/将文件上传到服务端,并接收其返回信息
@param client DefaultHttpClient
@param url 服务器url:如:http://localhost:8080/test/uploadaction
@param filePath 文件路径
@param params 上传参数
@param encode 编码集,主要用来解析返回的response中的信息
@return 解析出的返回信息,如服务器那边的成功提示:“success”
/
public static String sendHttpClientPostToUpload(DefaultHttpClient client, String url, String filePath,
Map<String, String> params, String encode){
MultipartEntity mpEntity = new MultipartEntity();
if (params != null && !paramsisEmpty()) {
for (MapEntry<String, String> entry : paramsentrySet()) {
// 参数名
StringBody par;
try {
par = new StringBody(entrygetValue()toString());
mpEntityaddPart(entrygetKey(), par);
} catch (UnsupportedEncodingException e) {
eprintStackTrace();
}
}
}
//
if (!filePathequals("")) {
FileBody file = new FileBody(new File(filePath));
mpEntityaddPart("file", file);
}
// 使用HttpPost对象设置发送的URL路径
HttpPost post = new HttpPost(url);
postsetEntity(mpEntity);
// 创建一个浏览器对象,以把POST对象向服务器发送,并返回响应消息
try {
HttpResponse response = clientexecute(post);
if (responsegetStatusLine()getStatusCode() == HttpStatusSC_OK) {
// 封装了服务器端返回的数据
HttpEntity responseEntity = responsegetEntity();
//这里是对服务器返回的session进行记录的操作,以获取sessionId
// CookieStore mCookieStore = ((DefaultHttpClient) client)getCookieStore();
// List<Cookie> cookies = mCookieStoregetCookies();
// for (int i = 0; i < cookiessize(); i++) {
// // 如果cookies头和"JSESSIONID" 就记录sessionID
// if ("JSESSIONID"equals(cookiesget(i)getName())) {
// String sessionId = cookiesget(i)getValue();
// break;
// }
// }
//完成
InputStream is = responseEntitygetContent();
return changeInputStream(responseEntitygetContent(), encode);
}
} catch (ClientProtocolException e) {
eprintStackTrace();
} catch (IOException e) {
eprintStackTrace();
}
return "";
}/
@param inputStream
@param encode
@return
/
private static String changeInputStream(InputStream inputStream,
String encode) {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
int len = 0;
byte[] date = new byte[1024];
String result = "";
try {
while ((len = inputStreamread(date)) != -1) {
outputStreamwrite(date, 0, len);
}
result = new String(outputStreamtoByteArray(), encode);
return result;
} catch (IOException e) {
eprintStackTrace();
}
return null;
}
需要的参数client,new 一个就可以了。
DefaultHttpClient client = new DefaultHttpClient();类似参考网上有很多,不过大都是你转载他得,他转载你的,能用的不多。
你好!
另一台机器也要有处理文件上传的WEB程序,你可以参考Stream上传插件(支持HTML5和Flash两种方式上传)
Stream 上传插件
Stream 是解决不同浏览器上传文件的插件,是Uploadify的Flash版和Html5版的结合!
Stream 简介
Stream 是根据某网的文件上传插件加工而来,支持不同平台(Windows, Linux, Mac, Android, iOS)下,主流浏览器(IE7+, Chrome, Firefox, Safari, 其他)的上传工作,当然在Html5标准下,还支持文件的断点续传功能,有效解决大文件的Web上传问题!
主要特征
1 源码完全开放,目前有Java、PHP、Perl三种后台语言实现
2 支持HTML5、Flash两种方式(跨域)上传
3 多文件一起上传
4 HTML5支持断点续传,拖拽等新特性
5 兼容性好IE7+, FF36+, Chrome,Safari4+,遨游等主流浏览器
6 进度条、速度、剩余时间等附属信息
7 `选择文件的按钮`可以自定义
8 简单的参数配置实现 灵活多变的功能
9 支持文件夹上传(Chrome21+, Opera15+)
10 支持自定义UI(V14+)
指定跨域上传就可以了
这些都是小鸟云的工程师告诉我的,建议你可以试试小鸟云
分布式是一种思想,范围很广,我得先知道它的诞生:
以前是一个数据库一个JSP就可以做一个应用了,后来随着业务复杂,我们开始分层,比如MVC之类的,再后来我们的数据越来越多了,比如有上亿的数据,这个时候我们一个数据库查询太慢了,就开始分库,这也算是分布式的一种。
还有比如我们的系统访问的人多了,比如双11,上千万人同时访问,我们的服务器(网站)支持不住了,这个时候就要部署到很多个服务器,每个服务器分摊请求,这也是分布式
当然随着业务扩大,我们得分业务了,比如注册登录的,物流的,卖东西的等等,不同的系统,但是各个系统之间进行协调,也算分布式一种
以上都算是分布式的来源,主要是解决压力过大,大家协同工作的,那么这就涉及到一些常用的东西,或者像你说的的技术
1你用N个数据库才放数据,至少CRUD方面就麻烦些了,得用cobar,tddl,mysql-proxy等协调
2服务器:你部署了很多服务器,肯定得用个东西来分发请求这些吧,nginx,apache等分发请求。
3你公司有很多系统,想很好的联系在一起,光用接口不满足了,得用一些JMS,像activemq,ons之类的来协调吧
4为了解决io问题,得加缓存吧,那么缓存对应上面的,也得分布式吧,就涉及memcache,redies等等
上面就简单的介绍了下分布式的东西,还有很多啦,这是常用的一些,希望你能慢慢来,不是一下子能理解得
服务器端源码:\x0d\import javaioBufferedReader;\x0d\import javaioFile;\x0d\import javaioFileNotFoundException;\x0d\import javaioFileOutputStream;\x0d\import javaioIOException;\x0d\import javaioInputStream;\x0d\import javaioInputStreamReader;\x0d\import javanetServerSocket;\x0d\import javanetSocket;\x0d\\x0d\/\x0d\ \x0d\ 文件名:ServerReceivejava\x0d\ 实现功能:作为服务器接收客户端发送的文件\x0d\ \x0d\ 具体实现过程:\x0d\ 1、建立SocketServer,等待客户端的连接\x0d\ 2、当有客户端连接的时候,按照双方的约定,这时要读取一行数据\x0d\ 其中保存客户端要发送的文件名和文件大小信息\x0d\ 3、根据文件名在本地创建文件,并建立好流通信\x0d\ 4、循环接收数据包,将数据包写入文件\x0d\ 5、当接收数据的长度等于提前文件发过来的文件长度,即表示文件接收完毕,关闭文件\x0d\ 6、文件接收工作结束\x0d\\x0d\public class ServerReceive {\x0d\ \x0d\ public static void main(String[] args) {\x0d\ \x0d\ /与服务器建立连接的通信句柄/\x0d\ ServerSocket ss = null;\x0d\ Socket s = null;\x0d\ \x0d\ /定义用于在接收后在本地创建的文件对象和文件输出流对象/\x0d\ File file = null;\x0d\ FileOutputStream fos = null;\x0d\ \x0d\ /定义输入流,使用socket的inputStream对数据包进行输入/\x0d\ InputStream is = null;\x0d\ \x0d\ /定义byte数组来作为数据包的存储数据包/\x0d\ byte[] buffer = new byte[4096 5];\x0d\ \x0d\ /用来接收文件发送请求的字符串/\x0d\ String comm = null;\x0d\\x0d\/建立socekt通信,等待服务器进行连接/\x0d\ try {\x0d\ ss = new ServerSocket(4004);\x0d\ s = ssaccept();\x0d\ } catch (IOException e) {\x0d\ eprintStackTrace();\x0d\ }\x0d\\x0d\/读取一行客户端发送过来的约定信息/\x0d\ try {\x0d\ InputStreamReader isr = new InputStreamReader(sgetInputStream());\x0d\ BufferedReader br = new BufferedReader(isr);\x0d\ comm = brreadLine();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器与客户端断开连接");\x0d\ }\x0d\ \x0d\ /开始解析客户端发送过来的请求命令/\x0d\ int index = commindexOf("/#");\x0d\ \x0d\ /判断协议是否为发送文件的协议/\x0d\ String xieyi = commsubstring(0, index);\x0d\ if(!xieyiequals("111")){\x0d\ Systemoutprintln("服务器收到的协议码不正确");\x0d\ return;\x0d\ }\x0d\ \x0d\ /解析出文件的名字和大小/\x0d\ comm = commsubstring(index + 2);\x0d\ index = commindexOf("/#");\x0d\ String filename = commsubstring(0, index)trim();\x0d\ String filesize = commsubstring(index + 2)trim();\x0d\\x0d\/创建空文件,用来进行接收文件/\x0d\ file = new File(filename);\x0d\ if(!fileexists()){\x0d\ try {\x0d\ filecreateNewFile();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器端创建文件失败");\x0d\ }\x0d\ }else{\x0d\ /在此也可以询问是否覆盖/\x0d\ Systemoutprintln("本路径已存在相同文件,进行覆盖");\x0d\ }\x0d\ \x0d\ /以上就是客户端代码中写到的服务器的准备部分/\x0d\\x0d\/\x0d\ 服务器接收文件的关键代码/\x0d\ try {\x0d\ /将文件包装到文件输出流对象中/\x0d\ fos = new FileOutputStream(file);\x0d\ long file_size = LongparseLong(filesize);\x0d\ is = sgetInputStream();\x0d\ /size为每次接收数据包的长度/\x0d\ int size = 0;\x0d\ /count用来记录已接收到文件的长度/\x0d\ long count = 0;\x0d\ \x0d\ /使用while循环接收数据包/\x0d\ while(count
0条评论