网络编程
两台及以上的电脑相互连接形成的网络，连接的本质就是网络通讯的问题，通讯的实现就产生了一系列的协议，IP，tcp，udp等协议，所谓网络编程就是数据的通讯操作，这个通讯操作，分为客户端和服务器端，形成了以下两种模型，
c/s(client/server，客户端与服务器端)，要开发出两套程序，一套程序为服务端，服务端改变后，客户端也发生相应改变，
b/s(Browse//server ,浏览器与服务端，) 只开发一套服务端的程序，服务端利用浏览器访问，开发维护成本低，由于使用http协议，并且使用80端口，故安全性较差，现在的开发大都以B/S为主。
C/S，分为两种，tcp(可靠的数据连接),udp(不可靠的数据连接)
echo程序模型
tcp程序的基本实现，
tcp开发，其核心时使用两个类实现数据的交互处理：serversocket（服务器端，），socket（客户端）
serversocket的主要目的时设置服务器的监听端口，
而socket要指明主机和端口，
实现一个简单的数据处理操作，使用echo模型，是一个客户端和服务器端的服务模型，
package demo;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class mythread {
public static void main(String[] args) throws Exception {
ServerSocket server=new ServerSocket(999); // 设置服务端口
System.out.println("d等待客户端连接*****");
Socket client =server.accept(); //有客户连接
/***
* 首先需要先接收客户端发来的信息，而后才可以将信息处理之后发送给客户端
*/
Scanner scan=new Scanner(client.getInputStream());
scan.useDelimiter("\n"); //设置分隔符
PrintWriter out=new PrintWriter(client.getOutputStream());
boolean flag=true; //作为一个循环标记
while(flag) {
if (scan.hasNext()){
String val=scan.next().trim();
if ("byebye".equalsIgnoreCase(val)){
out.println("byebye***");
flag=false; //结束循环
}else {
out.println("[echo]"+val);
out.flush(); //强制刷新缓冲区
}
}
}
scan.close();
out.close();
client.close();
}}
package demo;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class EchoClient {
private static final BufferedReader KEYBOARD_INPUT=new BufferedReader(new InputStreamReader(System.in));
public static void main(String[] args) throws Exception {
Socket client=new Socket("localhost",9999); //定义服务端连接信息，
//现在客户端需要输入和输出的操作支持，所以依然要准备出scanner和printwriter
Scanner scan=new Scanner(client.getInputStream()); //接受服务端内容
scan.useDelimiter("\n");
PrintWriter out=new PrintWriter(client.getOutputStream()); //向服务端发送内容
boolean flag=true;
while (flag){
String input=getString("请输入要发送的内容").trim();
out.println(input); //加换行
if (scan.hasNext()){
System.out.println(scan.next());
}
if ("byebye".equalsIgnoreCase(input)){
flag=false;
}
}
scan.close();
out.close();
client.close();
}
public static String getString(String prompt)throws Exception{
System.out.print(prompt);
String str = KEYBOARD_INPUT.readLine();
return str;
}
}
这里需要注意，自己电脑的telnet cilent服务端要打开，然后运行EchoClient.java,打开电脑的命令行，输入telnet，然后输入open localhost 9999，就可以输入操作了，
（window10版本 没有telnet服务端，要自行下载，网上很难找到破解版，鹰酱要收费，哎）
BIO处理模型
上一个程序存在严重的性能缺陷，仅能为一个线程提供服务，
单线程的服务器开发本身就是不合理的，
可以通过，服务器上启动多个线程，为每一个客户端提供服务，
修改服务器端程序实现多线程接受请求
package demo;
import java.io.IOException;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class mythread {
private static class ClientThread implements Runnable{
private Socket Client=null; //描述每一个不同的客户端
private Scanner scan=null;
private PrintStream out=null;
private boolean flag=true;
public ClientThread(Socket client) throws Exception {
this.Client=client;
this.scan=new Scanner(client.getInputStream());
this.scan.useDelimiter("\n"); //设置分隔符
this.out=new PrintStream(client.getOutputStream());
}
@Override
public void run() {
while(this.flag) {
if (this.scan.hasNext()){
String val=scan.next().trim();
if ("byebye".equalsIgnoreCase(val)){
out.println("byebye***");
this.flag=false; //结束循环
}else {
out.println("[echo]"+val);
out.flush(); //强制刷新缓冲区
}
}
}
try {
this.scan.close();
this.out.close();
this.Client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) throws Exception {
ServerSocket server=new ServerSocket(999); // 设置服务端口
System.out.println("d等待客户端连接*****");
boolean flag=true; //作为一个循环标记
while (flag){
Socket client =server.accept(); //有客户连接
/***
* 首先需要先接收客户端发来的信息，而后才可以将信息处理之后发送给客户端
*/
new Thread(new ClientThread(client)).start();
}
server.close();
}}
多线程意味着能够处理更多的服务处理，
udp程序
基于数据包的网路编程实现，
实现UDP程序需要两个类：datagramPacket（数据内容），datagramsoket（网路传输）数据包是否接收与发送者无关，
package demo;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPserver {
public static void main(String[] args) throws Exception{
DatagramSocket server=new DatagramSocket(9999); //连接到9999端口
String str="www.mldn.cn";
DatagramPacket packet=new DatagramPacket(str.getBytes(),0,str.length(), InetAddress.getByName("localhost"),9999); //接收数据
server.send(packet); //发送消息
System.out.println("发送完毕");
server.close();
}
}
package demo;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPClient {
public static void main(String[] args) throws Exception{
DatagramSocket Client=new DatagramSocket(9999); //连接到9999端口
byte data[]=new byte[1024]; //接受消息
DatagramPacket packet=new DatagramPacket(data,data.length); //接收数据
System.out.println("客户端等待接收消息*****");
Client.receive(packet); // 接收消息，所有的消息在data字节数据中
System.out.println("接收到的消息内容为："+new String(data,0,packet.getLength()));
Client.close();
}
}
tcp连接可靠但是需要的资源也越多，这也就是差别
/***下面补以下stream数据流
stream数据流
jdk1.8之后进入大数据时代，在类集里面也支持有数据的流式分析处理操作，为此专门提供了一个stream的接口，同时在collections接口中提供了实例化的方法，
获取stream接口对象：public default streamstream();
主要是对数据到分析处理，同时主要时是针对集合中的数据进行分析处理，
基础操作：
package demo;
import java.sql.SQLOutput;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class stream {
public static void main(String[] args) throws Exception{
List<String> all=new ArrayList<>();
Collections.addAll(all,"java","php","python","javascript");
Stream<String> stream=all.stream();
System.out.println(stream.count()); // 输出元素个数，
//要求将每一个元素的字母变为小写字母，然后在判断字母j是否存在
System.out.println(stream.filter(ele->ele.toLowerCase().contains("j")).count());
//将包含j的数据转化为list集合
List<String> result=stream.filter((ele)->ele.toLowerCase().contains("j")).collect(Collectors.toList());
System.out.println(result);
}
}
处理大量数据时，选取一些数据
Java大数据处理了解一下就行。