Java的Socket编程
package aaa;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
public class Sample extends Thread
{
private Socket s;
public Sample(Socket s)
{
this.s=s;
}
public void run()
{
try {
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
os.write("Hello,welcome you!".getBytes());
byte[] buf = new byte[100];
int len=is.read(buf);
System.out.println(new String(buf, 0, len));
os.close();
is.close();
s.close();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args)
{
if(args.length>0) //配置一下运行方式,当有参数传入时运行server()方法
server();
else //否则,运行client()方法
client();
}
public static void server()
{
try {
ServerSocket ss = new ServerSocket(6000);
while(true){
Socket s=ss.accept();
new Sample(s).start();
//ss.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void client()
{
try {
Socket s = new Socket(InetAddress.getByName(null), 6000);
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
byte[] buf = new byte[100];
int len = is.read(buf);
System.out.println(new String(buf, 0, len));
os.write("Hello,this is quan!".getBytes());
os.close();
is.close();
s.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
|
三种方式获取本机IP地址: InetAddress.getByName(null) InetAddress.getByName("localhost") InetAddress.getByName("127.0.0.1")
以上是基于TCP的socket编程。其中 服务器程序编写: 1、调用ServerSocket(int port)创建一个服务器端套接字,并绑定到指定的端口上; 2、调用accept(),监听连接请求,如果客户端请求连接,则接受连接,返回通信套接字; 3、调用Socket类的getOutputStream()和getInputStream()获取输出流和输入流,开始网络数据的发送和接收; 4、最后关闭通信套接字。
客户端程序编写: 1、调用Socket()创建一个流套接字,并连接服务器端; 2、调用Socket类的getOutputStream()和getInputStream()获取输出流和输入流,开始网络数据的发送和接收; 3、最后关闭通信套接字。
package aaa;
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.UnknownHostException;
public class Sample extends Thread { public static void main(String[] args) { if(args.length>0) recive(); else send(); } public static void recive() { try { DatagramSocket ds = new DatagramSocket(6000); byte[] buf = new byte[100]; DatagramPacket dp = new DatagramPacket(buf, 100); ds.receive(dp); System.out.println(new String(buf, 0, dp.getLength())); String str = "Welcome you!"; DatagramPacket dpSend = new DatagramPacket(str.getBytes(), str.length(), dp.getAddress(), dp.getPort()); ds.send(dpSend); ds.close(); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }
public static void send() { try { DatagramSocket ds=new DatagramSocket(); String str = "Hello,this is yihan!"; DatagramPacket dp = new DatagramPacket(str.getBytes(), str.length(), InetAddress.getByName("localhost"), 6000); ds.send(dp); byte[] buf = new byte[100]; DatagramPacket dpRecv = new DatagramPacket(buf, 100); ds.receive(dpRecv); System.out.println(new String(buf,0,dpRecv.getLength())); ds.close(); } catch (SocketException e) { e.printStackTrace(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
|
基于UDP的socket编程 接收端程序编写: 1、调用DatagramSocket(int port)创建一个数据报套接字,并绑定到指定端口上; 2、调用DatagramPacket(byte[] buf,int length),建立一个字节数组以接收UDP包; 3、调用Datagramsocket类的receive(),接收UDP包; 4、最后关闭数据报套接字;
发送端程序编写: 1、调用DatagramSocket()创建一个数据报套接字; 2、调用DatagramPacket(byte[] buf,int offset,int length,InetAddress address,int port),建立要
发送的UDP包; 3、调用DatagramSocket类的send(),发送UDP包; 4、最后关闭数据报套接字。
|