前言：
主要通过Java套接字Socket类来实现简单的客户client向服务器server发送信息
概述：
- 环境：Android Studio 3.42
- 语言：Java
- 特点：简单，易懂，效果爆炸
展示：
image.png
客户端
- 首先创建Client.java类
在main方法下构建客户端Socket对象，并连接到服务器,打印客户端和服务器信息
public class Client {
public static void main(String[] args)throws IOException{
Socket socket = new Socket();
//超时时间
socket.setSoTimeout(3000);
socket.connect(new InetSocketAddress(Inet4Address.getLocalHost(),2000),3000);
System.out.println("已发起服务端连接");
System.out.println("客户端信息："+socket.getLocalAddress()+"P:"+socket.getLocalPort());
System.out.println("服务器信息: "+socket.getInetAddress()+"P:"+socket.getPort());
try {
todo(socket);
}catch (Exception e){
System.out.println("异常退出");
}
}
todo方法完成客户端发送信息和接收信息
private static void todo(Socket client)throws IOException{
//构建键盘输入流
InputStream in = System.in;
BufferedReader input = new BufferedReader(new InputStreamReader(in));
//得到socket输出流并转化为打印流
OutputStream outputStream = client.getOutputStream();
PrintStream socketPrintStream = new PrintStream(outputStream);
//得到socket输入流并转化为BufferedReader
InputStream inputStream = client.getInputStream();
BufferedReader socketBufferedReader = new BufferedReader(new InputStreamReader(inputStream));
Boolean flag = true;
do {
//键盘读取一行
String str = input.readLine();
//发送到服务器
socketPrintStream.println(str);
//从服务器读取一行
String echo = socketBufferedReader.readLine();
if ("bye".equalsIgnoreCase(echo)){
flag = false;
}
else {
System.out.println(echo);
}
}
while (flag);
//资源释放
socketBufferedReader.close();
socketPrintStream.close();
}
- 输入输出流
InputStream和OutputStream
对于字节流的输入和输出，是作为协议的存在
关于InputStream,OutputStream详细介绍
BufferedReader和BufferedWriter
是为了提高字符流读写的效率，引入了缓冲机制，进行字符批量的读写，提高了单个字符读写的效率。BufferedReader用于加快读取字符的速度，BufferedWriter用于加快写入的速度，BufferedReader和BufferedWriter类各拥有8192个字符的缓冲区。当BufferedReader在读取文本文件时，会先尽量从文件中读入字符数据并放满缓冲区，而之后若使用read()方法，会先从缓冲区中进行读取。如果缓冲区数据不足，才会再从文件中读取，使用BufferedWriter时，写入的数据并不会先输出到目的地，而是先存储至缓冲区中。如果缓冲区中的数据满了，才会一次对目的地进行写出。
关于BufferedReader,BufferedWriter详细介绍
服务器
- 创建Server.java类
在main方法下构建服务器Socket对象，并获取连接的客户端，然后处理和显示客户端发送的信息
public class Server {
public static void main(String[] args)throws IOException {
ServerSocket server = new ServerSocket(2000);
System.out.println("服务器准备就绪");
System.out.println("服务器信息: "+server.getLocalSocketAddress()+"P:"+server.getLocalPort());
//等待客户端连接
for (;;){
Socket client = server.accept();//拿到客户端
ClientHandle clientHandle = new ClientHandle(client);//客户端加入一个异步线程
clientHandle.start();//启动线程
}
}
客户端的消息处理
/**
客户端消息处理
* */
private static class ClientHandle extends Thread{
private Socket socket;
private Boolean flag = true;
ClientHandle(Socket socket){
this.socket = socket;
}
@Override
public void run() {
super.run();
System.out.println("客户端连接: "+socket.getInetAddress()+"P:"+socket.getPort());
try {
//得到打印流，用于数据输出；服务器回送数据使用
PrintStream socketOutput = new PrintStream(socket.getOutputStream());
//得到输入流，用于接收数据
BufferedReader socketInput = new BufferedReader(new InputStreamReader(socket.getInputStream()));
do {
{
//客户端拿到一条数据
String str = socketInput.readLine();
if ("bye".equalsIgnoreCase(str)){
flag = false;
socketOutput.println("bye");
}
else {
System.out.println(str);
socketOutput.println("回送："+str.length());
}
}
}
while (flag);
}
catch (Exception e){
System.out.println("异常断开");
}
finally {
try {
socket.close();
}
catch (IOException e){
e.printStackTrace();
}
}
System.out.println("客户端已退出: "+socket.getInetAddress()+"P:"+socket.getPort());
}
}
这里通过继承线程Thread实现异步处理客户端发来的信息
总结
在网上发现的一篇文章，顺着作者的思路自己写了一遍代码，虽然自己以取也写过，但重头再来还是想起了不少以前学过的东西，希望大家在阅读的同时，能评论留言，感谢大家的参与~
网友评论