概述
在网络通讯中，第一次主动发起通讯的程序被称作客户端(Client)程序，简称客户端，而在第一次通讯中等待连接的程序被称作服务器端(Server)程序，简称服务器。一旦通讯建立，则客户端和服务器端完全一样，没有本质的区别。
“请求-响应”模式：
1. Socket类：发送TCP消息。
2. ServerSocket类：创建服务器并监听Socket类的连接请求。
套接字是一种进程间的数据交换机制。这些进程既可以在同一机器上，也可以在通过网络连接的不同机器上。一旦建立套接字连接，数据即可在相同或不同的系统中双向或单向发送，直到其中一个端点关闭连接。套接字与主机地址和端口地址相关联。主机地址就是客户端或服务器程序所在的主机的IP地址。端口地址是指客户端或服务器程序使用的主机的通信端口。
在客户端和服务器中，分别创建独立的Socket，并通过Socket的属性，将两个Socket进行连接，这样，客户端和服务器通过套接字所建立的连接使用IO流进行通信。
TCP/IP套接字是最可靠的双向流协议，使用TCP/IP可以发送任意数量的数据。
TCP/IP通信连接的简单过程：
位于A计算机上的TCP/IP软件向B计算机发送包含端口号的消息，B计算机的TCP/IP软件接收该消息，并进行检查，查看是否有它知道的程序正在该端口上接收消息。如果有，他就将该消息交给这个程序。
要使程序有效地运行，就必须有一个客户端和一个服务器。
通过Socket的编程顺序：
1. 创建服务器ServerSocket，在创建时，定义ServerSocket的监听端口(在这个端口接收客户端发来的消息)。
2. ServerSocket调用accept()方法，阻塞式等待连接。
3. 创建客户端Socket，并设置服务器的IP及端口。
4. 客户端发出连接请求，建立连接。
5. 分别取得服务器和客户端Socket的InputStream和OutputStream。
6. 利用Socket和ServerSocket进行数据传输。
7. 关闭流及Socket。
-
单向通信Socket：
服务器：
import java.io.DataInputStream;
import java.net.*;
/*
创建服务器
1、指定端口 使用ServerSocket创建服务器
2、阻塞式等待连接 accept()
3、操作：输入输出流操作
4、释放资源
*/
public class Server {
public static void main(String[] args) throws Exception {
System.out.println("-----Server-----");
//1、指定端口 使用ServerSocket创建服务器
ServerSocket server = new ServerSocket(8888);
//2、阻塞式等待连接 accept()
Socket client = server.accept();
System.out.println("一个客户端建立了连接");
//3、操作：输入输出流操作
DataInputStream dis = new DataInputStream(client.getInputStream());
String str = dis.readUTF();
System.out.println("客户端传来了数据："+str);
//4、释放资源
server.close();
dis.close();
}
}客户端：
import java.io.DataOutputStream;
import java.net.*;
/*
创建客户端
1、建立连接：使用Socket创建客户端 + 服务器的地址和端口
2、操作：输入输出流操作
3、释放资源
*/
public class Client {
public static void main(String[] args) throws Exception {
System.out.println("-----Client-----");
//1、建立连接：使用Socket创建客户端 + 服务器的地址和端口
Socket client = new Socket("localhost",8888);
//2、操作：输入输出流操作
DataOutputStream dos = new DataOutputStream(client.getOutputStream());
String str = "I'm datas";
dos.writeUTF(str);
dos.flush();
//3、释放资源
dos.close();
client.close();
}
}-
双向通信Socket：
服务器：
import java.io.*;
import java.net.*;
/*
创建服务器 模拟多线程登陆
1、指定端口 使用ServerSocket创建服务器
2、阻塞式等待连接 accept()
3、操作：输入输出流操作
4、释放资源
*/
public class LoginServer {
public static void main(String[] args) throws Exception {
System.out.println("-----Server-----");
//1、指定端口 使用ServerSocket创建服务器
ServerSocket server = new ServerSocket(8888);
boolean flag = true;
while(flag) {
//2、阻塞式等待连接 accept()
Socket client = server.accept();
System.out.println("一个客户端建立了连接");
new Thread(new Log(client)).start();
}
server.close();
}
static class Log implements Runnable {
private Socket client;
private ObjectInputStream dis;
private ObjectOutputStream dos;
private Object object;
private User user;
@Override
public void run() {
// 3、操作：输入输出流操作
try {
deal();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.out.println("4");
}
// 4、释放资源
close();
}
public Log(Socket client) throws IOException {
this.client = client;
try {
dis = new ObjectInputStream(
new BufferedInputStream(this.client.getInputStream()));
dos = new ObjectOutputStream(
new BufferedOutputStream(this.client.getOutputStream()));
} catch (IOException e) {
e.printStackTrace();
System.out.println("3");
client.close();
}
}
private void deal() throws IOException, ClassNotFoundException {
object = dis.readObject();
if(object instanceof User)
user = (User) object;
System.out.println("用户名："+user.getName()+'t'+"密码："+user.getPwd());
try {
if(user.getName().equals("Kvno")&&user.getPwd().equals("eric")) {
dos.writeUTF("登陆成功");
}else {
dos.writeUTF("用户名或密码错误");
}
dos.flush();
} catch (IOException e) {
e.printStackTrace();
System.out.println("1");
}
}
private void close() {
try {
dis.close();
dos.close();
client.close();
} catch (IOException e) {
e.printStackTrace();
System.out.println("2");
}
}
}
}客户端：
import java.io.*;
import java.net.Socket;
/*
创建客户端 模拟登陆
1、建立连接：使用Socket创建客户端 + 服务器的地址和端口
2、操作：输入输出流操作
3、释放资源
*/
public class LoginClient {
public static void main(String[] args) throws Exception {
System.out.println("-----Client-----");
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
User user = new User();
System.out.println("请输入用户名：");
user.setName(br.readLine());
System.out.println("请输入密码");
user.setPwd(br.readLine());
//1、建立连接：使用Socket创建客户端 + 服务器的地址和端口
Socket client = new Socket("localhost",8888);
//2、操作：输入输出流操作
ObjectOutputStream dos = new ObjectOutputStream(
new BufferedOutputStream(client.getOutputStream()));
dos.writeObject(user);
dos.flush();
ObjectInputStream dis = new ObjectInputStream(
new BufferedInputStream(client.getInputStream()));
String str = dis.readUTF();
System.out.println(str);
//3、释放资源
dis.close();
dos.close();
client.close();
}
}
class User implements Serializable {
private String name;
private String pwd;
public User() {
}
public User(String name, String pwd) {
this.name = name;
this.pwd = pwd;
}
public User setName(String name) {
this.name = name;
return this;
}
public User setPwd(String pwd) {
this.pwd = pwd;
return this;
}
public String getName() {
return name;
}
public String getPwd() {
return pwd;
}
}最后
以上就是畅快电源为你收集整理的Java TCP协议下Socket编程和通讯的简单实现的全部内容，希望文章能够帮你解决Java TCP协议下Socket编程和通讯的简单实现所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复