Java网络基础(一)
TCPTCPServer
import java.io.DataInputStream;import java.io.IOException;import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;public class TCPServer {public static void main(String args[]) {try {ServerSocket ss = new ServerSocket(65000);while (true) {Socket sk = ss.accept();InputStream inStream = sk.getInputStream();DataInputStream dis = new DataInputStream(inStream);System.out.println(dis.readUTF());dis.close();sk.close();}} catch (IOException e) {e.printStackTrace();}}}
TCPClient
import java.io.DataOutputStream;import java.io.OutputStream;import java.net.Socket;public class TCPClient {public static void main(String args[]) {try {Socket sk = new Socket("127.0.0.1", 65000);OutputStream outStream = sk.getOutputStream();DataOutputStream dos = new DataOutputStream(outStream);dos.writeUTF("hello server!");dos.flush();dos.close();sk.close();} catch (Exception e) {e.printStackTrace();}}}
ServerTest
import java.io.DataOutputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class ServerTest {public static void main(String args[]) {try {ServerSocket ss = new ServerSocket(6666);while (true) {Socket sk = ss.accept();OutputStream outStream = sk.getOutputStream();DataOutputStream dos = new DataOutputStream(outStream);dos.writeUTF("Ip:" + sk.getInetAddress() + "\nPort:"+ sk.getPort());dos.close();sk.close();}} catch (Exception e) {e.printStackTrace();System.out.println("程序运行错误");}}}
ClientTest
import java.io.DataInputStream;import java.io.InputStream;import java.net.Socket;public class ClientTest {public static void main(String args[]) {try {Socket sk = new Socket("127.0.0.1", 6666);InputStream inStream = sk.getInputStream();DataInputStream dis = new DataInputStream(inStream);System.out.println(dis.readUTF());dis.close();sk.close();} catch (Exception e) {e.printStackTrace();System.out.println("服务器连接失败!");}}}
SocketServerTest
import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class SocketServerTest {public static void main(String args[]) {try {ServerSocket ss = new ServerSocket(6666);Socket sk = ss.accept();InputStream inStream = sk.getInputStream();OutputStream outStream = sk.getOutputStream();DataInputStream dis = new DataInputStream(inStream);DataOutputStream dos = new DataOutputStream(outStream);String str = null;if ((str = dis.readUTF()) != null) {System.out.println(str);System.out.println("Ip:" + sk.getInetAddress());System.out.println("Port:" + sk.getPort());}dos.writeUTF("roger");dis.close();dos.close();sk.close();} catch (Exception e) {e.printStackTrace();}}}
SocketClientTest
import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.net.Socket;public class SocketClientTest {public static void main(String args[]) {try {Socket sk = new Socket("127.0.0.1", 6666);InputStream inStream = sk.getInputStream();OutputStream outStream = sk.getOutputStream();DataInputStream dis = new DataInputStream(inStream);DataOutputStream dos = new DataOutputStream(outStream);dos.writeUTF("cover me");String str = null;if ((str = dis.readUTF()) != null) {System.out.println(str);}dis.close();dos.close();sk.close();} catch (Exception e) {e.printStackTrace();}}}
UDP
UDPServer
import java.net.DatagramPacket;import java.net.DatagramSocket;public class UDPServer {public static void main(String args[]) {try {byte[] buffer = new byte;DatagramPacket dp = new DatagramPacket(buffer, buffer.length);DatagramSocket ds = new DatagramSocket(6666);ds.receive(dp);System.out.println(new String(buffer, 0, dp.getLength()));ds.close();} catch (Exception e) {e.printStackTrace();}}}
UDPClient
import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetSocketAddress;public class UDPClient {public static void main(String args[]) {try {byte[] buffer = (new String("Hello")).getBytes();DatagramPacket dp = new DatagramPacket(buffer, buffer.length,new InetSocketAddress("127.0.0.1", 6666));DatagramSocket ds = new DatagramSocket(5678);ds.send(dp);ds.close();} catch (Exception e) {e.printStackTrace();}}}
UDPServerTest
import java.io.ByteArrayInputStream;import java.io.DataInputStream;import java.net.DatagramPacket;import java.net.DatagramSocket;public class UDPServerTest {public static void main(String args[]) {try {byte[] buffer = new byte;DatagramPacket dp = new DatagramPacket(buffer, buffer.length);DatagramSocket ds = new DatagramSocket(5678);ds.receive(dp);ByteArrayInputStream bais = new ByteArrayInputStream(buffer);DataInputStream dis = new DataInputStream(bais);System.out.println(dis.readLong());} catch (Exception e) {e.printStackTrace();}}}
UDPClientTest
import java.io.ByteArrayOutputStream;import java.io.DataOutputStream;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetSocketAddress;public class UDPClientTest {public static void main(String args[]) {try {ByteArrayOutputStream baos = new ByteArrayOutputStream();DataOutputStream dos = new DataOutputStream(baos);dos.writeLong(112233L);byte[] buffer = baos.toByteArray();DatagramPacket dp = new DatagramPacket(buffer, buffer.length,new InetSocketAddress("127.0.0.1", 5678));DatagramSocket ds = new DatagramSocket(6666);ds.send(dp);ds.close();} catch (Exception e) {e.printStackTrace();}}}
页:
[1]