有关java client——server 间传送文件的问题，本想通过server把client1 发来的信息传送给client2

一般情况是使用DOM,SAX这是2个开原的插件,你只要在你的程序里导入就可以了JDOM或者DOM4J的JAR包就可以了。

下载的 这2个插件都有自己的网站,建议使用JDOM这个比较简单的,至于如何读和写,网上有很多的例子

XML作为全球通用的结构化语言，越来越受人们青睐，各种开发平台（比如Microsoft Studio系列、Oracle系列、Inprise Borland系列等）也都把支持XML开发作为宣传口号之一 。由于笔者所从事的电子政务开发较早的引入了XML,所以尝到了许多甜头，在许多项目中利用XML数据交换信息，省去了许多麻烦事，不用制定繁锁的数据格式，利用XML数据易于表达，也利于一线开发者跟踪调试。

笔者先前也曾发表过相关的文章，比如《简析Delphi中的XML编程》一文，有兴趣的读者可以到Google网（）去搜索一下，有很多媒体转载。今天笔者想探讨的是关于JAVA中的XML编程，希望对正在或想要学习XML编程的新老读者有所帮助。

在XML应用中，最常用也最实用的莫过于XML文件的读写，所以笔者通过一个简单的XML文件读写来作简要分析。可以在任何文本编辑器中先建立如下结构的XML文件，类似于HTML结构，但XML语义比较严格，起始标记必须配对，比如"〈学生花名册〉"与"〈／学生花名册〉"对应，空格多少可不必在意，但一般都以缩格形式书写，便于阅读。把此文件命名为Inputxml，可以在任何支持XML的浏览器中打开测试一下，如果输入正确，在浏览中可以看到此文件的树形表示结构。如果您还对XML结构感到比较陌生，建议先看看《简析Delphi中的XML编程》一文中关于XML文件的说明。

Inputxml

[code:1:af65f1d5b3]

<xml version="10" encoding="GB2312">

<学生花名册>

<学生 性别 = "男">

<姓名>李华</姓名>

<年龄>14</年龄>

<电话>6287555</电话>

</学生>

<学生 性别 = "男">

<姓名>张三</姓名>

<年龄>16</年龄>

<电话>8273425</电话>

</学生>

</学生花名册>

[/code:1:af65f1d5b3]

准备工作做完后，接着就开始写实质性的JAVA代码了。为保存从XML文件读入的信息，需要先建一个简单的Bean来保存学生信息，命名为StudentBean，代码如下所示：

StudentBeanjava

[code:1:af65f1d5b3]

public class StudentBean {

private String sex; //学生性别

private String name; //学生姓名

private int age; //学生年龄

private String phone; //电话号码

public void setSex(String s) {

sex = s;

}

public void setName(String s) {

name = s;

}

public void setAge(int a) {

age = a;

}

public void setPhone(String s) {

phone = s;

}

public String getSex() {

return sex;

}

public String getName() {

return name;

}

public int getAge() {

return age;

}

public String getPhone() {

return phone;

}

}

[/code:1:af65f1d5b3]

之后写XML的测试类，

TESTXmljava

[code:1:af65f1d5b3]

import javaio; //Java基础包，包含各种IO操作

import javautil; //Java基础包，包含各种标准数据结构操作

import javaxxmlparsers; //XML解析器接口

import orgw3cdom; //XML的DOM实现

import orgapachecrimsontreeXmlDocument; //写XML文件要用到

public class XMLTest {

Vector student_Vector;

XMLTest() {

}

//为了保存多个学生信息，还得借助一个集合类(并不是单纯意义上的集合，JAVA中的集合是集合框架的概念，包含向量、列表、哈希表等），这里采用Vector向量类。定义在XMLTest测试类中，命名为student_Vector。然后定义两个方法readXMLFile和writeXMLFile，实现读写操作。代码如下：

private void readXMLFile(String inFile) throws Exception {

//为解析XML作准备，创建DocumentBuilderFactory实例,指定DocumentBuilder

DocumentBuilderFactory dbf = DocumentBuilderFactorynewInstance();

DocumentBuilder db = null;

try {

db = dbfnewDocumentBuilder();

}

catch (ParserConfigurationException pce) {

Systemerrprintln(pce); //出异常时输出异常信息，然后退出，下同

Systemexit(1);

}

Document doc = null;

try {

doc = dbparse(inFile);

}

catch (DOMException dom) {

Systemerrprintln(domgetMessage());

Systemexit(1);

}

catch (IOException ioe) {

Systemerrprintln(ioe);

Systemexit(1);

}

//下面是解析XML的全过程，比较简单，先取根元素"学生花名册"

Element root = docgetDocumentElement();

//取"学生"元素列表

NodeList students = rootgetElementsByTagName("学生");

for (int i = 0; i < studentsgetLength(); i++) {

//依次取每个"学生"元素

Element student = (Element) studentsitem(i);

//创建一个学生的Bean实例

StudentBean studentBean = new StudentBean();

//取学生的性别属性

studentBeansetSex(studentgetAttribute("性别"));

//取"姓名"元素，下面类同

NodeList names = studentgetElementsByTagName("姓名");

if (namesgetLength() == 1) {

Element e = (Element) namesitem(0);

Text t = (Text) egetFirstChild();

studentBeansetName(tgetNodeValue());

}

NodeList ages = studentgetElementsByTagName("年龄");

if (agesgetLength() == 1) {

Element e = (Element) agesitem(0);

Text t = (Text) egetFirstChild();

studentBeansetAge(IntegerparseInt(tgetNodeValue()));

}

NodeList phones = studentgetElementsByTagName("电话");

if (phonesgetLength() == 1) {

Element e = (Element) phonesitem(0);

Text t = (Text) egetFirstChild();

studentBeansetPhone(tgetNodeValue());

}

student_Vectoradd(studentBean);

}

}

private void writeXMLFile(String outFile) throws Exception {

//为解析XML作准备，创建DocumentBuilderFactory实例,指定DocumentBuilder

DocumentBuilderFactory dbf = DocumentBuilderFactorynewInstance();

DocumentBuilder db = null;

try {

db = dbfnewDocumentBuilder();

}

catch (ParserConfigurationException pce) {

Systemerrprintln(pce);

Systemexit(1);

}

Document doc = null;

doc = dbnewDocument();

//下面是建立XML文档内容的过程，先建立根元素"学生花名册"

Element root = doccreateElement("学生花名册");

//根元素添加上文档

docappendChild(root);

//取学生信息的Bean列表

for (int i = 0; i < student_Vectorsize(); i++) {

//依次取每个学生的信息

StudentBean studentBean = (StudentBean) student_Vectorget(i);

//建立"学生"元素，添加到根元素

Element student = doccreateElement("学生");

studentsetAttribute("性别", studentBeangetSex());

rootappendChild(student);

//建立"姓名"元素，添加到学生下面，下同

Element name = doccreateElement("姓名");

studentappendChild(name);

Text tName = doccreateTextNode(studentBeangetName());

nameappendChild(tName);

Element age = doccreateElement("年龄");

studentappendChild(age);

Text tAge = doccreateTextNode(StringvalueOf(studentBean

getAge()));

ageappendChild(tAge);

Element phone = doccreateElement("电话");

studentappendChild(phone);

Text tPhone = doccreateTextNode(studentBeangetPhone());

phoneappendChild(tPhone);

}

//把XML文档输出到指定的文件

FileOutputStream outStream = new FileOutputStream(outFile);

OutputStreamWriter outWriter = new OutputStreamWriter(outStream);

( (XmlDocument) doc)write(outWriter, "GB2312");

outWriterclose();

outStreamclose();

}

//最后加入测试主函数，如下：

public static void main(String[] args) throws Exception {

//建立测试实例

XMLTest xmlTest = new XMLTest();

//初始化向量列表

xmlTeststudent_Vector = new Vector();

Systemoutprintln("开始读Inputxml文件");

xmlTestreadXMLFile("Inputxml");

Systemoutprintln("读入完毕,开始写Outputxml文件");

xmlTestwriteXMLFile("Outputxml");

Systemoutprintln("写入完成");

Systeminread();

}

}[/code:1:af65f1d5b3]

了，保存好StudentBean和XMLTest，把Inputxml保存到工作目录下。如果您输入很仔细，没敲错字母的话，可以看到"写入完成"了，去瞧瞧Outputxml文件和Inputxml文件是不是一样吧。如果您在调试过程中发现有什么问题，欢迎通过E-Mail：nbDeveloper@hotmailcom与笔者取得联系。 [/code]

服务器端源码：

import javaioBufferedReader;

import javaioFile;

import javaioFileNotFoundException;

import javaioFileOutputStream;

import javaioIOException;

import javaioInputStream;

import javaioInputStreamReader;

import javanetServerSocket;

import javanetSocket;

/

文件名：ServerReceivejava

实现功能：作为服务器接收客户端发送的文件

具体实现过程：

1、建立SocketServer，等待客户端的连接

2、当有客户端连接的时候，按照双方的约定，这时要读取一行数据

其中保存客户端要发送的文件名和文件大小信息

3、根据文件名在本地创建文件，并建立好流通信

4、循环接收数据包，将数据包写入文件

5、当接收数据的长度等于提前文件发过来的文件长度，即表示文件接收完毕，关闭文件

6、文件接收工作结束

public class ServerReceive {

public static void main(String[] args) {

/与服务器建立连接的通信句柄/

ServerSocket ss = null;

Socket s = null;

/定义用于在接收后在本地创建的文件对象和文件输出流对象/

File file = null;

FileOutputStream fos = null;

/定义输入流，使用socket的inputStream对数据包进行输入/

InputStream is = null;

/定义byte数组来作为数据包的存储数据包/

byte[] buffer = new byte[4096 5];

/用来接收文件发送请求的字符串/

String comm = null;

/建立socekt通信，等待服务器进行连接/

try {

ss = new ServerSocket(4004);

s = ssaccept();

} catch (IOException e) {

eprintStackTrace();

}

/读取一行客户端发送过来的约定信息/

try {

InputStreamReader isr = new InputStreamReader(sgetInputStream());

BufferedReader br = new BufferedReader(isr);

comm = brreadLine();

} catch (IOException e) {

Systemoutprintln("服务器与客户端断开连接");

}

/开始解析客户端发送过来的请求命令/

int index = commindexOf("/#");

/判断协议是否为发送文件的协议/

String xieyi = commsubstring(0, index);

if(!xieyiequals("111")){

Systemoutprintln("服务器收到的协议码不正确");

return;

}

/解析出文件的名字和大小/

comm = commsubstring(index + 2);

index = commindexOf("/#");

String filename = commsubstring(0, index)trim();

String filesize = commsubstring(index + 2)trim();

/创建空文件，用来进行接收文件/

file = new File(filename);

if(!fileexists()){

try {

filecreateNewFile();

} catch (IOException e) {

Systemoutprintln("服务器端创建文件失败");

}

}else{

/在此也可以询问是否覆盖/

Systemoutprintln("本路径已存在相同文件，进行覆盖");

}

/以上就是客户端代码中写到的服务器的准备部分/

/

服务器接收文件的关键代码/

try {

/将文件包装到文件输出流对象中/

fos = new FileOutputStream(file);

long file_size = LongparseLong(filesize);

is = sgetInputStream();

/size为每次接收数据包的长度/

int size = 0;

/count用来记录已接收到文件的长度/

long count = 0;

/使用while循环接收数据包/

while(count < file_size){

/从输入流中读取一个数据包/

size = isread(buffer);

/将刚刚读取的数据包写到本地文件中去/

foswrite(buffer, 0, size);

fosflush();

/将已接收到文件的长度+size/

count += size;

Systemoutprintln("服务器端接收到数据包，大小为" + size);

}

} catch (FileNotFoundException e) {

Systemoutprintln("服务器写文件失败");

} catch (IOException e) {

Systemoutprintln("服务器：客户端断开连接");

}finally{

/

将打开的文件关闭

如有需要，也可以在此关闭socket连接

/

try {

if(fos != null)

fosclose();

} catch (IOException e) {

eprintStackTrace();

}//catch (IOException e)

}//finally

}//public static void main(String[] args)

}//public class ServerReceive

客户端源码：

import javaioFile;

import javaioFileInputStream;

import javaioFileNotFoundException;

import javaioIOException;

import javaioOutputStream;

import javaioPrintStream;

import javanetSocket;

/

文件名：ClientSendjava

实现功能：作为客户端向服务器发送一个文件

具体实现过程：

1、建立与服务器端的连接，IP：127001， port：4004

2、将文件的名字和大小通过自定义的文件传输协议，发送到服务器

3、循环读取本地文件，将文件打包发送到数据输出流中

4、关闭文件，结束传输

/

public class ClientSend {

public static void main(String[] args) {

/与服务器建立连接的通信句柄/

Socket s = null;

/定义文件对象，即为要发送的文件

如果使用绝对路径，不要忘记使用'/'和'\'的区别

具体区别，请读者自行查询

/

File sendfile = new File("APICHM");

/定义文件输入流，用来打开、读取即将要发送的文件/

FileInputStream fis = null;

/定义byte数组来作为数据包的存储数据包/

byte[] buffer = new byte[4096 5];

/定义输出流，使用socket的outputStream对数据包进行输出/

OutputStream os = null;

/检查要发送的文件是否存在/

if(!sendfileexists()){

Systemoutprintln("客户端：要发送的文件不存在");

return;

}

/与服务器建立连接/

try {

s = new Socket("127001", 4004);

}catch (IOException e) {

Systemoutprintln("未连接到服务器");

}

/用文件对象初始化fis对象

以便于可以提取出文件的大小

/

try {

fis = new FileInputStream(sendfile);

} catch (FileNotFoundException e1) {

e1printStackTrace();

}

/首先先向服务器发送关于文件的信息，以便于服务器进行接收的相关准备工作

具体的准备工作，请查看服务器代码。

发送的内容包括：发送文件协议码（此处为111）/#文件名（带后缀名）/#文件大小

/

try {

PrintStream ps = new PrintStream(sgetOutputStream());

psprintln("111/#" + sendfilegetName() + "/#" + fisavailable());

psflush();

} catch (IOException e) {

Systemoutprintln("服务器连接中断");

}

/

此处睡眠2s，等待服务器把相关的工作准备好

也是为了保证网络的延迟

读者可自行选择添加此代码

/

try {

Threadsleep(2000);

} catch (InterruptedException e1) {

e1printStackTrace();

}

/之前的准备工作结束之后

下面就是文件传输的关键代码

/

try {

/获取socket的OutputStream，以便向其中写入数据包/

os = sgetOutputStream();

/ size 用来记录每次读取文件的大小/

int size = 0;

/使用while循环读取文件，直到文件读取结束/

while((size = fisread(buffer)) != -1){

Systemoutprintln("客户端发送数据包，大小为" + size);

/向输出流中写入刚刚读到的数据包/

oswrite(buffer, 0, size);

/刷新一下/

osflush();

}

} catch (FileNotFoundException e) {

Systemoutprintln("客户端读取文件出错");

} catch (IOException e) {

Systemoutprintln("客户端输出文件出错");

}finally{

/

将打开的文件关闭

如有需要，也可以在此关闭socket连接

/

try {

if(fis != null)

fisclose();

} catch (IOException e) {

Systemoutprintln("客户端文件关闭出错");

}//catch (IOException e)

}//finally

}//public static void main(String[] args)

}//public class ClientSend

文件从本地到服务器的功能，其实是为了解决目前浏览器不支持获取本地文件全路径。不得已而想到上传到服务器的固定目录，从而方便项目获取文件，进而使程序支持EXCEL批量导入数据。

java中文件上传到服务器的指定路径的代码：

在前台界面中输入：

<form method="post" enctype="multipart/form-data"  action="/manage/excelImportdo">

请选文件:<input type="file"  name="excelFile">

<input type="submit" value="导入" onclick="return impExcel();"/>

</form>

action中获取前台传来数据并保存

/

excel 导入文件

@return

@throws IOException

/

@RequestMapping("/usermanager/excelImportdo")

public String excelImport(

String filePath,

MultipartFile  excelFile,HttpServletRequest request) throws IOException{

loginfo("<<<<<<action:{} Method:{} start>>>>>>","usermanager","excelImport" );

if (excelFile != null){

String filename=excelFilegetOriginalFilename();

String a=requestgetRealPath("u/cms/www/201509");

SaveFileFromInputStream(excelFilegetInputStream(),requestgetRealPath("u/cms/www/201509"),filename);//保存到服务器的路径

}

loginfo("<<<<<<action:{} Method:{} end>>>>>>","usermanager","excelImport" );

return "";

}

/

将MultipartFile转化为file并保存到服务器上的某地

/

public void SaveFileFromInputStream(InputStream stream,String path,String savefile) throws IOException

{      

FileOutputStream fs=new FileOutputStream( path + "/"+ savefile);

Systemoutprintln("------------"+path + "/"+ savefile);

byte[] buffer =new byte[10241024];

int bytesum = 0;

int byteread = 0;

while ((byteread=streamread(buffer))!=-1)

{

bytesum+=byteread;

fswrite(buffer,0,byteread);

fsflush();

}

fsclose();

streamclose();

}