TCP单向通讯

TCP单向通讯

在网络通讯中,第一次主动发起通讯的程序被称作客户端(Client)程序,简称客户端,而在第一次通讯中等待连接的程序被称作服务器端(Server)程序,简称服务器。一旦通讯建立,则客户端和服务器端完全一样,没有本质的区别。

请求-响应模式:

  1. Socket类:发送TCP消息。
  2. ServerSocket类:创建服务器。
    套接字是一种进程间的数据交换机制。这些进程既可以在同一机器上,也可以在通过网络连接的不同机器上。换句话说,套接字起到通信端点的作用。单个套接字是一个端点,而一对套接字则构成一个双向通信信道,使非关联进程可以在本地或通过网络进行数据交换。一旦建立套接字连接,数据即可在相同或不同的系统中双向或单向发送,直到其中一个端点关闭连接。套接字与主机地址和端口地址相关联。主机地址就是客户端或服务器程序所在的主机的IP地址。端口地址是指客户端或服务器程序使用的主机的通信端口。
    在客户端和服务器中,分别创建独立的Socket,并通过Socket的属性,将两个Socket进行连接,这样,客户端和服务器通过套接字所建立的连接使用输入输出流进行通信。
    TCP/IP套接字是最可靠的双向流协议,使用TCP/IP可以发送任意数量的数据。
    实际上,套接字只是计算机上已编号的端口。如果发送方和接收方计算机确定好端口,他们就可以通信了。

    TCP/IP通信连接的简单过程:

    位于A计算机上的TCP/IP软件向B计算机发送包含端口号的消息,B计算机的TCP/IP软件接收该消息,并进行检查,查看是否有它知道的程序正在该端口上接收消息。如果有,他就将该消息交给这个程序。
    要使程序有效地运行,就必须有一个客户端和一个服务器。

    通过Socket的编程顺序:

  3. 创建服务器ServerSocket,在创建时,定义ServerSocket的监听端口(在这个端口接收客户端发来的消息)。
  4. ServerSocket调用accept()方法,使之处于阻塞状态。
  5. 创建客户端Socket,并设置服务器的IP及端口。
  6. 客户端发出连接请求,建立连接。
  7. 分别取得服务器和客户端Socket的InputStream和OutputStream。
  8. 利用Socket和ServerSocket进行数据传输。
  9. 关闭流及Socket。

    单项通讯服务器:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    /**
    * 服务器:
    * 1.指定端口,使用ServerSocket创建服务器
    * 2.阻塞式等待链接 accept 返回一个Socket
    * 3.操作:输入输出流
    * 4.释放资源
    */
    public class TCP_Server {
    public static void main(String[] args) throws Exception {
    System.out.println("-------Server-------");
    //1.指定端口,使用ServerSocket创建服务器
    ServerSocket SS=new ServerSocket(6666);
    // 2.阻塞式等待链接 accept
    Socket Client=SS.accept();
    System.out.println("客户端连接已建立");
    // 3.操作:输入输出流
    DataInputStream dis=new DataInputStream(Client.getInputStream());
    String st=dis.readUTF();
    System.out.println(st);
    // 4.释放资源
    dis.close();
    Client.close();
    }//先启动服务器在启动客户端
    }

结果:

——-Server——-

单项通讯客户端:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
/**
* 客户端:
* 1.建立连接:使用Socket创建客户端:服务器地址和端口
* 2.操作:输入输出流
* 3.释放资源
*/
public class TCP_Client {
public static void main(String[] args) throws Exception {
System.out.println("-------Client-------");
//1.建立连接:使用Socket创建客户端:服务器地址和端口
Socket S=new Socket("localhost",6666);
// 3.操作:输入输出流
DataOutputStream out=new DataOutputStream(S.getOutputStream());
String st="你好";
out.writeUTF(st);
out.flush();
// 4.释放资源
out.close();
S.close();
}
}

结果:

——-Server——-
客户端连接已建立
你好

原创技术分享,您的支持将鼓励我继续创作
0%