ServerSocket类：
在开发TCP程序时，首先需要创建服务器端程序。JDK的java.net包中提供了一个ServerSocket类，该类的实例对象可以实现一个服务器段的程序
构造方法：ServerSocket(int port) 创建绑定到特定端口的服务器套接字
常用方法：Socket accept（） 侦听并接受到此套接字的连接
IntAddress getIntAddress() 返回此服务器套接字的本地地址
Socket类：
ServerSocket对象可以实现服务端程序，但只实现服务器端程序还不能完成通信，此时还需要一个客户端程序与之交互，为此JDK提供了一个Socket类，用于实现TCP客户端程序。
通过查阅API文档可知Socket类同样提供了多种构造方法，接下来就对Socket的常用构造方法进行详细讲解。
使用该构造方法在创建Socket对象时，会根据参数去连接在指定地址和端口上运行的服务器程序，其中参数host接收的是一个字符串类型的IP地址。
该方法在使用上与第二个构造方法类似，参数address用于接收一个InetAddress类型的对象，该对象用于封装一个IP地址。
在以上Socket的构造方法中，最常用的是第一个构造方法。
接下来学习一下Socket的常用方法，如表所示。
|
方法声明 |
功能描述 |
|
int getPort() |
该方法返回一个int类型对象，该对象是Socket对象与服务器端连接的端口号 |
|
InetAddress getLocalAddress() |
该方法用于获取Socket对象绑定的本地IP地址，并将IP地址封装成InetAddress类型的对象返回 |
|
void close() |
该方法用于关闭Socket连接，结束本次通信。在关闭socket之前，应将与socket相关的所有的输入/输出流全部关闭，这是因为一个良好的程序应该在执行完毕时释放所有的资源 |
|
InputStream getInputStream() |
该方法返回一个InputStream类型的输入流对象，如果该对象是由服务器端的Socket返回，就用于读取客户端发送的数据，反之，用于读取服务器端发送的数据 |
|
OutputStream getOutputStream() |
该方法返回一个OutputStream类型的输出流对象，如果该对象是由服务器端的Socket返回，就用于向客户端发送数据，反之，用于向服务器端发送数据 |
在Socket类的常用方法中，getInputStream()和getOutStream()方法分别用于获取输入流和输出流。当客户端和服务端建立连接后，数据是以IO流的形式进行交互的，从而实现通信。
文件上传案例：
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Random;
public class Upload implements Runnable {
private Socket socket;
public Upload(Socket socket) {
this.socket = socket;
}
public void run() {
FileOutputStream fos = null;
try {
InputStream in = socket.getInputStream();
// 判断目的地文件夹是否存在，不存在就创建
File file = new File("D:\upload");
if (!file.exists()) {
file.mkdirs();
}
// 封装文件名
String filename = "oracle" + System.currentTimeMillis() + new Random().nextInt(999999) + ".jpg";
fos = new FileOutputStream(file + File.separator + filename);
byte[] bytes = new byte[1024];
int len = 0;
while ((len = in.read(bytes)) != -1) {
fos.write(bytes, 0, len);
}
// 回复客户端
// 获取字节输出流
OutputStream out = socket.getOutputStream();
out.write("收到".getBytes());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
fos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Demo01 {
public static void main(String[] args) throws IOException {
ServerSocket server=new ServerSocket(8888);
while(true){
Socket socket=server.accept();
//创建线程任务
Upload upload=new Upload(socket);
//创建线程对象
Thread th=new Thread(upload);
//开启线程
th.start();
}
}
}
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 TCPClient {
public static void main(String[] args) throws UnknownHostException, IOException {
//创建客户端对象，明确要连接的服务器所在的ip地址和端口号
Socket socket =new Socket("192.168.1.125",8888);
//创建文件字节输入流明确数据源
FileInputStream fis=new FileInputStream("D:\io1227\n.jpg");
//明确目的地
OutputStream out=socket.getOutputStream();
//创建字节数组
byte[] bytes=new byte[1024];
int len=0;
while((len=fis.read(bytes))!=-1){
out.write(bytes,0,len);
}
//告知服务器没有了，别读了
socket.shutdownOutput();
//接收服务器回复
InputStream in=socket.getInputStream();
len=in.read(bytes);
String ip=socket.getInetAddress().getHostAddress();
System.out.println("ip地址为："+ip+"发送的内容为："+new String(bytes,0,len));
socket.close();
fis.close();
}
}