java.net包中定义的两个类Socket和ServerSocket,分别用来实现双向连接到client和server；
TCP端口和UDP端口是分开的，每个都有65536个；
首先启动server在启动client---这时应该启动两个dos窗口，一个编译执行ServerSocket一个编译执行Socket
====================服务器端======================
import java.net.*;
public class TCPServer{
public static void main(String args[])throws Exception{
//相当于起了个服务，并且监听的是6666---即该服务占得事6666这个端口
ServerSocket ss=new ServerSocket(6666);
/**
*对于服务器端的该服务，可能有n个客户端去连接，所以服务器应该不断的去接
*收(ss.accept())----服务器端一般写个死循环，这样可以不断的接受客户端的
*请求；服务器端接受一个请求，就创建一个Socket，用这个Socket来与客户端
*进行交互；
*/
while(true){//死循环
//接受客户端的连接，accept是堵塞的，没有连接就等待
Socket s=ss.accept();
//有连接上面就执行，下面就跟着执行，所以回输出下面的内容
System.out.println("A client connect！");
}
}
}
====================客户端======================
import java.net.*;
public class TCPClient{
public static void main(String args[]) throws Exception{
//创建到指定ip和端口的连接，客户端的这个服务也占端口的
//该端口系统随机分配
Socket s=new Socket("127.0.0.1",6666);
}
}
=========================================================================================================
import java.net.*;
import java.io.*;
public class TCPServer{
public static void main(String args[])throws Exception{
//相当于起了个服务，并且监听的是6666---即该服务占得事6666这个端口
ServerSocket ss=new ServerSocket(6666);
/**
*对于服务器端的该服务，可能有n个客户端去连接，所以服务器应该不断的去接
*收(ss.accept())----服务器端一般写个死循环，这样可以不断的接受客户端的
*请求；服务器端接受一个请求，就创建一个Socket，用这个Socket来与客户端
*进行交互；
*/
while(true){//死循环
//接受客户端的连接，accept是堵塞的，没有连接就等待
Socket s=ss.accept();
//相当于创建一个来自网络连接的输入流，并被处理流包装一下
DataInputStream dis=new DataInputStream(s.getInputStream());
//readUTF也是堵塞式的，如果没写东西，则会等待，知道写了为止
System.out.print(dis.readUTF());
dis.close();
s.close();
}
}
}
------------------------------------------------------------------------------------------------------
import java.net.*;
import java.io.*;
public class TCPClient{
public static void main(String args[]) throws Exception{
//创建到指定ip和端口的连接，客户端的这个服务也占端口的
//该端口系统随机分配
Socket s=new Socket("127.0.0.1",6666);
//相当于创建一个指向TCP连接的输出流
OutputStream os=s.getOutputStream();
//包装一下字节流
DataOutputStream dos=new DataOutputStream(os);
dos.writeUTF("hello server!");
dos.flush();
dos.close();
s.close();
}
}
*****************************************************服务器与客户端的交互**************************************
import java.net.*;
import java.io.*;
public class TCPServer{
public static void main(String args[])throws Exception{
ServerSocket ss=new ServerSocket(6666);
InputStream in=null;
OutputStream out=null;
try{
Socket s=ss.accept();
DataInputStream dis=new DataInputStream(s.getInputStream());
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
String str=null;
if((str=dis.readUTF())!=null){
System.out.println(str);
System.out.println("From:"+s.getInetAddress());
System.out.println("Port:"+s.getPort());
}
dos.writeUTF("hi,client!");
dis.close();
dos.close();
s.close();
}catch(IOException e){e.printStackTrace();}
}
}
---------------------------------------------------------------------------------------------------------
import java.net.*;
import java.io.*;
public class TCPClient{
public static void main(String args[]) throws Exception{
Socket s=new Socket("127.0.0.1",6666);
OutputStream os=s.getOutputStream();
InputStream in=s.getInputStream();
DataOutputStream dos=new DataOutputStream(os);
DataInputStream dis=new DataInputStream(in);
dos.writeUTF("hello server!");
System.out.println(dis.readUTF());
dos.flush();
dos.close();
dis.close();
s.close();
}
}
===========================================================================================
import java.net.*;
public class UDPServer{
public static void main(String args[]) throws Exception{
byte buf[]=new byte[1024];
//创建数据包，而数据包中真正存数据的是上面的数组
DatagramPacket dp=new DatagramPacket(buf,buf.length);
//创建一个DatagramSocket(数据包插座)---接受数据，并放到数据包中
DatagramSocket ds=new DatagramSocket(6666);
while(true){
//接受数据存到数据包中
ds.receive(dp);
System.out.println(new String(buf,0,dp.getLength()));
}
}
}
--------------------------------------------------------------------------------------
import java.net.*;
public class UDPClient{
public static void main(String args[]) throws Exception{
byte[] buf=(new String("hello")).getBytes();
DatagramPacket dp=new DatagramPacket(buf,buf.length,
new InetSocketAddress("127.0.0.1",6666));
DatagramSocket ds=new DatagramSocket(9999);
ds.send(dp);
ds.close();
}
}
====================================================================================================
import java.net.*;
import java.io.*;
public class UDPServer{
public static void main(String args[]) throws Exception{
byte buf[]=new byte[1024];
//创建数据包，而数据包中真正存数据的是上面的数组
DatagramPacket dp=new DatagramPacket(buf,buf.length);
//创建一个DatagramSocket(数据包插座)---接受数据，并放到数据包中
DatagramSocket ds=new DatagramSocket(6666);
while(true){
//接受数据存到数据包中
ds.receive(dp);
ByteArrayInputStream bais=new ByteArrayInputStream(buf);
DataInputStream dis=new DataInputStream(bais);
long n=dis.readLong();
System.out.println(n);
}
}
}
---------------------------------------------------------------------------------------------------
import java.net.*;
import java.io.*;
public class UDPClient{
public static void main(String args[]) throws Exception{
long n=10000L;
ByteArrayOutputStream baos=new ByteArrayOutputStream();
DataOutputStream dos=new DataOutputStream(baos);
dos.writeLong(n);
byte[] buf=baos.toByteArray();
DatagramPacket dp=new DatagramPacket(buf,buf.length,
new InetSocketAddress("127.0.0.1",6666));
DatagramSocket ds=new DatagramSocket(9999);
ds.send(dp);
ds.close();
}
}