一缓苛、目的
- 了解URL地址
- 使用socket實現(xiàn)數(shù)據(jù)發(fā)送
- 實現(xiàn)雙向傳遞
- 實現(xiàn)對聊和群聊功能
二甩栈、學習內(nèi)容
1.網(wǎng)絡(luò)編程
在兩臺不同的計算機之間傳遞數(shù)據(jù)
- 1.qq聊天
- 2.打開網(wǎng)易App 刷新界面 就有數(shù)據(jù)
- 3.打開瀏覽器 網(wǎng)頁 www.baidu.com
客戶端:手機App 瀏覽器 桌面QQ
服務(wù)器端:存儲/處理數(shù)據(jù)
2.URL:統(tǒng)一的資源定位
http://www.baidu.com/search?code=android
http//https:傳輸協(xié)議 TCP/IP
www.baidu.com:域名 表示一臺網(wǎng)絡(luò)中的電腦
ipv4 ipv6地址:唯一標識一臺網(wǎng)絡(luò)中的計算機
32位:四個部分每個是8個字節(jié)
3.DNS服務(wù)器:域名解析
將www.baidu.com類型的域名解析為對應(yīng)的ip地址
search 對應(yīng)的后臺程序文件 php java jsp
寥袭？表示運行這個程序需要傳遞的參數(shù)
code=Android code是服務(wù)器端規(guī)定的字段
& 如果有多個參數(shù)使用&符號鏈接
4.ip地址落恼、端口號
ip地址:唯一標識某一臺電腦
端口號:唯一標識電腦上的某一個進程（程序）80
數(shù)據(jù)傳輸:TCP/IP協(xié)議
TCP:面向連接的锨能、安全的 打電話
UDP:面向無連接的 不安全 但快
5.網(wǎng)絡(luò)中的數(shù)據(jù)傳輸:
Socket實現(xiàn)->套接字
Socket類:客戶端
ServerSocket:服務(wù)器端
- 讀取數(shù)據(jù):服務(wù)器讀取 客戶端讀取
BufferedReader->InputStreamReader->socket.getInputStream() - 讀取終端
BufferedReader->InputStreamReader->System.in - 輸出:客戶端輸出 服務(wù)器端輸出
BufferedWriter->OutputStreamWriter->socket.getOutputStream()
PrintStream->socket.getOutputStream()
三扯再、技術(shù)的使用
1.模擬客戶端
class Client{
public static void main(String[] args) throws IOException {
//1.創(chuàng)建用于通信的socket
// 指明和誰通信:ip地址 端口號
Socket socket=new Socket("127.0.0.1",8989);
// 接收服務(wù)器端的數(shù)據(jù)
BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//socket.getInputStream();
// 向服務(wù)器發(fā)送數(shù)據(jù)
//socket.getOutputStream();
String line=null;
while ((line=br.readLine())!=null){
System.out.println(line);
}
//客戶端向服務(wù)器端發(fā)送數(shù)據(jù)
PrintStream ps=new PrintStream(socket.getOutputStream());
ps.println("你好啊");
socket.shutdownOutput();
}
}
2.模擬服務(wù)器端
class Server{
public static void main(String[] args) throws IOException {
//1.創(chuàng)建服務(wù)器端的serversocket
ServerSocket ss=new ServerSocket(8989);
//2.獲取連接的客戶端的socket
Socket clientSocket=ss.accept();
//3.向客戶端發(fā)送數(shù)據(jù)
//BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
PrintStream ps=new PrintStream(clientSocket.getOutputStream());
ps.println("登錄成功");
//輸出完畢
clientSocket.shutdownOutput();
//4.服務(wù)器端接收客戶端發(fā)來的數(shù)據(jù)
BufferedReader br=new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
String line=null;
while ((line=br.readLine())!=null){
System.out.println(line);
}
}
}
3.實現(xiàn)上傳圖片
class Client{
public static void main(String[] args) throws IOException {
//連接服務(wù)器端 獲取socket
Socket socket=new Socket("127.0.0.1",8787);
//創(chuàng)建服務(wù)器端對應(yīng)的輸入流 用于接收服務(wù)器端發(fā)來的數(shù)據(jù)
BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
System.out.println(br.readLine());
//向服務(wù)器端發(fā)送文件(圖片)
//1.將文件寫入到內(nèi)存
String path="C:\\Users\\asus\\Desktop\\草圖1.png";
FileInputStream fis=new FileInputStream(path);
//2.創(chuàng)建字節(jié)流
BufferedOutputStream bos=new BufferedOutputStream(socket.getOutputStream());
byte[] buf=new byte[1024];
int len=-1;
while ((len=fis.read(buf))!=-1){
bos.write(buf,0,len);
}
socket.shutdownOutput();
}
}
class Server{
public static void main(String[] args) throws IOException {
//創(chuàng)建服務(wù)器端的ServerSocket
ServerSocket ss=new ServerSocket(8787);
//監(jiān)聽客戶端連接
//當有客戶端來連接這個服務(wù)器 就可以得到對應(yīng)的socket對象
//當沒有客戶端來連接 服務(wù)器一直在這里等待
Socket socket=ss.accept();
//創(chuàng)建客戶端對應(yīng)的輸出流 用于向這個客戶端發(fā)送數(shù)據(jù)
PrintStream ps=new PrintStream(socket.getOutputStream());
ps.println("連接成功 可以輸出數(shù)據(jù)了！");
BufferedInputStream bis=new BufferedInputStream(socket.getInputStream());
//文件對應(yīng)的輸出流
String path="C:\\Users\\asus\\Desktop\\Android\\Android Studio\\java\\src\\main\\java\\day12\\media\\草圖1.png";
FileOutputStream fos=new FileOutputStream(path);
byte[] buf=new byte[1024];
int len=-1;
while ((len=bis.read(buf))!=-1){
fos.write(buf,0,len);
}
}
}
四址遇、聊天功能的實現(xiàn)
1.對聊
（1）功能及實現(xiàn)方法
客戶端和服務(wù)器端都可以隨意地發(fā)送內(nèi)容
從終端輸入
- 客戶端:
主線程:接收終端輸入 將終端的輸入發(fā)送給服務(wù)器端
子線程:接收服務(wù)器端發(fā)來的數(shù)據(jù) - 服務(wù)器端:
主線程:接收終端輸入 將終端輸入發(fā)送給客服端
子線程:接收客戶端端發(fā)來的數(shù)據(jù)
（2）代碼實現(xiàn)
class Client{
public static void main(String[] args) throws IOException {
Socket socket=new Socket("127.0.0.1",9000);
//用一個子線程處理服務(wù)器端數(shù)據(jù)
new Thread(new ClientThread(socket)).start();
//主線程處理終端輸入 發(fā)送給服務(wù)器端
BufferedReader keyin=new BufferedReader(new InputStreamReader(System.in));
PrintStream ps=new PrintStream(socket.getOutputStream());
String line=null;
while ((line=keyin.readLine())!=null){
ps.println(line);
}
}
}
/**
* 創(chuàng)建一個子線程處理客戶端接收服務(wù)器端數(shù)據(jù)
*
*/
class ClientThread implements Runnable{
private Socket socket;
//保存操作的socket對象
public ClientThread(Socket socket){
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
//獲取服務(wù)器端的輸入流對象
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//讀取數(shù)據(jù)
String line=null;
while ((line=br.readLine())!=null){
System.out.println(line);
}
} catch (IOException e) {
System.out.println("網(wǎng)絡(luò)出錯 請重新登錄");
System.exit(-1);
}finally {
try {
if (br!=null){
br.close();
}
if (socket!=null){
socket.close();
}
}catch (IOException ex){
}
}
}
}
class Server{
public static void main(String[] args) throws IOException {
ServerSocket ss=new ServerSocket(9000);
//獲取客戶端的socket
Socket socket=ss.accept();
//創(chuàng)建子線程 處理客戶端輸入信息
new ServerThread(socket).start();
//終端輸入流對象
BufferedReader keyin=new BufferedReader(new InputStreamReader(System.in));
//客戶端的輸出流對象
PrintStream ps=new PrintStream(socket.getOutputStream());
//讀取終端的輸入 將輸入輸出給客戶端
String line=null;
while ((line=keyin.readLine())!=null){
ps.println(line);
}
}
}
/**
* 創(chuàng)建一個子線程處理服務(wù)器端接收客戶端的數(shù)據(jù)
*/
class ServerThread extends Thread{
private Socket socket;
public ServerThread(Socket socket){
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line=null;
while ((line=br.readLine())!=null){
System.out.println(line);
}
} catch (IOException e) {
System.out.println("網(wǎng)絡(luò)異常 請重新登錄");
System.exit(-1);
}finally {
//關(guān)閉輸入輸出流
//關(guān)閉對應(yīng)的socket鏈接
try {
if (br!=null){
br.close();
}
if (socket!=null){
socket.close();
}
}catch (IOException e){
e.printStackTrace();
}
}
}
}
2.群聊
（1）實現(xiàn)方法
在對聊的基礎(chǔ)上讓服務(wù)器端維護一個數(shù)組【socket】
（2）代碼實現(xiàn)
class Client{
public static void main(String[] args) throws IOException {
Socket socket=new Socket("10.129.28.253",6666);
//用一個子線程處理服務(wù)器端數(shù)據(jù)
new Thread(new ClientThread(socket)).start();
//主線程處理終端輸入 發(fā)送給服務(wù)器端
BufferedReader keyin=new BufferedReader(new InputStreamReader(System.in));
PrintStream ps=new PrintStream(socket.getOutputStream());
String line=null;
while ((line=keyin.readLine())!=null){
ps.println(line);
}
}
}
/**
* 創(chuàng)建一個子線程處理客戶端接收服務(wù)器端數(shù)據(jù)
*
*/
class ClientThread implements Runnable{
private Socket socket;
//保存操作的socket對象
public ClientThread(Socket socket){
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
//獲取服務(wù)器端的輸入流對象
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//讀取數(shù)據(jù)
String line=null;
while ((line=br.readLine())!=null){
System.out.println(line);
}
} catch (IOException e) {
System.out.println("網(wǎng)絡(luò)出錯 請重新登錄");
System.exit(-1);
}finally {
try {
if (br!=null){
br.close();
}
if (socket!=null){
socket.close();
}
}catch (IOException ex){
}
}
}
}
/**
* 1.如何實現(xiàn)群聊
* 在服務(wù)器端維護一個數(shù)組【socket】
* 2.私聊
* 3.給每個人起名字
*/
class Server{
//保存每一個鏈接過來的socket對象
public static ArrayList<Socket>sockets=new ArrayList<>();
public static void main(String[] args) throws IOException {
ServerSocket ss=new ServerSocket(7777);
//不停的等待客戶端來連接
while (true) {
Socket socket = ss.accept();
//當有客戶端連接過來了 就保存
sockets.add(socket);
//開啟一個線程處理每一個客戶端的輸入
new ServerThread(socket).start();
}
}
}
/**
* 創(chuàng)建一個子線程處理服務(wù)器端接收客戶端的數(shù)據(jù)
*/
class ServerThread extends Thread{
private Socket socket;
public ServerThread(Socket socket){
this.socket=socket;
}
@Override
public void run() {
BufferedReader br=null;
try {
br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line=null;
while ((line=br.readLine())!=null){
//群發(fā)消息
//遍歷Server維護的數(shù)組
for (Socket s:Server.sockets){
//向socket對應(yīng)的客戶端發(fā)送消息
PrintStream ps=new PrintStream(s.getOutputStream());
ps.println(line);
}
}
} catch (IOException e) {
System.out.println("網(wǎng)絡(luò)異常 請重新登錄");
System.exit(-1);
}finally {
//關(guān)閉輸入輸出流
//關(guān)閉對應(yīng)的socket鏈接
try {
if (br!=null){
br.close();
}
if (socket!=null){
socket.close();
}
}catch (IOException e){
e.printStackTrace();
}
}
}
}
