您的位置:首页 > 理论基础 > 计算机网络

java复习系列(1)--实现基于TCP的Socket通信

2017-10-06 14:53 459 查看

java实现基于TCP的Socket通信

正文之前随便说几句,作为一个大四狗最近开始找实习了,先前两次内推,获得两份offer都没有去,因为觉得自己水平还是低了,去了丢学长的脸,还是想再提升下自己。由此开始java系列正式复习,这也是第一篇博客了,有兴趣的小伙伴可以和我一起复习下去。我也是一个菜鸟,如果有什么地方写错了可以告诉我下。在此还要谢谢和我一起学习java的小伙伴Markuna(虽然不知道这个傻吊为啥取这个名字)

什么是socket

简单的来说就是一个接口,服务器端和客户端可以通过这个接口通信。

下列代码参考的是慕课网的教学视频,加上自己的部分见解

服务器端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.*;
public class Server {
public static void main(String[] args) {
try {
//1.创建一个服务器端的socket,即ServerSocket绑定指定端口,并监听此端口
ServerSocket serverSocket=new ServerSocket(8888);
//2.调用accept方法开始监听,等待客户端的连接
System.out.println("服务器已启动,等待客户端响应");
Socket socket=serverSocket.accept();
//3.获取输入流并读取客户端的信息
InputStream is=socket.getInputStream();//获取字节输入流
InputStreamReader isr=new InputStreamReader(is);//将字节流转换成字符流
BufferedReader br=new BufferedReader(isr);//为输入流添加换成
String info=null;
while((info=br.readLine())!=null)
{
System.out.println("获取到客户端的信息 :"+info);
}
socket.shutdownInput();//关闭输入流
//4.向客户端返回信息
OutputStream os=socket.getOutputStream();
PrintWriter pw=new PrintWriter(os);
pw.write("客户端你好");
pw.flush();
//5.关闭资源,原则是先开的后关
pw.close();
os.close();
br.close();
isr.close();
is.close();
socket.close();
serverSocket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}


客户端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.*;
public class Client {
public static void main(String[] args) {
try {
//1.创建客户端Socket,指定服务器的地址和端口
Socket socket=new Socket("localhost",8888);
//2.获取输出流,向服务器发送信息
OutputStream os=socket.getOutputStream();
PrintWriter pw=new PrintWriter(os);
pw.write("服务器你好,我
89ab
是客户端");
pw.flush();//刷新缓存,向服务器发送消息
socket.shutdownOutput();//关闭输出流
//3.接收服务器端返回的信息
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String info=null;
while((info=br.readLine())!=null)
{
System.out.println("获取到服务器端回馈的信息:"+info);
}
//4.关闭资源
br.close();
is.close();
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}


一些看法

1.为什么要不直接用字节流通信呢,一方面是因为对于磁盘而言,反复的存取会对磁盘造成伤害,字符的存取相对于字节而可以减少很多存取的次数。其次,客户端与服务器端的通信这里用的就是字符流的形式。

2.调用shutdownInput()、shutdownOutput()方法之后,socket端口还是处于未关闭状态的,所以还要调用close()方法

3.由于我是用的MyEclipse,想要切换服务器端和客户端的输出界面,可以点右下方向的display selected console

4.这里关闭操作我只是为了简便,按道理来说应该把变量都先声明在try外面,然后在finally里面判断是否为空,然后再一个个关闭,这里我就偷个懒。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: