Socket通信类行
image
Socket通信步骤：
1.建立服务端ServerSocket和客户端Socket
2.打开连接到Socket的输出输入流
3.按照协议进行读写操作
4.关闭相对应的资源
类 ServerSocket 对应的一些方法
image.png
image.png
类 Socket对应的方法
image.png
image.png
image.png
image.png
代码实现
package Day13_1;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 客户端和服务器端都可以随意的发送文件
* 从终端输入
*
* 客户端：
* 接收终端的输入 将终端的输入发送给服务器端
* 接收服务器端发送来的数据
* 服务器端：
* 接收终端的输入 将终端的输入发送给客户端
* 接收客户端发送来的数据
*
* 对聊
*
* 客户端：
* 主线程： 接收终端的输入 将终端的输入发送给服务器端
* 子线程： 接收服务器端发送来的数据
* 服务器端：
* 主线程： 接收终端的输入 将终端的输入发送给客户端
* 子线程： 接收客户端发送来的数据
*
*/
public class MYcass
{
}
class Client
{
public static void main(String[] args) throws IOException {
Socket socket=new Socket("10.129.32.34",10000);
//用一个子线程处理服务器端的数据
new Thread(new ClientThread(socket)).start();
BufferedReader keyin=new BufferedReader(new InputStreamReader(System.in));
PrintStream ps=new PrintStream(socket.getOutputStream());
String line=null;
while ((line = keyin.readLine())!=null)
{
ps.print(line);
}
//用一个子线程处理服务器端的数据
new Thread(new ClientThread(socket)).start();
}
}
/**
*
* 客户端子线程创建
*/
class ClientThread implements Runnable
{
private Socket socket;
//保存Socket对象
public ClientThread( Socket socket)
{
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//读取数据
String line=null;
while ((line = br.readLine())!=null)
{
System.out.print(line);
}
} catch (IOException e) {
System.out.print("出错");
System.exit(-1);
}finally {
try {
if (br !=null)
{
br.close();
}
if (socket !=null)
{
socket.close();
}
} catch (IOException e) {
// e.printStackTrace();
}
}
}
}
/**
*
* 创建一个子线程处理客户端传来的数据
*
*/
class ServerThread extends Thread
{
private Socket socket;
public ServerThread(Socket socket)
{
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line=null;
while ((line = br.readLine())!=null)
{
System.out.println(line);
}
} catch (IOException e) {
//e.printStackTrace();
System.out.println("网络异常");
System.exit(-1);
}finally {
try {
if (br !=null) {
br.close();
}
if (socket != null)
socket.close();
} catch (IOException e) {
// e.printStackTrace();
}
}
super.run();
}
}
class Server
{
public static void main(String[] args) throws IOException {
ServerSocket ss=new ServerSocket(10000);
//获取客户端的socket
Socket socket=ss.accept();
//创建一个子线程处理客户端传来的数据
new ServerThread(socket).start();
//终端输入流对象
BufferedReader keyin=new BufferedReader(new InputStreamReader(System.in));
//客户端的输出流对象
PrintStream ps=new PrintStream(socket.getOutputStream());
//读取终端的输入 将输入输出给客户端
String line=null;
while ((line = keyin.readLine())!=null)
{
ps.print(line);
}
}
}
/**
* 1.群聊
* 2.私聊
* 3.取名字
*
*
*
*/
