好久没写了,最近在学习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();
}
}
网友评论