Java 网络编程 之 TCP协议

TCP协议 (服务器端程先启动，等待客户端连接)

TCP协议是面向连接的通信协议，即在传输数据前先在发送端和接收端建立逻辑连接，然后再传输数据

保证传输数据的全性安，文件数据不易丢失

在JDK中提供了两个类用于实现TCP程序，一个是ServerSocket类，用于表示服务器端，一个是Socket类，用于表示客户端。

首先创建代表服务器端的ServerSocket对象，并等待客户端的连接，

然后创建代表客户端的Socket对象向服务器端发出连接请求，服务器端响应请求，客户端再次向服务器端发送确认信息，确认连接

 

 

public class TCPClient {//客户端

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

Socket socket=new Socket("127.0.0.1",8888);//客户端对象 建连接

//Socket socket=new Socket(inet,8888);//(地址对象,端口号)

OutputStream out=socket.getOutputStream();//客户端的 输出流

//写数据

Scanner sc=new Scanner(System.in);

String str=sc.nextLine();

out.write(str.getBytes());

//明确数据源

FileInputStream fis=new FileInputStream("F:\java\1.jpg");

//BufferedInputStream bis = new BufferedInputStream(fis);

//写数据

int len=0;

byte[] bytes=new byte[1024];

while((len=fis.read(bytes))!=-1){ //bis.read(bytes)

out.write(bytes,0,len); //写入 socket的 输出流

}

socket.shutdownOutput();//socket对象 的输出流 写入结束符

//接收服务器端的响应

InputStream in=socket.getInputStream();

byte[] bytes=new byte[1024];

int len=in.read(bytes);

System.out.println(new String(bytes,0,len));

socket.close();//释放内存

fis.close();//关闭数据源

}

}

int port=socket.getPort();//获取端口号

InetAddress inet=getLocalAddress();//获取本地地址对象

 

public class TCPServer {//服务器端

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

ServerSocket server=new ServerSocket(8888);//服务端对象(端口号)

Socket socket=server.accept();//创建连接  获取客户端对象

InputStream in=socket.getInputStream();//客户端的 输入流  不关

//读出数据

byte[] bytes=new byte[1024];

int len=in.read(bytes);

System.out.println(new String(bytes,0,len));

 

//明确目的地

File file=new File("F:\aaa");

if(!file.exists()){ file.mkdirs(); }//文件夹不存在  创建

String fn="oracle"+System.currentTimeMillis()//域名+毫秒值

　　　　　　　　　　+new Random().nextInt(999999)+".jpg";//+六位随机数+后缀

FileOutputStream fos=new FileOutputStream(file+File.separator+fn);

//BufferedOutputStream bos = new BufferedOutputStream(fos);

//开始复制

byte[] bytes=new byte[1024];

int len=0;

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

fos.write(bytes,0,len); //bos.write(bytes,0,len);

}

//发送给客户端响应

OutputStream out=socket.getOutputStream();//输出流

 

Scanner sc=new Scanner(System.in);

String str=sc.nextLine();

out.write(str.getBytes());//写数据 

out.write("上传成功".getBytes());//写数据

 

server.close();//释放资源

fos.close(); //bos.close();

}

}

InetAddress address = socket.getInetAddress();//获取地址对象

String ip=address.getHostAddress(); //ip地址

String name=address.getHostName(); //主机名

System.out.println("来自IP:"+ip+"主机名:"+name);

 

多线程(多人同时访问服务器)
public class Upload implements Runnable{
    private Socket socket;
    public Upload(){}
    public Upload(Socket socket){this.socket=socket;}
    public void run() {
        FileOutputStream fos=null;
        try{
        InputStream in=socket.getInputStream();//客户端 输入流
        //明确目的地
        File file=new File("F:\aaa");
        if(!file.exists()){ file.mkdirs(); }//文件夹不存在  创建
        String filename="oracle"+System.currentTimeMillis()//域名+毫秒值
                    +new Random().nextInt(999999)+".jpg";//+六位随机数+后缀
        fos=new FileOutputStream(file+File.separator+filename);
        //开始复制
        byte[] bytes=new byte[1024];
        int len=0;
        while((len=in.read(bytes))!=-1){fos.write(bytes,0,len);}
        //发送给客户端响应
        OutputStream out=socket.getOutputStream();//输出流
        out.write("上传成功".getBytes());//写数据
        }catch(IOException ex){ex.printStackTrace();}
　　　　　finally{ if(fos!=null){fos.close();//点try...catch} }
    }
}       

public class TCPThreadServer {//服务器端 多线程  （客户端不变）
    public static void main(String[] args) throws IOException {
        ServerSocket server=new ServerSocket(8888);//服务端对象(端口号)
        while(true){
            Socket socket=server.accept();//创建连接  获取客户端对象 
            new Thread(new Upload(socket)).start();//创建并开启线程
        }
    }
}