对于Java中Socket类的理解

举报
小小张自由--张有博 发表于 2021/11/30 22:53:08 2021/11/30
【摘要】 在Java中,提供了两个类用于实现TCP通信程序:          1. 客户端: java.net.Socket 类表示。创建 Socket 对象,向服务端发出连接请求,服务端响应请求,两者...
Java中,提供了两个类用于实现TCP通信程序:
         1. 客户端: java.net.Socket 类表示。创建 Socket 对象,向服务端发出连接请求,服务端响应请求,两者建
立连接开始通信。
        2. 服务端: java.net.ServerSocket 类表示。创建 ServerSocket 对象,相当于开启一个服务,并等待客户端
的连接。 

Socket 类的一些方法:
public InputStream getInputStream() 返回此套接字的输入流。
public OutputStream getOutputStream() 返回此套接字的输出流。
public void close() :关闭此套接字。
public void shutdownOutput() 禁用此套接字的输出流。

ServerSocker类的一些方法:
public Socket accept() :侦听并接受连接,返回一个新的 Socket 对象,用于和客户端实现通信。该方法
会一直阻塞直到建立连接。 

简单的Java代码的小例子
服务端实现: 
 public class ServerTCP {
public static void main ( String [] args ) throws IOException {
System . out . println ( " 服务端启动 , 等待连接 .... " );
// 1. 创建 ServerSocket 对象,绑定端口,开始等待连接
ServerSocket ss = new ServerSocket ( 6666 );
// 2. 接收连接 accept 方法 , 返回 socket 对象 .
Socket server = ss . accept ();
// 3. 通过 socket 获取输入流
InputStream is = server . getInputStream ();
// 4. 一次性读取数据
// 4.1 创建字节数组
byte [] b = new byte [ 1024 ];
// 4.2 据读取到字节数组中 .
int len = is . read ( b )
// 4.3 解析数组 , 打印字符串信息
String msg = new String ( b , 0 , len );
System . out . println ( msg );
//5. 关闭资源 .
is . close ();
server . close ();
}
}

客户端实现:
 public class ClientTCP {
public static void main ( String [] args ) throws Exception {
System . out . println ( " 客户端 发送数据 " );
// 1. 创建 Socket ( ip , port ) , 确定连接到哪里 .
Socket client = new Socket ( "localhost" , 6666 );
// 2. 获取流对象 . 输出流
OutputStream os = client . getOutputStream ();
// 3. 写出数据 .
os . write ( " 你好么 ? tcp , 我来了 " . getBytes ());
// 4. 关闭资源 .
os . close ();
client . close ();
}
}
 

第二个小例子
服务端代码
 public class FileUpload_Server {
public static void main ( String [] args ) throws IOException {
System . out . println ( " 服务器 启动 ..... " );
// 1. 创建服务端 ServerSocket
ServerSocket serverSocket = new ServerSocket ( 6666 );
// 2. 建立连接
Socket accept = serverSocket . accept ();
// 3. 创建流对象
// 3.1 获取输入流 , 读取文件数据
BufferedInputStream bis = new BufferedInputStream ( accept . getInputStream ());
// 3.2 创建输出流 , 保存到本地 .
BufferedOutputStream bos = new BufferedOutputStream ( new FileOutputStream ( "copy.jpg" ));
// 4. 读写数据
byte [] b = new byte [ 1024 * 8 ];
int len ;
while (( len = bis . read ( b )) != 1 ) {
bos . write ( b , 0 , len );
}
//5. 关闭 资源
bos . close ();
bis . close ();
accept . close ();
System . out . println ( " 文件上传已保存 " );
}
}
客户端代码
 public class FileUPload_Client {
public static void main ( String [] args ) throws IOException {
// 1. 创建流对象
// 1.1 创建输入流 , 读取本地文件
BufferedInputStream bis = new BufferedInputStream ( new FileInputStream ( "test.jpg" ));
// 1.2 创建输出流 , 写到服务端
Socket socket = new Socket ( "localhost" , 6666 );
BufferedOutputStream bos = new BufferedOutputStream ( socket . getOutputStream ());
//2. 写出数据 .
byte [] b = new byte [ 1024 * 8 ];
int len ;
while (( len = bis . read ( b )) != 1 ) {
bos . write ( b , 0 , len );
bos . flush ();
}
System . out . println ( " 文件发送完毕 " );
// 3. 释放资源
bos . close ();
socket . close ();
bis . close ()
System . out . println ( " 文件上传完毕 " );
}
}

网络传输三要素;协议,IP,端口号

今天是学习了网络传输,所以简单记录一下。


文章来源: blog.csdn.net,作者:小小张自由—>张有博,版权归原作者所有,如需转载,请联系作者。

原文链接:blog.csdn.net/promsing/article/details/121633181

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

举报
请填写举报理由
0/200