Java 網絡編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng)
更新時間:2020年11月20日 09:06:00 作者:Hateyes
這篇文章主要介紹了Java 網絡編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng),幫助大家更好的理解和學習Java 網絡編程,感興趣的朋友可以了解下
客戶端
1、連接服務器 Socket
2、發(fā)送消息
package lesson02;
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
/**
* 客戶端
*/
public class TcpClientDemo1 {
public static void main(String[] args) {
Socket socket = null;
OutputStream os = null;
try {
//1、要知道服務器的地址 端口號
InetAddress serverIP = InetAddress.getByName("127.0.0.1");
int port = 9999;
//2、創(chuàng)建一個 socket 連接
socket = new Socket(serverIP, port);
//3、發(fā)送消息 IO流
os = socket.getOutputStream();
os.write("你好,歡迎學習狂神學Java".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();
}
}
}
}
}
服務端
1、建立服務的端口 ServerSocket
2、等待用戶的連接 accept
3、接收用戶的消息
package lesson02;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務端
*/
public class TcpServerDemo1 {
public static void main(String[] args) {
ServerSocket serverSocket = null;
Socket socket = null;
InputStream is = null;
ByteArrayOutputStream baos = null;
try {
//1、我得有一個地址
serverSocket = new ServerSocket(9999);
while (true){
//2、等待客戶端連接過來
socket = serverSocket.accept();
//3、讀取客戶端的消息
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());
}
/*
byte[] buffer = new byte[1024];
int len;
while ((len = is.read(buffer)) != -1){
String msg = new String(buffer, 0, len);
System.out.println(msg);
}
*/
} catch (IOException 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();
}
}
}
}
}
服務端
1、建立服務的端口 ServerSocket
2、等待用戶的連接 accept
3、接收用戶的消息
package lesson02;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務端
*/
public class TcpServerDemo1 {
public static void main(String[] args) {
ServerSocket serverSocket = null;
Socket socket = null;
InputStream is = null;
ByteArrayOutputStream baos = null;
try {
//1、我得有一個地址
serverSocket = new ServerSocket(9999);
while (true){
//2、等待客戶端連接過來
socket = serverSocket.accept();
//3、讀取客戶端的消息
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());
}
/*
byte[] buffer = new byte[1024];
int len;
while ((len = is.read(buffer)) != -1){
String msg = new String(buffer, 0, len);
System.out.println(msg);
}
*/
} catch (IOException 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();
}
}
}
}
}
以上就是Java 網絡編程之 TCP 實現(xiàn)簡單的聊天系統(tǒng)的詳細內容,更多關于Java 實現(xiàn)簡單的聊天系統(tǒng)的資料請關注腳本之家其它相關文章!
相關文章
Java畢業(yè)設計實戰(zhàn)之醫(yī)院心理咨詢問診系統(tǒng)的實現(xiàn)
這是一個使用了java+Spring+Maven+mybatis+Vue+mysql開發(fā)的醫(yī)院心理咨詢問診系統(tǒng),是一個畢業(yè)設計的實戰(zhàn)練習,具有心理咨詢問診該有的所有功能,感興趣的朋友快來看看吧2022-01-01
springboot中rabbitmq實現(xiàn)消息可靠性機制詳解
這篇文章主要介紹了springboot中rabbitmq實現(xiàn)消息可靠性機制詳解,本文通過實例代碼給大家介紹的非常詳細,需要的朋友可以參考下2021-09-09
Java Scanner類用法及nextLine()產生的換行符問題實例分析
這篇文章主要介紹了Java Scanner類用法及nextLine()產生的換行符問題,結合實例形式分析了Scanner類功能、hasNextInt()和nextInt()方法使用及nextLine()產生的換行符問題解決方法,需要的朋友可以參考下2019-03-03

