小奥的学习笔记

  • Home
  • Learning & Working
    • Speech Enhancement Notes
    • Programming language
    • Computer & DL
    • MOOC
  • Life
    • Life Time
    • Thinking & Comprehension
    • Volunteer
    • Plan
    • Travel
  • Footprints
  • GuestBook
  • About
    • About Me
    • 个人履历
    • 隐私策略
  1. 首页
  2. Study-notes
  3. Programming language
  4. Java
  5. 正文

Java语言程序设计(进阶)(第五章)整理

2018年4月7日 1423点热度 0人点赞 0条评论

第五章:网络编程(下)

1.Socket多客户端通信实现

1.客户端程序代码:

客户端代码与第四章中客户端代码相同,不再累述。

2.服务器端程序代码:

//MultiTalkeServer.java文件
import java.io.*;
import java.net.*;
 
public class MultiTalkServer {
       static int clientnum = 0;//统计客户端数量
 
       public static void main(String[] args) throws IOException {
              // TODO Auto-generated method stub
              ServerSocket server = null;//声明一个serversocket对象
              boolean listening = true;
              try {
                            server = 
                            new ServerSocket(4700);
                     }catch(IOException e) {
                    System.out.println("could not listen on port:4700" );
                     }
                     Socket socket = null;
                     try {
                            socket = server.accept();
                     }catch(Exception e) {
                            System.out.println("Error."+e);
                            System.exit(-1);
                     }
                     while(listening)
                     {
                            new ServerThread(serverSocket.accept(),
clientnum).start();
                            clientnum++;
                     }
                     serverSocket.close();
       }
}
//ServerThread.java文件代码
import java.io.*;
import java.net.*;
 
public class ServerThread extends Thread {
       Socket socket = null;
       int clientnum;
       public ServerThread(Socket socket, int num){
              this.socket = socket;
              clientnum = num+1;
       }
       public void run(){
              try{
                     //下面开始通信。
                     String line;
                     BufferedReader is = new BufferedReader
(new InputStreamReader(socket.getInputStream()));
                     PrintWriter os =new PrintWriter
                     (socket.getOutputStream());
                     BufferedReader sin = new BufferedReader
(new InputStreamReader(System.in));
                     System.out.println("Client:" + clientnum + ":"
                      + is.readLine());
                     line =sin.readLine();
                     while(!line.equals("bye"))
                     {
                            os.println(line);
                            os.flush();
                                                
                            //下面是打印客户端和服务器端发送的信息
                            System.out.println("Server:"+ line);
                            System.out.println("Client:"+ clientnum
+":" + is.readLine());
                            line = sin.readLine();
                     }
                     os.close();
                     is.close();
                     socket.close();
              }catch(Exception e) {\
                     System.out.println("Error:"+e);
              }
       }
 
}

2.数据报通信

数据包通信采用的是UDP(User Datagram Protocol),它是非面向连接的,提供不可靠的数据包式的数据传说的协议,类似于从邮局发送信件的过程。Java中的DatagramPacket/DatagramSocket/MulticastSocket等累使用UDP协议进行网络通信。

TCP(Transport Control Protocol)是面向对接的能够提供可靠的流式数据传输的协议。Java中的ULR/URLConnection/socket/serverSocket等类使用TCP协议进行网络通信。

1.TCP和UDP的区别

(1)TCP有建立时间,UDP没有;

(2)UDP传输限制包在64k以内;

(3)TCP的应用有Telnet、FTP等,UDP的应用有ping等。

2.Java中进行数据报通信

所用的类有:

①DatagramSocket()//只允许数据报发往一个目的地址

②DatagramSocket(int port)

③DatagramPacket(byte ibuf[], int ilength)//接受

④DatagramPacket(byte ibuf[], int ilength, InetAdress iaddr, int iport);//发送

收数据报:

DatagramPacket packet = new DatagramPacket(buf, 256);
socket.receive(packet);

发数据报:

DatagramPacket packet = new DatagramPacket(buf, buf.length,address,port);
socket.send(packet);

例:客户方程序QuoteClient.java

代码:

import java.io.*;
import java.net.*;
import java.util.*;
public class QuoteClient {
       public static void main(String[] args) throws IOException{
              if(args.length!=1){//如果没有参数的执行内容
                     System.out.println("Usage:java QuoteClient<hostname");
                     return
              }
              DatagramPacket packet = new DatagramPacket();
              //send request
              byte[] buf = new byte[256];
              InetAddress address = InetAddress.getByName(args[0]);
              DatagramPacket packet = new
 DatagramPacket(buf, buf.length,address,4445);
              socket.send(packet);
              //get response
               packet = new DatagramPacket(buf, buf.length);
               socket.receive(packet);
               //display response
               String received = new String(packet.getData());
               System.out.println("Quote of the Moment:" +received);
               socket.close();
       }
}

例:服务器方程序QuoteServer.java

代码:

public class QuoteServer{
       public static void main(String[] args) throws java.io.IOException{
              new QuoteServerThread().start();
       }
}

例:服务器方程序QuoteServerThread.java

代码:

import java.io.*;
import java.net.*;
import java.util.*;
public class QuoteServerThread extends Thread {
       protected DatagramSocket socket = null;
       protected BufferedReader in =null;
       protected boolean moreQuotes = true;
       public QuoteServerThread() throws IOException{
              this("QuoteServerThread");
       }
       public QuoteServerThread(String name) throws IOException{
              super(name);
              socket  = new DatagramSocket(4445);
              try{
                     in = new BufferedReader(new FileReader("one-liners.txt"));
              }catch(FileNotFoundException e){
                     System.err.println
("Counldnot open quote file.Serving time instead.");
              }
       }
       public void run(){
              while(moreQuotes){
                     try{
                            byte[] buf =new byte[256];
                            DatagramPacket packet =
new DatagramPacket(buf,buf.length);
                            socket.receive(packet);
                            String dString = null;
                            if(in==null)
                                   dString = new Date().toString();
                            else dString = getNextQuote();
                            buf =dString.getBytes();
                            //send the response to the client at "address"
                            //and "port"
                            InetAddress address = packet.getAddress();
                            int port = packet.getPort();
                            packet =
new DatagramPacket(buf,buf.length,address,port);
                            socket.send(packet);
                     }catch(IOException e){
                            e.printStackTrace();
                            moreQuotes=false;
                     }
              }
              socket.close();
       }
       protected String getNextQuote(){
              String returnValue = null;
              try{
                     if((returnValue=in.readLine())==null){
                            in.close();
                            moreQuotes=false;
                            returnValue = "No more quotes.Goodbye.";
                     }catch(IOException e){
                            returnValue="IOException occurred in server";
                     }
                     return returnValue;
              }
       }
}

      

 

3.使用数据报进行广播通信

MulticastSocket讲数据报以广播方式发送到该端口的所有客户。

例:客户方程序MulticastClient.java

代码:

import java.io.*;
import java.net.*;
import java.util.*;
public class MulticastClient {
       public static void main(String[] args) throws IOException{
              MulticastSocket socket = new MulticastSocket(4446);
              InetAddress address = InetAddress.getName("230.0.0.1");
              socket.joinGroup(address);
              DatagramPacket packet;
              //get a few quotes
              for(int i = 0;i<5;i++){
                     byte[] buf = new byte[256];
                     packet = new DatagramPacket(buf,buf.length);
                     socket.receive(packet);
                     String received = new String(packet.getData());
                     System.out.println
("Quote of the Moment:" +received);
              }
              socket.leaveGroup(address);
              socket.close();
       }
}

例:客户方程序MulticastServer.java

代码:

public class MulticastServer{
       public static void main(String args[])
 throws java.io.IOException{
              new MulticastServerThread().start();
       }
}

例:服务器方程序QuoteServerThread.java

代码:

import java.io.*;
import java.net.*;
import java.util.*;
public class MulticasterverThread extends Thread {
       private long FIVE_SECOND=5000;
       public MulticastServerThread() throws IOException{
              super("MulticastServerThread");
       }
       public void run(){
              while(moreQuotes){
                     try{
                            byte[] buf = new byte[256];
                            //construct quote
                            String dString = null;
                            if(in==null)
                                   dString = new Date().toString();
                            else dString = getNextQuote();
                            buf =dString.getBytes();
                            //send it
                            InetAddress group =
InetAddress.getByName("230.0.0.1");
                            DatagramPacket pacet = new
DatagramPacket(buf,buf.length,group,4446);
                            socket.send(packet);
                            //sleep for a while
                            try{
                                   sleep((long)(Math.random()*FIVE_SECOND));
                            }catch(InterruptedException e){}
                     }catch(IOException e){
                            e.printStackTrace();
                            moreQuotes=false;
                     }
              }
              socket.close();
       }
}
本作品采用 知识共享署名 4.0 国际许可协议 进行许可
标签: Java
最后更新:2018年4月7日

davidcheung

这个人很懒,什么都没留下

打赏 点赞
< 上一篇
下一篇 >

文章评论

razz evil exclaim smile redface biggrin eek confused idea lol mad twisted rolleyes wink cool arrow neutral cry mrgreen drooling persevering
取消回复

搜索
欢迎关注我的个人公众号
最新 热点 随机
最新 热点 随机
DEEPFILTERNET:一种基于深度滤波的全频带音频低复杂度语音增强框架 奥地利匈牙利九日游旅程 论文阅读之Study of the General Kalman Filter for Echo Cancellation 小奥看房之鸿荣源珈誉府 杭州往返旅途及西溪喜来登和万怡的体验报告 2022年的第一篇碎碎念
奥地利匈牙利九日游旅程论文阅读之Study of the General Kalman Filter for Echo CancellationDEEPFILTERNET:一种基于深度滤波的全频带音频低复杂度语音增强框架
上高中之后博客的一些安排 《鸟哥的Linux私房菜》(基础篇)笔记整理(第8章) 新建济南至莱芜高速铁路项目环境影响评价信息公示 坚持,相信这个社会会是正义的 关于谷歌中国的最新声明 iNove新春2010主题[本博客2010新年主题]
标签聚合
leetcode Java Python 学习 linux 鸟哥的linux私房菜 高中 算法 生活 python学习
最近评论
davidcheung 发布于 5 个月前(02月09日) The problem has been fixed. May I ask if you can s...
tk88 发布于 5 个月前(02月07日) Hmm is anyone else having problems with the pictur...
cuicui 发布于 9 个月前(10月20日) :wink:
niming 发布于 10 个月前(09月19日) 同级校友,能刷到太巧了
davidcheung 发布于 2 年前(08月16日) 我得找一下我之前整理的word文档看一下,如果找到了我就更新一下这篇文章。
Nolan 发布于 2 年前(07月25日) 您的笔记非常有帮助。贴图不显示了,可以更新一下吗?
davidcheung 发布于 3 年前(06月19日) 到没有看webrtc的代码。现在主要在看我们公司的代码了。。。只是偶尔看一看webrtc的东西。。。
aobai 发布于 3 年前(03月13日) gain_change_hangover_ 应该是每三个block 只能够调整一次,这样保证每帧...
匿名 发布于 5 年前(12月30日) 烫
小奥 发布于 5 年前(12月12日) webRTC里面的NS本身我记得就是在C++里面呀

COPYRIGHT © 2025 小奥的学习笔记. ALL RIGHTS RESERVED.

Theme Kratos Made By Seaton Jiang

陕ICP备19003234号-1

鲁公网安备37120202000100号