△客户端使用Scanner与BufferedReader的异同,Scanner在客户端调用s.shutdownoutput的时候,将会因为读不到行而报异常,但是BufferedReader的readline方法则会正常终止.因此应当根据实际情况选择客户端服务端的流输入.
△实例：根据DatagramSocket和DatagramPacket建立发送端和接收端。
接收端：
public class Receive {
public static void main(String[] args) throws IOException {
System. out.println("接收端启动……" );
// 建立socket流
DatagramSocket ds=new DatagramSocket();
//将要接受的数据封装到数据包中
byte[] b =new byte[];
DatagramPacket dp= new DatagramPacket(b ,b .length );
//接受数据
ds.receive( dp);
//获取数据中 的信息
String s= new String(dp .getData(),,dp.getLength());
System. out.println(dp .getAddress().getHostAddress()+"::"+ dp.getPort()+ "..."+s );
}
}
发送端：
public class Send {
public static void main(String[] args) throws IOException {
System. out.println("发送端启动。。。。。。。。。。" );
String s= "hello world！" ;
byte[] b =s .getBytes();
//建立socket连接
DatagramSocket ds= new DatagramSocket();
//将要发送的数据信息封装到数据包中
DatagramPacket dp= new DatagramPacket(b,b .length ,InetAddress.getByName ("192.168.0.103" ),9999);
//将数据包的数据发送出去
ds.send( dp);
//关闭socket
ds.close();
}
}
△TCP客户端和服务端练习时，要注意以下两点：
1.输出流需要及时刷新，保证这一点可以让PrintWriter参数列表里有true。
2.readline方法必须要读取到换行符，否则会一直处于阻塞状态
3.在文件读写时，当服务端读写客户端的输入流时，可以在客户端用shutdownoutput方法告诉服务端，(半关闭状态)客户端的读写已经结束。
△TCP传输也可以使用带资源的try语句(方便自动关闭):
public class Server1 {
public static void main(String[] args) throws IOException {
ServerSocket ss =new ServerSocket(9998);
try (Socket s =ss .accept();) {
PrintWriter pw= new PrintWriter(s .getOutputStream(), true);
// Scanner scanner=new Scanner(s.getInputStream());
try (BufferedReader bufr = new BufferedReader(new InputStreamReader(s .getInputStream()));) {
String str= null ;
while ((str =bufr .readLine())!= null) {
pw.println( str.toUpperCase());
}
}
}
}
}
△TCP服务端是多线程的:在接受到一个Socket后,在run方法内执行操作(开启一条线程操作,主线程继续等待接受)标准代码如下:
public class Server2 {
public static void main(String[] args) throws IOException {
ServerSocket ss =new ServerSocket(9999);
while (true ) {
Socket s= ss.accept();
Runnable r=new RunnableImplements(s);
Thread t=new Thread(r);
t.start();
}
}
}
class RunnableImplements implements Runnable {
private Socket incoming;
public RunnableImplements(Socket i) {
incoming=i;
}
public void run() {
System.out.println("任务开始");
//任务
}
}
△可中断套接字:
当通过套接字读写数据的时候,当前线程会被阻塞直到操作或产生超时为止.为了中断套接字操作,可以使用SocketChannel类.如下:
SocketChannel channel=SocketChannel.open(new InetSocketAddress(host,port)); //获取通道
Scanner in=new Scanner(channel); //获取输入流,或者Channel.newInputStream()方法获取字节输入流
OutputStream out=Channels.newOutputStream(channel); //获取输出流
这时候,如果服务器线程正在执行打开或者读取或写入操作,此时如果线程中断,那么这些操作将不会陷入阻塞,而是已抛出异常的形式结束.
△URL类可以封装统一资源定位符,URL类可以打开一个到资源的流,可以调用openConnection方法,建立连接,调用getHeadFields方法获取Map对象类型的相应头.下面是示例(将输出响应头):
public class Demo1 {
public static void main(String[] args) throws IOException {
URL url= new URL("http://www.baidu.com" );
URLConnection con= url.openConnection();
con.connect();
Map<String,List<String>> headers =con .getHeaderFields();
for (Map.Entry<String,List<String>> entry :headers .entrySet()) {
String key= entry.getKey();
for (String value :entry .getValue()) {
System. out .println(key +"::" +value );
}
}
}
}
△URL和URLConnection实现提交表单数据:
1.URL封装资源定位符
2.打开连接,采用openConncetion方法.
3.connection.setDoOutput(true);建立可以输出的连接
4.PrintWriter out=new PrintWriter(connection.getOutPutStream()); 获取可以输出数据的流
5.调用Out的打印方法,发送数据.