文章目錄

• 客戶端
• 服務(wù)器
• review：查詢IP和端口
• 發(fā)送文件

客戶端

鏈接服務(wù)器Socket

發(fā)送消息

package com.ayv.try02;import java.io.IOException; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket;//客戶端 public class TcoClientDemo01 {public static void main(String[] args) {Socket socket =null;OutputStream os = null;try {//知道服務(wù)器端口號InetAddress serverIP = InetAddress.getByName("127.0.0.1");int port=9999;//創(chuàng)建一個(gè)socket鏈接socket = new Socket(serverIP,port);//發(fā)送一個(gè)消息IO流os = socket.getOutputStream();os.write("hello world".getBytes());} catch (Exception e) {e.printStackTrace();} finally {//異常if(os!=null){try {os.close();} catch (IOException e) {e.printStackTrace();}}if(socket!=null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}}} }

服務(wù)器

建立服務(wù)的端口 serverSocket

等待用戶的鏈接 accept

接收用戶的消息

package com.ayv.try02;import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket;//服務(wù)端 public class TcpServeDemo02 {public static void main(String[] args) {ServerSocket serverSocket=null;Socket socket =null;InputStream is =null;ByteArrayOutputStream baos =null;try { serverSocket = new ServerSocket(9999);//等待客戶端連接socket = serverSocket.accept();//讀取客戶端消息is = socket.getInputStream();//管道流baos = new ByteArrayOutputStream();byte[] buffer = new byte[1024];int len;while((len=is.read(buffer))!=-1){baos.write(buffer,0,len);}System.out.println(baos.toString());} catch (Exception e) {e.printStackTrace();} finally {if(baos!=null){try {baos.close();} catch (IOException e) {e.printStackTrace();}}if(is!=null){try {is.close();} catch (IOException e) {e.printStackTrace();}}if(socket!=null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}if(serverSocket!=null){try {serverSocket.close();} catch (IOException e) {e.printStackTrace();}}}} }

review：查詢IP和端口

package com.ayv.try01;import java.net.InetAddress; import java.net.UnknownHostException; //測試IP public class TestInetadderss {public static void main(String[] args) {//InetAddress intAddress1 = null;try {//查詢本機(jī)地址InetAddress intAddress1 = InetAddress.getByName("127.0.0.1");System.out.println(intAddress1);InetAddress intAddress3 = InetAddress.getByName("localhost");System.out.println(intAddress3);InetAddress intAddress4 = InetAddress.getLocalHost();System.out.println(intAddress4);//查詢網(wǎng)站IP地址InetAddress intAddress2 = InetAddress.getByName("www.baidu.com");System.out.println(intAddress2);} catch (UnknownHostException e) {e.printStackTrace();}} }

發(fā)送文件

//服務(wù)端 package com.ayv.try02;import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket;public class TcpServerDamo2 {public static void main(String[] args) throws Exception {//創(chuàng)建服務(wù)ServerSocket serverSocket = new ServerSocket(9000);//監(jiān)聽客戶端的鏈接Socket socket = serverSocket.accept(); /**阻斷式監(jiān)聽，會(huì)一直等待客戶端鏈接*///獲取輸入流InputStream is = socket.getInputStream();//文件輸入FileOutputStream fos = new FileOutputStream(new File("receive.jpg"));byte[] buffer = new byte[1024];int len;while((len=is.read(buffer))!=-1){fos.write(buffer,0,len);}fos.close();is.close();socket.close();serverSocket.close();}} //客戶端 package com.ayv.try02;import java.io.File; import java.io.FileInputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; import java.net.UnknownHostException;public class TCPClientDamo2 {public static void main(String[] args) throws Exception {//創(chuàng)建一個(gè)Socket鏈接Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9000);//創(chuàng)建一個(gè)輸出流OutputStream os = socket.getOutputStream();//讀取文件FileInputStream fis = new FileInputStream(new File("觀望.jpg"));//寫出文件byte[] buffer = new byte[1024];int len;while((len=fis.read(buffer))!=-1){os.write(buffer,0,len);}//關(guān)閉資源fis.close();os.close();socket.close();} }

總結(jié)

以上是生活随笔為你收集整理的TCP（发消息：简易代码实现）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。