Java网络编程（二）TCP的理解和学习

一、TCP实现发送消息

客户端代码&＃xff1a;

/***客户端*/
public class TcpClientDemo {public static void main(String[] args) {Socket socket &＃61; null;OutputStream os &＃61; null;//首先得知道服务端的地址和端口号//这里记得异常不要抛出去&＃xff0c;捕获起来方便处理try {//服务器地址&＃xff0c;用InetAddress来接收InetAddress inetAddress &＃61; InetAddress.getByName("127.0.0.1");//端口号int port &＃61; 7777;//创建一个套接字链接&＃xff08;socket&＃xff09;socket &＃61; new Socket(inetAddress,port);//发送消息的时候要以io流的方式来发送&＃xff0c;发送消息肯定是输出流啦os &＃61; socket.getOutputStream();//创建Scanner对象&＃xff0c;接受从控制台输入Scanner input&＃61;new Scanner(System.in);//接受String类型String messge &＃61; input.next();//发送消息os.write(messge.getBytes(StandardCharsets.UTF_8));} catch (Exception e) {e.printStackTrace();}finally {//这里是重点&＃xff01;&＃xff01;&＃xff01;千万不要忘记关闭链接和流if (socket !&＃61; null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}if (os !&＃61; null){try {os.close();} catch (IOException e) {e.printStackTrace();}}}}
}


服务端代码&＃xff1a;

/***服务端*/
public class TcpServerDemo {public static void main(String[] args) {ServerSocket serverSocket &＃61; null;Socket socket &＃61; null;InputStream is &＃61; null;ByteArrayOutputStream byteArrayOutputStream &＃61; null;//首先建立一个服务端try {//1,ip地址serverSocket &＃61; new ServerSocket(7777);while (true) {//2、等待客户端连接socket &＃61; serverSocket.accept();//3.消息过来了我们得读取客户消息&＃xff0c;接受消息肯定是输入流啦is &＃61; socket.getInputStream();//这个时候消息已经接受到了&＃xff0c;我们怎么样读取呢&＃xff1f;//管道输出流&＃xff0c;ByteArrayOutputStreambyteArrayOutputStream &＃61; new ByteArrayOutputStream();byte[] buffer &＃61; new byte[1024];//字节数组来接受int length;//长度while ((length &＃61; is.read(buffer)) !&＃61; -1) {byteArrayOutputStream.write(buffer, 0, length);}System.out.println(byteArrayOutputStream.toString());}} catch (Exception e) {e.printStackTrace();}finally {//同样的&＃xff0c;得关闭流if (serverSocket !&＃61; null){try {serverSocket.close();} catch (IOException e) {e.printStackTrace();}}if (socket !&＃61; null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}if (is !&＃61; null){try {is.close();} catch (IOException e) {e.printStackTrace();}}if (byteArrayOutputStream !&＃61; null){try {byteArrayOutputStream.close();} catch (IOException e) {e.printStackTrace();}}}}
}


客户端执行结果&＃xff1a;

服务端接受结果&＃xff1a;

总结&＃xff1a; 看代码说话&＃xff01;

• 客户端

  • 连接服务器Socket
  • 发送消息

• 服务端

  • 建立服务的端口ServerScoket
  • 等待用户的连接accept
  • 接收用户的消息

二、TCP实现文件上传

• 客户端代码

/*** 客户端*/
public class TcpUplodeFileClient {public static void main(String[] args) throws Exception{//1、创建一个Socket连接Socket socket &＃61; new Socket(InetAddress.getByName("127.0.0.1"), 7777);//2、创建一个输出流OutputStream os &＃61; socket.getOutputStream();//3、读取文件FileInputStream fis &＃61; new FileInputStream(new File("C:\\Users\\大大丁大大\\Desktop\\有用文件\\test.jpg"));//4、写出文件byte[] buffer &＃61; new byte[1024];int len;while ((len &＃61; fis.read(buffer)) !&＃61; -1) {os.write(buffer, 0, len);}//通知服务器&＃xff0c;我已经结束了socket.shutdownOutput(); //我已经传输完了&＃xff01;//确定服务器接收完毕&＃xff0c;才能够断开连接InputStream inputStream &＃61; socket.getInputStream();//String byte[]ByteArrayOutputStream baos &＃61; new ByteArrayOutputStream();byte[] buffer2 &＃61; new byte[1024];int len2;while ((len2 &＃61; inputStream.read(buffer2)) !&＃61; -1) {baos.write(buffer2, 0, len2);}System.out.println(baos.toString());//5、关闭资源baos.close();inputStream.close();fis.close();os.close();socket.close();}
}


• 服务端代码

/*** 服务端*/
public class TcpUplodeFileServer {public static void main(String[] args) throws Exception{//创建服务ServerSocket serverSocket &＃61; new ServerSocket(7777);//监听连接Socket socket &＃61; serverSocket.accept();//获取输入流InputStream is &＃61; socket.getInputStream();//文件输出FileOutputStream fos &＃61; new FileOutputStream(new File("test.jpg"));byte[] buffer &＃61; new byte[1024];int len;while ((len&＃61;is.read(buffer)) !&＃61; -1){fos.write(buffer,0,len);}//通知客户端接收完毕OutputStream os &＃61; socket.getOutputStream();os.write("接收完成".getBytes());//千万记得关闭所有资源serverSocket.close();socket.close();is.close();os.close();}
}


• 客户端执行结果&＃xff1a;
  

• 服务端执行结果
  
  关于TCP的学习就先到此为止啦~

Java网络编程扩展&＃xff1a;Java网络编程学习汇总

路漫漫其修远兮&＃xff0c;吾必将上下求索~
如果你认为i博主写的不错&＃xff01;写作不易&＃xff0c;请点赞、关注、评论给博主一个鼓励吧_{**转载请注明出处哦**}