Tcp通信有两个特点分别是面向连接,具有可靠性.
面向连接:指的是客户端与服务端之间的连接,在通信之前会有三次握手的机制来确保连接的可靠性.
可靠性:tcp在确保他的可靠性上做了许多的功夫,这个可靠性体现在下面两方面:
如下图是实现服务器端与客户端通信的思路:
服务端用到的类是ServerSocket
ServerSocker类在他的api文档里面也说了他是实现服务器的一个类
了解一个类我们还是老样子先了解他的构造方法,我们看一下api文档
我们常用的构造方法是第一个ServerSocket()和第二个serverSocket(int port).接下来我们只讲这两个方法.
我们先来讲讲serverSocket()这个构造方法吧!
serverSocket()这个构造方法是创建一个没有绑定端口的对象,一般他和如下方法配套使用
用以上的方法可以绑定一个你指定的ip地址和端口号.
接下来我们再讲讲第二个常用的构造方法吧 !
ServerSocket(int port)这个构造函数创建的是一个绑定本机的一个自定义端口的一个ServerSocket对象.
如下面的例子
ServerSocket serverSocket = new ServerSocket(6666); //绑定端口号为6666的端口
ServerSocket常用的方法
accept()方法是一个监听器,是一个阻塞式,它要等有服务端来连接了才能进行下一步,如果没有客户端来连接就会一直等待下去,直到接收到连接才往下运行.这个方法返回的是一个Socket对象,有客户端来连接,就会产生一个Socket对象.这个Socket对象就负责与服务端进行通信
close方法是释放服务器所占用的资源,并且断开全部客户端的连接.
Socket类是实现客户端通信
接下来我们解析socket类
我们就看常用的socket类的构造方法吧
第一个构造方法
是创建一个连接到的一个指定的ip地址以及指定的端口号的服务器的socket对象.如果你得到的一个Ip地址是一个字符串类型我们还可以使用另一个构造方法
这个构造方法同样的也是创建一个连接到的一个指定的ip地址以及指定的端口号的服务器的socket对象
我们来看看他的常用方法
我们这里着重讲的是getOutputStream()方法与getInputStream()
getOutputStream()返回的是一个OutputStream字节输出流对象，我们从这里可以知道我们可以发送数据给服务器/客户端。
getInputStream() 返回有的是InputStream字节输入流对象，我们可以通过这个对象接受服务器/客户端发来的消息。
服务端代码
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.net.ServerSocket;
import java.net.Socket;
/**
* 服务端
* @author Administrator
*
*/
public class Server {
public static void main(String[] args) {
ServerSocket server = null;
Socket socket = null;
try {
//准备服务器端用的通讯对象（套接字）,指明端口号为8888
server = new ServerSocket(8888);
//到指定端口去阻塞监听,一旦有客户端请求发送过来，那么立即自动与客户端建立连接
socket = server.accept();
System.out.println("服务器端准备ok");
//我要发送到客户端的内容
String msg = "你好,我是服务器，这是我的第一次通讯,请问你收到了吗";
OutputStream os = socket.getOutputStream();//准备输出对象
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
bw.write(msg);
bw.newLine();
bw.flush();
//接收客户端发送的信息
InputStream is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String reply = br.readLine();
System.out.println("我是服务器，接收到信息："+reply);
br.close();
is.close();
bw.close();
os.close();
socket.close();
server.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}客户端代码
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.net.Socket;
import java.net.UnknownHostException;
/**
* 客户端
* @author Administrator
*
*/
public class Client {
public static void main(String[] args) {
Socket socket = null;
try {
socket = new Socket("localhost", 8888);
System.out.println("客户端准备完成");
//客户端开始接受请求
InputStream is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String msg = br.readLine();
System.out.println("我是客户端，接收到信息："+msg);
//客户端接收到服务器端的信息之后，需要反馈信息给服务器
//客户端想要反馈给服务器端的信息
String reply = "我是客户端，收到你的信息，这是我的反馈";
OutputStream os = socket.getOutputStream();//准备客户端的输出流
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
bw.write(reply);
bw.newLine();
bw.flush();
bw.close();
os.close();
br.close();
is.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
