第84节：Java中的网络编程（中）
程序员文章站
2022-05-17 16:01:55
第84节：Java中的网络编程（中） 实现客户端和服务端的通信： 客户端需要的操作，创建socket，明确地址和端口，进行键盘录入，获取需要的数据，然后将录入的数据发送给服务端，为socket输出流，然后进行读取服务端发送回来的大写数据，为socket读取流，最后进行客户端显示器的显示，进行读写操作 ......
第84节：java中的网络编程（中）
实现客户端和服务端的通信：
客户端需要的操作，创建socket，明确地址和端口，进行键盘录入，获取需要的数据，然后将录入的数据发送给服务端，为socket输出流，然后进行读取服务端发送回来的大写数据，为socket读取流，最后进行客户端显示器的显示，进行读写操作，关闭资源。
网络编程tcp客户端
package com.dashucoding.tcp3;
import java.io.bufferedreader;
import java.io.bufferedwriter;
import java.io.ioexception;
import java.io.inputstream;
import java.io.inputstreamreader;
import java.io.outputstream;
import java.io.outputstreamwriter;
import java.io.printwriter;
import java.net.socket;
import java.net.unknownhostexception;
public class transclient {
public static void main(string[] args) throws ioexception {
// 客户端
// 创建socket 明确地址和端口
socket s = new socket("192.168.1.151",10005);
// 键盘录入
bufferedreader bufr = new bufferedreader(new inputstreamreader(system.in));
// 网络， socket输出流
// outputstream out = s.getoutputstream();
// 传的是字符数据， 转换，提高效率
// bufferedwriter bufout = new bufferedwriter(new outputstreamwriter(out));
// 打印流，既能接收字符又能接收字节
printwriter out = new printwriter(s.getoutputstream());
// 读取流,读取服务端发来的数据
// inputstream in = s.getinputstream();
bufferedreader bufin = new bufferedreader(new inputstreamreader(s.getinputstream()));
// 显示数据，使用输出语句
// 频繁读写，读键盘
string line = null;
while((line=bufr.readline()) != null) {
if("over".equals(line)) {
break;
}
// 读取键盘的数据发送到服务端
out.println(line);
// 读取服务端返回的数据
string uppertext = bufin.readline();
system.out.println(uppertext);
}
// 关闭资源
s.close();
}
}
对于服务端，要创建一个服务端的socket，然后明确端口，要读取客户端发送过来的数据，要读取socket输入流，接着使用socket输出流，将数据发送给客户端，进行读写操作，关闭资源。
网络编程tcp服务端
package com.dashucoding.tcp3;
import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.serversocket;
import java.net.socket;
public class transserver {
public static void main(string[] args) throws ioexception {
system.out.println("服务端运行。。。");
// 服务端：
// 创建服务端的socket,明确端口
serversocket ss = new serversocket(10005);
while (true) {
// 获取客户端对象
socket s = ss.accept();
// 打印ip地址
system.out.println(s.getinetaddress().gethostaddress()+"...connected");
// socket输入流，读取客户端发过来的数据
bufferedreader bufin = new bufferedreader(new inputstreamreader(s.getinputstream()));
// socket输出流，将数据发送给客户端
// printwriter out = new printwriter(s.getoutputstream());
printwriter out = new printwriter(s.getoutputstream(), true);
// 频繁的读写操作
string line = null;
while ((line = bufin.readline()) != null) {
// 如果客户端发送过来的是over
if ("over".equals(line)) {
break;
}
// 客户端的数据
system.out.println(line);
// 字母转大写
out.println(line.touppercase());
// 都在缓冲区中，刷新
// out.flush();
}
// 关闭客户端
s.close();
}
}
}
package com.dashucoding.tcp3;
import java.io.bufferedreader;
import java.io.bufferedwriter;
import java.io.ioexception;
import java.io.inputstream;
import java.io.inputstreamreader;
import java.io.outputstream;
import java.io.outputstreamwriter;
import java.io.printwriter;
import java.net.socket;
import java.net.unknownhostexception;
public class transclient {
public static void main(string[] args) throws ioexception {
system.out.println("客户端运行。。。");
// 客户端
// 创建socket 明确地址和端口
socket s = new socket("192.168.2.151",10005);
// 键盘录入
bufferedreader bufr = new bufferedreader(new inputstreamreader(system.in));
// 网络， socket输出流
// outputstream out = s.getoutputstream();
// 传的是字符数据， 转换，提高效率
// bufferedwriter bufout = new bufferedwriter(new outputstreamwriter(out));
// 打印流，既能接收字符又能接收字节
// printwriter out = new printwriter(s.getoutputstream());
printwriter out = new printwriter(s.getoutputstream(), true);
// 读取流,读取服务端发来的数据
// inputstream in = s.getinputstream();
bufferedreader bufin = new bufferedreader(new inputstreamreader(s.getinputstream()));
// 显示数据，使用输出语句
// 频繁读写，读键盘
string line = null;
// 都一行，有行终止符才返回
while((line=bufr.readline()) != null) {
// 读取键盘的数据发送到服务端
// out.print(line+"\r\n");
out.println(line);
// 刷数据，都在缓冲区中
// out.flush();
if("over".equals(line)) {
break;
}
// 读取服务端返回的数据
string uppertext = bufin.readline();
system.out.println(uppertext);
}
// 关闭资源
s.close();
}
}
上传文件
void shutdowninput() 此套接字的输入流置于“流的末尾” void shutdownoutput() 禁用此套接字的输出流 string tostring() 将此套接字转换为string.
客户端：
package com.dashucoding.net.uploadtext;
import java.io.bufferedreader;
import java.io.filereader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.socket;
import java.net.unknownhostexception;
public class uploadtextclient {
public static void main(string[] args) throws unknownhostexception, ioexception {
system.out.println("上传文件客户端运行。。。");
// 客户端
// 创建socket 明确地址和端口
socket s = new socket("192.168.43.126", 10006);
// 读取文本文件
bufferedreader bufr = new bufferedreader(new filereader("tempfile\\client.txt"));
// 将数据发送给服务端
printwriter out = new printwriter(s.getoutputstream(), true);
// 显示数据，使用输出语句
// 频繁读写，读键盘
string line = null;
// 都一行，有行终止符才返回true
while ((line = bufr.readline()) != null) {
out.println(line);
}
// 给服务端发送一个结束标记，条约标记
// out.println("over");
s.shutdownoutput();
// 向服务端发送了结束标记
// 读取流,读取服务端发来的数据
bufferedreader bufin = new bufferedreader(new inputstreamreader(s.getinputstream()));
string info = bufin.readline();
system.out.println(info);
// 关闭资源
bufr.close();
s.close();
}
}
服务端：
package com.dashucoding.net.uploadtext;
import java.io.bufferedreader;
import java.io.filewriter;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.serversocket;
import java.net.socket;
public class uploadtextserver {
public static void main(string[] args) throws ioexception {
system.out.println("上传文本服务端运行。。。");
// 服务端：
// 创建服务端的socket,明确端口
serversocket ss = new serversocket(10006);
while (true) {
// 获取客户端对象
socket s = ss.accept();
system.out.println(s.getinetaddress().gethostaddress() + "...connected");
// socket输入流，读取客户端发过来的数据
bufferedreader bufin = new bufferedreader(new inputstreamreader(
s.getinputstream()));
// socket输出流，目的是文件
printwriter pw = new printwriter(new filewriter("tempfile\\server.txt"), true);
// 频繁的读写操作
string line = null;
while ((line = bufin.readline()) != null) {
if("over".equals(line)) {
break;
}
pw.println(line);
}
// 发回给客户端，上传成功
printwriter out = new printwriter(s.getoutputstream(),true);
out.println("上传成功");
// 关闭客户端
s.close();
}
}
}
上传图片
客户端：
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileinputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.outputstream;
import java.net.socket;
import java.net.unknownhostexception;
public class uploadpicclient {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片客户端运行。。。");
// 上传图片
// 创建socket
socket s = new socket("192.168.43.126",10007);
// 读取图片，图片路径
file picfile = new file("tempfile\\001.jpg");
fileinputstream fis = new fileinputstream(picfile);
// socket 输出流
outputstream out = s.getoutputstream();
byte[] buf = new byte[1024];
int len = 0;
while((len=fis.read(buf)) != -1) {
out.write(buf,0,len);
}
// 告诉服务器端图片数据发送完毕，不要等着读了。
s.shutdownoutput();
// 读取上传成功
inputstream in = s.getinputstream();
byte[] bufin = new byte[1024];
int lenin = in.read(bufin);
system.out.println(new string(bufin, 0, lenin));
// 关闭
fis.close();
s.close();
}
}
服务端：
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.serversocket;
import java.net.socket;
import org.omg.corba_2_3.portable.outputstream;
public class uploadpicserver {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片服务端运行。。。");
// 创建serversocket
serversocket ss = new serversocket(10007);
while (true) { // 实现上传多回
// 获取客户端
socket s = ss.accept();
string ip = s.getinetaddress().gethostaddress();
system.out.println(ip+"...connected");
// 读取图片数据
inputstream in = s.getinputstream();
// 写图片数据到文件
file picfile = new file("tempfile\\server.jpg"); // 存储图片
fileoutputstream fos = new fileoutputstream(picfile);
byte[] buf = new byte[1024];
int len = 0;
while ((len = in.read(buf)) != -1) {
fos.write(buf, 0, len);
}
// 给客户端返回一个回馈信息
java.io.outputstream out = s.getoutputstream();
out.write("上传成功".getbytes());
// 关闭资源
fos.close();
s.close();
}
}
}
如何解决图片重名的问题：
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileinputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.outputstream;
import java.net.socket;
import java.net.unknownhostexception;
public class uploadpicclient {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片客户端运行。。。");
// 上传图片
// 创建socket
socket s = new socket("192.168",10007);
// 读取图片，图片路径
file picfile = new file("tempfile\\001.jpg");
fileinputstream fis = new fileinputstream(picfile);
// socket 输出流
outputstream out = s.getoutputstream();
byte[] buf = new byte[1024];
int len = 0;
while((len=fis.read(buf)) != -1) {
out.write(buf,0,len);
}
// 告诉服务器端图片数据发送完毕，不要等着读了。
s.shutdownoutput();
// 读取上传成功
inputstream in = s.getinputstream();
byte[] bufin = new byte[1024];
int lenin = in.read(bufin);
system.out.println(new string(bufin, 0, lenin));
// 关闭
fis.close();
s.close();
}
}
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.serversocket;
import java.net.socket;
import org.omg.corba_2_3.portable.outputstream;
public class uploadpicserver {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片服务端运行。。。");
// 创建serversocket
serversocket ss = new serversocket(10007);
while (true) { // 实现上传多回
// 获取客户端
socket s = ss.accept();
string ip = s.getinetaddress().gethostaddress();
system.out.println(ip+"...connected");
// 读取图片数据
inputstream in = s.getinputstream();
// 写图片数据到文件
// 创建目录
file dir = new file("e:\\uploadpic");
// 如果不存在就创建目录
if(!dir.exists()) {
dir.mkdir();
}
// 给文件编号
// 加计数器
int count = 1;
// 防止第二次为0
file picfile = new file(dir, ip + "("+count+").jpg");
// if(picfile.exists()) {
while(picfile.exists()) {
count++;
picfile = new file(dir, ip + "("+count+").jpg");
}
fileoutputstream fos = new fileoutputstream(picfile);
// file picfile = new file("tempfile\\" + ip + ".jpg");
// file picfile = new file("tempfile\\server.jpg");
// 存储图片
byte[] buf = new byte[1024];
int len = 0;
while ((len = in.read(buf)) != -1) {
fos.write(buf, 0, len);
}
// 给客户端返回一个回馈信息
java.io.outputstream out = s.getoutputstream();
out.write("上传成功".getbytes());
// 关闭资源
fos.close();
s.close();
}
}
}
解决上传并发的问题
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileinputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.outputstream;
import java.net.socket;
import java.net.unknownhostexception;
public class uploadpicclient {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片客户端运行。。。");
// 上传图片
// 创建socket
socket s = new socket("",10007);
// 读取图片，图片路径
file picfile = new file("tempfile\\001.jpg");
fileinputstream fis = new fileinputstream(picfile);
// socket 输出流
outputstream out = s.getoutputstream();
byte[] buf = new byte[1024];
int len = 0;
while((len=fis.read(buf)) != -1) {
out.write(buf,0,len);
}
// 告诉服务器端图片数据发送完毕，不要等着读了。
s.shutdownoutput();
// 读取上传成功
inputstream in = s.getinputstream();
byte[] bufin = new byte[1024];
int lenin = in.read(bufin);
system.out.println(new string(bufin, 0, lenin));
// 关闭
fis.close();
s.close();
}
}
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.serversocket;
import java.net.socket;
import org.omg.corba_2_3.portable.outputstream;
public class uploadpicserver {
public static void main(string[] args) throws ioexception {
system.out.println("上传图片服务端运行。。。");
// 创建serversocket
serversocket ss = new serversocket(10007);
while (true) { // 实现上传多回
// 获取客户端
socket s = ss.accept();
new thread(new uploadpic(s)).start();
}
}
}
package com.dashucoding.net.uploadpic;
import java.io.file;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.socket;
// 创建任务
// 线程完成任务后，会自动结束
public class uploadpic implements runnable {
private socket s;
// 创建构造函数
public uploadpic(socket s) {
this.s = s;
}
@override
public void run() {
try {
// 主线程负债接收客户端，其它线程负责接收数据
string ip = s.getinetaddress().gethostaddress();
system.out.println(ip + "...connected");
// 读取图片数据
inputstream in = s.getinputstream();
// 写图片数据到文件
// 创建目录
file dir = new file("e:\\uploadpic");
// 如果不存在就创建目录
if (!dir.exists()) {
dir.mkdir();
}
// 给文件编号
// 加计数器
int count = 1;
// 防止第二次为0
file picfile = new file(dir, ip + "(" + count + ").jpg");
// if(picfile.exists()) {
while (picfile.exists()) {
count++;
picfile = new file(dir, ip + "(" + count + ").jpg");
}
fileoutputstream fos = new fileoutputstream(picfile);
// 开始循环进行读写操作
// 一个线程，不能处理并发的数据
byte[] buf = new byte[1024];
int len = 0;
while ((len = in.read(buf)) != -1) {
fos.write(buf, 0, len);
}
// 给客户端返回一个回馈信息
java.io.outputstream out = s.getoutputstream();
out.write("上传成功".getbytes());
// 关闭资源
fos.close();
s.close();
} catch (ioexception e) {
e.printstacktrace();
}
}
}
客户端：浏览器，服务端：tomcat
端口号，\con\server.xml：
浏览器发送http请求
get / http / 1.1 accept: accept-language: accept-encoding: user-agent: host: connection:
请求行，协议，应用层协议，超文本传输协议，请求方式，访问资源的路径，http的协议版本，
package com.dashucoding.net.myserver;
import java.io.ioexception;
import java.io.inputstream;
import java.io.printwriter;
import java.net.socket;
import java.net.unknownhostexception;
public class mybrowser {
public static void main(string[] args) throws unknownhostexception, ioexception {
// 浏览器发送http消息
socket s = new socket("",8080);
// 把信息发送给服务端
printwriter out=new printwriter(s.getoutputstream(),true);
out.println("");
out.println();//空行
// 读取服务端的数据
inputstream in = s.getinputstream();
byte[] buf = new byte[1024];
string text = new string(buf,0,len);
system.out.print(text);
s.close();
}
}
发送和http协议相同的信息，收到了tomcat服务器返回的数据。
package com.dashucoding.net.myserver;
import java.awt.borderlayout;
import java.awt.eventqueue;
import javax.swing.jframe;
import javax.swing.jpanel;
import javax.swing.border.emptyborder;
public class mybrowsergui extends jframe {
private jpanel contentpane;
/**
* launch the application.
*/
public static void main(string[] args) {
eventqueue.invokelater(new runnable() {
public void run() {
try {
mybrowsergui frame = new mybrowsergui();
frame.setvisible(true);
} catch (exception e) {
e.printstacktrace();
}
}
});
}
/**
* create the frame.
*/
public mybrowsergui() {
setdefaultcloseoperation(jframe.exit_on_close);
setbounds(100, 100, 450, 300);
contentpane = new jpanel();
contentpane.setborder(new emptyborder(5, 5, 5, 5));
contentpane.setlayout(new borderlayout(0, 0));
setcontentpane(contentpane);
}
}
url的描述
java.net 类 url java.lang.object java.net.url 所有已实现的接口: serializable public final class url extends object implements serializable url 表示一个统一的资源定位符，用于指向互联网"资源"的指针。
// 构造方法 url (string spec)： 根据string表示形式创建url对象 url (string protocol, string host, int port, string file) 根据指定protocol,host,port号和file创建url对象
package com.dashucoding.net.url;
import java.io.ioexception;
import java.io.inputstream;
import java.net.malformedurlexception;
import java.net.url;
import java.net.urlconnection;
public class urldemo {
public static void main(string[] args) throws ioexception {
string str_url = "http://";
//将url地址封装成对象。
url url = new url(str_url);
// system.out.println("getprotocol:"+url.getprotocol());
// system.out.println("gethost:"+url.gethost());
// system.out.println("getport:"+url.getport());
// system.out.println("getpath:"+url.getpath());
// system.out.println("getfile:"+url.getfile());
// system.out.println("getquery:"+url.getquery());
//获取指定资源的连接对象,封装了socket。
urlconnection conn = url.openconnection();
// system.out.println(conn);
inputstream in = conn.getinputstream();
byte[] buf = new byte[1024];
int len = in.read(buf);
string text = new string(buf,0,len);
system.out.println(text);
}
}
openconnection public urlconnection openconnection() throws ioexception 返回一个urlconnection对象，它表示到url所引用的远程对象的连接
urlconnection
package com.dashucoding.net.url;
import java.io.ioexception;
import java.io.inputstream;
import java.net.malformedurlexception;
import java.net.url;
import java.net.urlconnection;
public class urldemo {
public static void main(string[] args) throws ioexception {
string str_url = "http://";
// 将url地址封装成对象。
url url = new url(str_url);
// system.out.println("getprotocol:"+url.getprotocol());
// system.out.println("gethost:"+url.gethost());
// system.out.println("getport:"+url.getport());
// system.out.println("getpath:"+url.getpath());
// system.out.println("getfile:"+url.getfile());
// system.out.println("getquery:"+url.getquery());
// 获取指定资源的连接对象,封装了socket。
urlconnection conn = url.openconnection();
// system.out.println(conn);
inputstream in = conn.getinputstream();
byte[] buf = new byte[1024];
int len = in.read(buf);
string text = new string(buf, 0, len);
system.out.println(text);
}
}
网络编程中http版本的区别
http1.0请求一次连接就断开了，一次连接只能有一次请求，http1.1一次连接多次请求。
url用于解析url地址，urlconnection用于获取url的连接。
常见的网络架构：cs和bs
client / server 客户端和服务端，维护麻烦 browser / server 只需要服务端，只要系统内置浏览器 所有的运算在服务端，简单易用
结言
好了，欢迎在留言区留言，与大家分享你的经验和心得。
感谢你学习今天的内容，如果你觉得这篇文章对你有帮助的话，也欢迎把它分享给更多的朋友，感谢。
达叔小生：往后余生，唯独有你
you and me, we are family !
90后帅气小伙，良好的开发习惯；独立思考的能力；主动并且善于沟通
简书博客： 达叔小生
结语
- 下面我将继续对 其他知识 深入讲解 ，有兴趣可以继续关注
- 小礼物走一走 or 点赞