socket传输案例

ゝ一世哀愁。 2022-11-28 13:29 144阅读 0赞

**目录**

字符传输案例

服务端

客户端

写入文本文件案例

服务端

客户端

图片传输案例

服务端

客户端

--------------------

# 字符传输案例 #

### 服务端 ###

package com.ctx.tcp2;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * 服务端接受消息
     * 
     * @author ashen
     *
     */
    public class TCPService {
    	public static void main(String[] args) {
    		new TCPService().service();
    	}
    
    	public void service() {
    		ServerSocket ss = null;
    		Socket socket = null;
    		InputStream is = null;
    		ByteArrayOutputStream baos = null;
    		try {
    			ss = new ServerSocket(4399);
    			socket = ss.accept();
    			is = socket.getInputStream();
    
    			baos = new ByteArrayOutputStream();
    			byte[] buffer = new byte[1];
    			int len;
    			while ((len = is.read(buffer)) != -1) {
    				baos.write(buffer, 0, len);
    			}
    			System.out.println(baos.toString());
    		} catch (Exception e) {
    		} finally {
    			if (baos != null) {
    				try {
    					baos.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (is != null) {
    				try {
    					is.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (socket != null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (ss != null) {
    				try {
    					ss.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    
    		}
    
    	}
    }

### 客户端 ###

package com.ctx.tcp2;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * 客户端发送消息
     * 
     * @author ashen
     *
     */
    public class TCPClient {
    	public static void main(String[] args) {
    		new TCPClient().client();
    	}
    
    	public void client() {
    		Socket socket = null;
    		OutputStream os = null;
    		try {
    			InetAddress inetAddress = InetAddress.getByName("192.168.0.107");
    			socket = new Socket(inetAddress, 4399);
    			os = socket.getOutputStream();
    			os.write("始于颜值，终于才华。".getBytes());
    		} catch (Exception e) {
    		} finally {
    			if (os != null) {
    				try {
    					os.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (socket != null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    
    		}
    
    	}
    
    }

# 写入文本文件案例 #

### 服务端 ###

package com.ctx.tcp;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * 服务端接收消息并保存成txt文件
     * 
     * @author ashen
     *
     */
    public class TCPService {
    	public static void main(String[] args) {
    		new TCPService().service();
    	}
    
    	public void service() {
    		ServerSocket ss = null;
    		FileOutputStream fos = null;
    		InputStream is = null;
    		Socket socket = null;
    		try {
    			ss = new ServerSocket(4399);
    			socket = ss.accept();
    			is = socket.getInputStream();
    			fos = new FileOutputStream(new File("D:/images/a.txt"));
    			byte[] buffer = new byte[50000];
    			int len = 0;
    			while ((len = is.read(buffer)) != -1) {
    				fos.write(buffer, 0, len);
    			}
    
    			OutputStream os = socket.getOutputStream();
    			os.write("服务端接受完毕。".getBytes());
    		} catch (Exception e) {
    		} finally {
    			if (fos != null) {
    				try {
    					fos.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (is != null) {
    				try {
    					is.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (socket != null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (ss != null) {
    				try {
    					ss.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    
    		}
    
    	}
    }

### 客户端 ###

package com.ctx.tcp;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * 客户端发送消息
     * 
     * @author ashen
     *
     */
    public class TCPClient {
    	public static void main(String[] args) {
    		new TCPClient().client();
    	}
    
    	public void client() {
    		Socket socket = null;
    		OutputStream os = null;
    		try {
    			InetAddress inetAddress = InetAddress.getByName("192.168.0.107");
    			socket = new Socket(inetAddress, 4399);
    			os = socket.getOutputStream();
    			os.write("始于颜值，终于才华。".getBytes());
    
    		} catch (Exception e) {
    
    		} finally {
    			if(os!=null) {
    				try {
    					os.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if(socket!=null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    
    	}
    
    }

# 图片传输案例 #

### 服务端 ###

package com.ctx.tcp3;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * 服务端接收图片
     * 
     * @author ashen
     *
     */
    public class TCPService {
    	public static void main(String[] args) {
    		new TCPService().service();
    	}
    	public void service() {
    		ServerSocket ss = null;
    		Socket socket = null;
    		InputStream is = null;
    		FileOutputStream fos = null;
    		OutputStream os = null;
    		try {
    			ss = new ServerSocket(4399);
    			socket = ss.accept();
    			is = socket.getInputStream();
    			fos = new FileOutputStream(new File("D:/images/a.jpg"));
    			byte[] buffer = new byte[50000];
    			int len = 0;
    			while ((len = is.read(buffer)) != -1) {
    				fos.write(buffer, 0, len);
    			}
    			os = socket.getOutputStream();
    			os.write("服务端接受完毕。".getBytes());
    		} catch (Exception e) {
    		} finally {
    			if (fos != null) {
    				try {
    					fos.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (is != null) {
    				try {
    					is.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (socket != null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (ss != null) {
    				try {
    					ss.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (os != null) {
    				try {
    					os.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    
    		}
    
    	}
    }

### 客户端 ###

package com.ctx.tcp3;
    
    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * 客户端发送照片给服务器
     * 
     * @author ashen
     *
     */
    public class TCPClient {
    	public static void main(String[] args)  {
    		new TCPClient().client();
    	}
    
    	@SuppressWarnings("resource")
    	public void client() {
    		Socket socket = null;
    		OutputStream os = null;
    		FileInputStream fis = null;
    		try {
    
    			InetAddress inetAddress = InetAddress.getByName("127.0.0.1");
    			socket = new Socket(inetAddress, 4399);
    			os = socket.getOutputStream();
    			File file = new File("D:/images/llj.jpg");
    			fis = new FileInputStream(file);
    
    			byte[] buffer = new byte[50024];
    			int len;
    			while ((len = fis.read(buffer)) != -1) {
    				os.write(buffer, 0, len);
    			}
    			socket.shutdownOutput();
    
    			InputStream is = socket.getInputStream();
    			byte[] b = new byte[3024];
    			int length = is.read(b);
    			String msg = new String(b, 0, length);
    			System.out.println(msg);
    		} catch (Exception e) {
    		} finally {
    			if (fis != null) {
    				try {
    					fis.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (os != null) {
    				try {
    					os.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (socket != null) {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    
    		}
    
    	}
    
    }