怎么用Java实现使用TCP协议实现文件传输程序

服务端监听：ServerSocket server=new ServerSocket(port)//port：绑定的端口号

Socket client=server.accept()//监听端口，一旦取得连接则获得客户端的socket连接对象client

客户端： Socket s=new Socket(ip,port)//要连接的服务器的ip以及端口号

如果正常连接上之后，socket的对象可以获得InputStream和OutputStreame，然后就可以进行通信了

完成通信之后，执行socket对象的close（）方法关闭连接，完成一次完整的socket连接

//以前写的一个文件传输的小程序，有客户端和服务器端两部分，服务器可//以一直运行，客户端传输完一个后退出，当然你也可以根据你的需要改。

//服务器端可以支持多个客户端同时上传，用到了多线程

/**

* 文件传输，客户端

* @aurth anyx

*/

//package per.anyx.ftp

import java.net.*

import java.io.*

public class FtpClient{

public static void main(String[] args){

if(args.length != 3){

System.out.println("Usage: FtpClient host_add host_port src_file")

System.exit(0)

}

File file = new File(args[2])

if(!file.exists() || !file.isFile()){

System.out.println("File \"" + args[2] + "\" does not exist or is not a normal file.")

System.exit(0)

}

Socket s = null

FileInputStream in = null

OutputStream out = null

try{

s = new Socket(args[0], Integer.parseInt(args[1]))

in = new FileInputStream(file)

out = s.getOutputStream()

byte[] buffer = new byte[1024*8]

int len = -1

System.out.println("File tansfer statr...")

while((len=in.read(buffer)) != -1){

out.write(buffer, 0, len)

}

System.out.println("File tansfer complete...")

}catch(Exception e){

System.out.println("Error: " + e.getMessage())

System.exit(1)

}finally{

try{

if(in != null) in.close()

if(out != null) out.close()

if(s != null) s.close()

}catch(Exception e){}

}

}

}

/**

* 文件传输，服务器端

* @aurth anyx

*/

//package per.anyx.ftp

import java.net.*

import java.io.*

public class FtpServer{

public static void main(String[] args){

if(args.length != 1){

System.out.println("Usage: FtpServer server_port")

System.exit(0)

}

ServerSocket ss = null

try{

ss = new ServerSocket(Integer.parseInt(args[0]))

System.out.println("FtpServer start on port ..." + args[0])

while(true){

Socket s = ss.accept()

new FtpThread(s).start()

System.out.println(s.getInetAddress().getHostAddress() + " connected.")

}

}catch(Exception e){

System.out.println("Error: " + e.getMessage())

}finally{

try{

if(ss != null) ss.close()

}catch(Exception e){}

}

}

}

class FtpThread extends Thread{

Socket s

long fileName = 0

public FtpThread(Socket s){

this.s = s

}

public void run(){

FileOutputStream out = null

InputStream in = null

File file = null

do{

file = new File("" + (fileName++))

}while(file.exists())

try{

out = new FileOutputStream(file)

in = s.getInputStream()

byte[] buffer = new byte[1024*8]

int len = -1

while((len=in.read(buffer)) != -1){

out.write(buffer, 0, len)

}

}catch(Exception e){

System.out.println("Error: " + e.getMessage())

}finally{

try{

if(in != null) in.close()

if(out != null) out.close()

if(s != null) s.close()

System.out.println(s.getInetAddress().getHostAddress() + " connect closed..")

}catch(Exception e){}

}

}

}

如果文件太大不能一次全读入！！

JAVA里关于文件读写的有几十个类，不知道你想要如何实现，

以下是读文件的一个程序，如果有问题，发信息给我吧........

import java.io.*

import java.nio.*

import java.nio.channels.FileChannel

public class javaTest {

public static void main(String[] args) {

String file1=System.getProperty("user.dir")+"/1.txt"//文件，自己修改

FileInputStream myFile = null

try {

myFile = new FileInputStream(file1)//

} catch(FileNotFoundException e) {

e.printStackTrace(System.err)

System.exit(1)

}

FileChannel myChannel = myFile.getChannel()

//这里定义缓冲区大小，每次读入字节数

ByteBuffer mybuf = ByteBuffer.allocate(1024)

try {

while(myChannel.read(mybuf) != -1) {

byte[] mybytes = mybuf.array()//读入的文件转为字节数组

mybuf.clear()

/**

* 在这里进行比较

* 可以通过字节对比

* 也可以把字节转成字符串再对比

*

*/

}

myFile.close()

}catch(IOException e) {

e.printStackTrace(System.err)

System.exit(1)

}

---