好久没写了，最近在学习Java，真的是一入Java深似海啊，比C++简单易用的特性让我有了继续深入下去的动力，Java又称C++-，可以说是C++ 的改进版，取消了类型自动转换，运算符重载，多继承，以及致命的指针，还有内存空间的动态申请与释放，Java创建了垃圾自动回收机制，更是方便了我们编码。
经过一周的学习，已经初步了解了Java语言的特性，对于Java的继承多态与封装，接口，集合，多线程多进程，IO流有了一定的认识。Java在服务器，网站开发领域的应用是最多的，服务器与客户端这样的关系在已经深入我们的日常生活中，比如QQ，微信，各种客户端游戏DOTA，LOL等。服务器与客户端，客户端与客户端的通信肯定少不了各种协议，其中在传输层最常用的就是TCP，UDP。
关于协议的介绍可参考 阮一峰老师的博客，我觉得写的非常好，通俗易懂，深入浅出，很佩服阮老师能从03年开始写博客，一直坚持到现在，已有16年了。
TCP 协议简介
互联网协议入门（一）
互联网协议入门（二）
下面是一个简单的基于TCP协议的服务器和客户端demo
客户端代码
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
public class TCPClient {
public static void main(String[] args) throws IOException {
// 创建一个客户端对象Socket，构造方法绑定服务器的IP地址和端口号
Socket socket = new Socket("127.0.0.1",8888);
// 使用socket对象中的方法getOutputStream()获取网络字节输出流对象
OutputStream os = socket.getOutputStream();
// 使用网络字节输出流对象OutputStream中的方法write,给服务器发送数据
os.write("你好，服务器".getBytes());
// 使用socket对象中的方法getInputStream()获取网络字节输入流对象
InputStream is = socket.getInputStream();
// 使用read方法，读取服务器回写的数据
byte[] bytes = new byte[1024];
int len = is.read(bytes);
System.out.println(new String(bytes,0,len));
// 释放资源
socket.close();
}
}
服务器代码
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class TCPServer {
public static void main(String[] args) throws IOException {
// 创建一个服务器对象ServerSocket，构造方法绑定端口号
ServerSocket serversocket = new ServerSocket(8888);
//通过服务器对象的accept方法，得到客户端对象
Socket socket = serversocket.accept();
// 使用socket对象中的方法getInputStream()获取网络字节输入流对象
InputStream is = socket.getInputStream();
// 使用socket对象中的方法getOutputStream()获取网络字节输出流对象
OutputStream os = socket.getOutputStream();
byte[] bytes = new byte[1024];
int len = is.read(bytes);
System.out.println(new String(bytes,0,len));
os.write("收到谢谢".getBytes());
// 释放socket资源
socket.close();
// 释放serversocket资源
serversocket.close();
}
}
先运行服务器端代码，开启服务器，在运行客户端代码，发送“你好，服务器”在服务器显示，服务器端回应“收到谢谢”在客户端显示。这展示了一个基本的TCP通信流程，下面做简单修改，可以让客户端发送文件保存到服务器。
客户端代码：
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
public class UploadCliend {
public static void main(String[] args) throws IOException {
FileInputStream fis = new FileInputStream("E:\\java_code\\src\\Net\\lenna.jpg");
Socket socket = new Socket("127.0.0.1",8888);
OutputStream os = socket.getOutputStream();
int len=0;
while((len=fis.read())!=-1)
{
os.write(len);
}
fis.close();
os.close();
}
}
服务器代码：
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(8888);
Socket accept = serverSocket.accept();
InputStream is = accept.getInputStream();
FileOutputStream fos = new FileOutputStream("lenna1.jpg");
int len=0;
while ((len=is.read())!=-1)
{
fos.write(len);
}
accept.close();
fos.close();
}
}
给服务器添加多线程，增加上传效率
服务器代码：
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;
public class UploadServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(8888);
while (true) {
Socket accept = serverSocket.accept();
// new一个Thread，并使用匿名内部类实现Runnable接口，重写run方法。
new Thread(new Runnable() {
@Override
public void run() {
try {
InputStream is = accept.getInputStream();
// 随机生成一个文件名
String filename = "itcast"+System.currentTimeMillis()+new Random().nextInt(999999)+".jpg";
FileOutputStream fos = new FileOutputStream(filename);
byte[] bytes = new byte[1024];
int len=0;
while ((len=is.read(bytes))!=-1)
{
fos.write(bytes,0,len);
}
accept.getOutputStream().write("上传成功".getBytes());
fos.close();
accept.close();
}catch (Exception e){
System.out.println(e);
}
}
}).start();
//serverSocket.close();
}
}
}
客户端代码：
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class UploadCliend {
public static void main(String[] args) throws IOException {
FileInputStream fis = new FileInputStream("E:\\java_code\\src\\Net\\lenna.jpg");
Socket socket = new Socket("127.0.0.1",8888);
OutputStream os = socket.getOutputStream();
byte[] bytes = new byte[1024];
int len=0;
while((len=fis.read(bytes))!=-1) {
os.write(bytes, 0, len);
}
socket.shutdownOutput();
InputStream is = socket.getInputStream();
while((len=is.read(bytes))!=-1)
{
System.out.println(new String(bytes,0,len));;
}
fis.close();
socket.close();
}
}
