JavaSE网络编程TCP协议单线程聊天室

学习时间

2021-04-07

学习内容

注意&＃xff1a;本文在同一台机器上演示

测试类1&＃xff1a;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class Test1 {public static void main(String[] args) throws IOException {TCPClient();}public static void TCPClient() throws IOException {Socket socket &＃61; new Socket("192.168.1.xxx", 2222);//创建套接字并绑定端口OutputStream outputStream &＃61; socket.getOutputStream();//获取输出流Scanner scanner &＃61; new Scanner(System.in);System.out.println("请输入要发送的内容&＃xff1a;");String s &＃61; scanner.nextLine();//要输入的内容outputStream.write(s.getBytes());//写入数据socket.close();//释放资源TCPServerClient();}public static void TCPServerClient() throws IOException {ServerSocket serverSocket &＃61; new ServerSocket(3333);//创建服务器端的Socket&＃xff0c;并暴露端口号Socket accept &＃61; serverSocket.accept();//侦听连接InputStream inputStream &＃61; accept.getInputStream();//获取输入流byte[] bytes &＃61; new byte[1024];int read &＃61; inputStream.read(bytes);String s &＃61; new String(bytes, 0, read);//解析连接String ip &＃61; accept.getInetAddress().getHostAddress();System.out.println(ip &＃43; "发来信息&＃xff1a;" &＃43; s);serverSocket.close();//释放资源TCPClient();}
}


测试类2&＃xff1a;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class Test2 {public static void main(String[] args) throws IOException {TCPServerClient();}public static void TCPClient() throws IOException {Socket socket &＃61; new Socket("192.168.1.xxx", 3333);//创建套接字并绑定端口OutputStream outputStream &＃61; socket.getOutputStream();//获取输出流Scanner scanner &＃61; new Scanner(System.in);System.out.println("请输入要发送的内容&＃xff1a;");String s &＃61; scanner.nextLine();//要输入的内容outputStream.write(s.getBytes());//写入数据socket.close();//释放资源TCPServerClient();}public static void TCPServerClient() throws IOException {ServerSocket serverSocket &＃61; new ServerSocket(2222);//创建服务器端的Socket&＃xff0c;并暴露端口号Socket accept &＃61; serverSocket.accept();//侦听连接InputStream inputStream &＃61; accept.getInputStream();//获取输入流byte[] bytes &＃61; new byte[1024];int read &＃61; inputStream.read(bytes);String s &＃61; new String(bytes, 0, read);//解析连接String ip &＃61; accept.getInetAddress().getHostAddress();System.out.println(ip &＃43; "发来信息&＃xff1a;" &＃43; s);serverSocket.close();//释放资源TCPClient();}
}


声明&＃xff1a;

关于转载&＃xff1a;

允许非商业用途转载&＃xff0c;注明出处和链接即可。