ServerSocket():
创建非绑定服务器套接字。ServerSocket(int port):
创建绑定到特定端口的服务器套接字。ServerSocket(int port, int backlog):
利用指定的backlog创建服务器套接字并将其绑定到指定的本地端口号。ServerSocket(int port, int backlog, InetAddress bindAddress):
使用指定的端口、侦听backlog和要绑定到的本地I地址创建服务器。这种情况适用于计算机上有多块网卡和多个IP地址的情况,用于可以明确规定ServerSocket在哪块网卡或P地址上等待客户的连接请求。accept()
方法会阻塞线程的继续执行,直到接收到客户的呼叫。ServerSocket
类的accept()
方法会返回一个和客户端Socket
对象相连接的Socket
对象Socket
对象使用getOutputStream()
方法获得的输出流将指向客户端Socket
对象使用getInputStream()
方法获得的那个输入流;Socket
对象使用getInputStream()
方法获得的输入流将指向客户端Socket
对象使用getOutputStream()
方法获得的那个输出流。// server
BufferedReader reader;
Socket socket;
ServerSocket serverSocket = new ServerSocket(8080);
System.out.println("创建成功");
while (true){
socket = serverSocket.accept();
System.out.println("连接成功");
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
try {
String info = null;
while ((info = reader.readLine()) != null) {
System.out.println(info);
}
} catch (Exception e){
}
if (reader != null) reader.close();
if (socket != null) socket.close();
}
// client
PrintWriter pw;
Socket socket = new Socket("localhost", 8080);
System.out.println("连接成功");
pw = new PrintWriter(socket.getOutputStream(), true);
pw.write("ok");
pw.print('x');
if(pw!=null)
pw.close();
if(socket!=null)
socket.close();
服务端socket处理客户端socket连接是需要一定时间的。ServerSocket有一个队列,存放还没有来得及处理的客户端Socket,这个队列的容量就是backlog的含义。如果队列已经被客户端socket占满了,如果还有新的连接过来,那么ServerSocket会拒绝新的连接。也就是说backlog提供了容量限制功能,避免太多的客户端socket占用太多服务器资源。 客户端每次创建一个Socket对象,服务端的队列长度就会增加1个。服务端每次accept(),就会从队列中取出一个元素。
DatagramSocket()
创建一个数据包套接字。DatagramPacket(byte[] buf, int offset, int length, InetAddress address, int port)
创建要发送的数据包。DatagramSocket
类的send()
方法发送数据包。DatagramSocket(int port)
创建数据包套接字,绑定到指定的端口。DatagramPacket(byte[] buf, int length)
创建字节数组来接收数据包。DatagramPacket
类的receive()
方法接收UDP
包。DatagramSocket
类的receive()
方法接收数据时,如果还没有可以接收的数据,在正常情况下receive()
方法将阻塞,一直等到网络上有数据传来,receive()
方法接收该数据并返回。
receive()
方法也没有阻塞,肯定是程序有问题,大多数是使用了一个被其他程序占用的端口号。
DatagramSocket()
:构造数据报套接字并将其绑定到本地主机上任何可用的端口。DatagramSocket(int port)
:创建数据报套接字并将其绑定到本地主机上的指定端口。DatagramSocket(int port,InetAddress addr)
:创建数据报套接字并将其绑定到指定的本地地址。 在接收程序时,必须指定一个端口号,不要让系统随机产生,此时可以使用第二种构造函数。在发送程序时,通常使用第一种构造函数,不指定端口号,这样系统就会为我们分配一个端口号。
// server
byte[] data = new byte[1024];
DatagramSocket socket = new DatagramSocket(8080);
InetAddress inetAddress = InetAddress.getLocalHost();
DatagramPacket packet = new DatagramPacket(data, data.length);
socket.receive(packet);
System.out.println(Arrays.toString(data));
// client
byte[] data = "test".getBytes();
DatagramSocket socket = new DatagramSocket();
InetAddress inetAddress = InetAddress.getLocalHost();
DatagramPacket packet = new DatagramPacket(data, data.length, inetAddress, 8080);
socket.send(packet);
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.12</version>
</dependency>
使用HttpClient
发送请求主要分为以下几个步骤:
CloseableHttpClient
对象或CloseableHttpAsyncClient
对象,前者同步,后者为异步Http
请求对象execute
方法执行请求,如果是异步请求在执行之前需调用start
方法// 最好使用static修饰,以保证用同一个client对象处理请求,以保存进度
static CloseableHttpClient client = HttpClients.createDefault();
// 第二种方法里添加一些网络访问选项设置
static CloseableHttpClient httpClient=HttpClients.custom().build();
HttpGet get = new HttpGet("http://www.baidu.com");
参数为cookiespecs
的一些字段。
作用:
header
中有set-cookie
字段时,采用默认方式可能会被cookie reject
,无法写入cookie
。将此属性设置成CookieSpecs.STANDARD_STRICT
可避免此情况。
cookie
访问,则将此属性设置成CookieSpecs.IGNORE_COOKIES
。
**tips:**注意网站编码,否则容易出现乱码
// 设置超时及cookie策略
static RequestConfig config = RequestConfig.custom()
.setConnectTimeout(6000)
.setSocketTimeout(6000)
.setCookieSpec(CookieSpecs.STANDARD)
.build();
get.setConfig(config);
新建httpget对象 -> 用httpClient执行- > 解析返回的response得到自己需要的内容
// 执行请求,获取response
HttpResponse response = client.execute(get);
// 状态码
int statusCode = response.getStatusLine().getStatusCode();
System.out.println(statusCode);
// 用于得到返回的文件头
Header[] headers = response.getAllHeaders();
System.out.println(Arrays.toString(headers));
// 在后面参数输入网站的编码,一般为utf-8。返回的html代码,避免发生编码错误
String html = new String(EntityUtils.toString(response.getEntity()).getBytes("iso8859-1"), "gb2312");
System.out.println(html);
新建post对象 -> 新建需要的表单页 -> 将表单内容设置入请求中 -> 执行并获得response
CloseableHttpClient client = HttpClients.createDefault();
HttpPost post = new HttpPost("http://www.baidu.com");
// 设置请求头header
post.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/45.0.2454.93 Safari/537.36");
post.setHeader("Connection", "keep-alive");
// 设置表单键值对
List<NameValuePair> list = new ArrayList<>();
list.add(new BasicNameValuePair("key1", "value1"));
list.add(new BasicNameValuePair("key2", "value2"));
// 把输入数据编码成合适的内容
HttpEntity entity = new UrlEncodedFormEntity(list, "utf-8");
post.setEntity(entity);
HttpResponse response = client.execute(post);
String html = EntityUtils.toString(response.getEntity());
System.out.println(html);
String responseHtml = EntityUtils.toString(response.getEntity());
int statusCode = response.getStatusLine().getStatusCode();
response.getFirstHeader("key"); // 得到第一个名字为key的header
response.getHeaders("key"); // 得到名字为key的所有header,返回一个数组
response.getLastHeader("key");
下载网络部分资源的时候有可能会对cookie有要求,此时需要用到httpClient来下载。例如验证码等等。
InputStream inputStream = response.getEntity().getContent();
由一系列url编码对组成的实体。这在发送HTTP POST请求时通常很有用。
UrlEncodedFormEntity会以字符串键值对形式传给后台,即:{“a”:“value1”, “b”:“value2”},传给java方法,接收到的参数是:a=value1&b=value2,即它不支持json参数传递;
而StringEntity传参,后台接收到的依然是 {“a”:“value1”, “b”:“value2”},即StringEntity能传递json。
当然,如果你传递的就是一个普通的字符串,StringEntity也是支持的。
String param = "{\"a\":\"value1\", \"b\":\"value2\"}";
StringEntity entity = new StringEntity(param, ContentType.create("application/json", "UTF-8"));
post.setEntity(entity);
使用指定编码格式,将网页中文内容转换成对应的字符集。
String Ori = EntityUtils.toString(httpResponse.getEntity(), "iso8859-1");
再转换为统一的utf-8
String entity = new String(Ori.getBytes(), "utf-8");
String CharsetString = EntityUtils.toString(response.getEntity());
// 解析
Document CharsetDocument = Jsoup.parse(CharsetString);
// 字符集信息提取
String charset = CharsetDocument.select("meta[http-equiv=Content-Type]").attr("content").split("=")[1];