如何实现socket网络编程的多线程
本文主要介绍了如何实现socket网络编程的多线程，分享给大家
TCP、UDP、IP地址的基本介绍：
- TCP
- UDP：
- IP地址：
下面的例子是基于TCP协议进行的。
publicclassClient{
publicstaticvoidmain(String[]args)throwsException{
//打开一个套接字，准备发送请求
Socketsocket=newSocket("localhost",9996);//得先建立连接，就是所谓的TCP是建立可靠的连接
System.out.println("尊敬的VIP客户，请求数据小分队已准备好，请输入您的请求：");
//向服务端发送带着客户端请求的数据，这个请求数据是从键盘读入的，发送给服务端是以PrintWriter的形式包装
PrintWriterout=newPrintWriter(socket.getOutputStream(),true);
//输入流getInputStream()，单独开一个线程在Receive类中完成接收服务器发来的数据
Threadt=newThread(newReceive(socket));
t.start();
Scannerscanner=newScanner(System.in);//键盘输入
while(scanner.hasNextLine()){
out.println(scanner.nextLine());//将从键盘输入的数据发送出去
}
}
}
publicclassReceiveimplementsRunnable{
privateSocketsocket;
publicReceive(Socketsocket){
this.socket=socket;
}
@Override
publicvoidrun(){
try{
Scannerscanner=newScanner(socket.getInputStream());//接收数据
Stringstr=null;
while(true){
str=scanner.nextLine();
System.out.println("服务器说："+str);//打印接收的数据
}
}catch(IOExceptione){
e.printStackTrace();
}
}
}
publicclassServer{
publicstaticvoidmain(String[]args)throwsException{
ServerSocketserver=newServerSocket(9996);//在端口9996开一个服务，监听客户端发来的请求，准备接收客户端发来的请求数据
System.out.println("服务端准备完毕，随时待命接收请求！");
Socketsocket=server.accept();//只有当有客户端请求并连接时，才回返回一个Socket对象，这个对象就是带着客户端请求的那个Socket对象
//创建一个PrintWriter的实例对象out来完成服务端向客户端的输出数据的任务，
PrintWriterout=newPrintWriter(socket.getOutputStream(),true);
//单独开一个线程接收从客户端过来的请求，在Receive1类中完成数据的接收
Threadt=newThread(newReceive1(socket));
t.start();
/*一定要理解Socket是一个用于机器之间通信的类*/
//发送数据给客户端
Scannerscanner=newScanner(System.in);//键盘输入服务端要发给客户端的数据
while(scanner.hasNextLine()){
out.println(scanner.nextLine());//将键盘输入的服务端要发给客户端的数据封装在PrintWriter类的对象中
}
}
}
publicclassReceive1implementsRunnable{
privateSocketsocket;
publicReceive1(Socketsocket){
this.socket=socket;//在服务端接收客户端发来的数据需要调用Receive1()这个方法，就会得到一个Socket对象，这个对象就是携带着客户端请求的socket
}
@Override
publicvoidrun(){
try{
Scannerscanner=newScanner(socket.getInputStream());//获得客户端从键盘接收的输入流
Stringstr=null;
while(true){
str=scanner.nextLine();
System.out.println("客户端发来的数据："+str);
}
}catch(IOExceptione){
e.printStackTrace();
}//接收数据
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票