การวิเคราะห์การประยุกต์ใช้การสื่อสารเครือข่ายโดยอาศัยการทบทวนจาวา

โมฆะคงที่สาธารณะ main (String [] args) พ่น IOException
-
ซ็อกเก็ตซ็อกเก็ต = null;
BufferedReader br = null;
PrintWriter pw = null;
BufferedReader brTemp = null;
พยายาม
-
ซ็อกเก็ต = ซ็อกเก็ตใหม่ (InetAddress.getLocalHost(), 5678);
br = ใหม่ BufferedReader (InputStreamReader ใหม่ (socket.getInputStream ()));
pw = PrintWriter ใหม่ (socket.getOutputStream());
brTemp = BufferedReader ใหม่ (InputStreamReader ใหม่ (System.in));
ในขณะที่(จริง)
-
เส้นสตริง = brTemp.readLine();
pw.println(บรรทัด);
pw.ฟลัช();
ถ้า (line.equals("end")) แตก;
System.out.println(br.readLine());
-
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
ในที่สุด
-
ถ้า (ซ็อกเก็ต != null) socket.close();
ถ้า (br != null) br.close();
ถ้า (brTemp != null) brTemp.close();
ถ้า (pw != null) pw.close();
-
-
-

โมฆะคงที่สาธารณะ main (String [] args) พ่น IOException
-
เซิร์ฟเวอร์ ServerSocket = null;
ไคลเอนต์ซ็อกเก็ต = null;
BufferedReader br = null;
PrintWriter pw = null;
พยายาม
-
เซิร์ฟเวอร์ = ServerSocket ใหม่ (5678);
ลูกค้า = เซิร์ฟเวอร์ยอมรับ ();
br = ใหม่ BufferedReader (InputStreamReader ใหม่ (client.getInputStream ()));
pw = PrintWriter ใหม่ (client.getOutputStream());
ในขณะที่(จริง)
-
เส้นสตริง = br.readLine();
pw.println("การตอบสนอง:" + บรรทัด);
pw.ฟลัช();
ถ้า (line.equals("end")) แตก;
-
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
ในที่สุด
-
ถ้า (เซิร์ฟเวอร์ != null) server.close();
ถ้า (ไคลเอนต์ != null) client.close();
ถ้า (br != null) br.close();
ถ้า (pw != null) pw.close();
-
-
-

คลาส ServerThread ขยายเธรด
-
ซ็อกเก็ตซ็อกเก็ตส่วนตัว = null;

ServerThread สาธารณะ (ซ็อกเก็ตซ็อกเก็ต)
-
this.socket = ซ็อกเก็ต;
-

โมฆะสาธารณะวิ่ง () {
BufferedReader br = null;
PrintWriter pw = null;
พยายาม
-
br = ใหม่ BufferedReader (InputStreamReader ใหม่ (socket.getInputStream ()));
pw = PrintWriter ใหม่ (socket.getOutputStream());
ในขณะที่(จริง)
-
เส้นสตริง = br.readLine();
pw.println("การตอบสนอง:" + บรรทัด);
pw.ฟลัช();
ถ้า (line.equals("end")) แตก;
-
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
ในที่สุด
-
ถ้า (ซ็อกเก็ต != null)
พยายาม {
ซ็อกเก็ต.ปิด();
} จับ (IOException e1) {
e1.printStackTrace();
-
ถ้า (br != null)
พยายาม {
br.ปิด();
} จับ (IOException จ) {
e.printStackTrace();
-
ถ้า (pw != null) pw.close();
-
-
-

ที่อยู่ InetAddress ส่วนตัว = null;
พอร์ต int ส่วนตัว
ซ็อกเก็ตส่วนตัว [] arrSockets = null;
บูลีนส่วนตัว [] arrStatus = null;
จำนวน int ส่วนตัว

TcpConnectionPool สาธารณะ (ที่อยู่ InetAddress, พอร์ต int, จำนวน int)
-
this.address = ที่อยู่;
this.port = พอร์ต;
นี้ .count = นับ;
arrSockets = ซ็อกเก็ตใหม่ [นับ];
arrStatus = บูลีนใหม่ [นับ];

เริ่มต้น();
-

โมฆะส่วนตัว init()
-
พยายาม
-
สำหรับ (int i = 0; i < นับ; i++)
-
arrSockets[i] = ซ็อกเก็ตใหม่ (address.getHostAddress(), พอร์ต);
arrStatus[i] = เท็จ;
-
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
-

สาธารณะซ็อกเก็ต getConnection ()
-
ถ้า (arrSockets == null) init();
อินท์ i = 0;
สำหรับ(i = 0; i <นับ; i++)
-
ถ้า (arrStatus[i] == เท็จ)
-
arrStatus[i] = จริง;
หยุดพัก;
-
-
ถ้า (i == นับ) โยน RuntimeException ใหม่ ("ไม่มีการเชื่อมต่อในขณะนี้");

กลับ arrSockets [i];
-

การเชื่อมต่อการปล่อยโมฆะสาธารณะ (ซ็อกเก็ตซ็อกเก็ต)
-
ถ้า (arrSockets == null) init();
สำหรับ (int i = 0; i < นับ; i++)
-
ถ้า (arrSockets[i] == ซ็อกเก็ต)
-
arrStatus[i] = เท็จ;
หยุดพัก;
-
-
-

โมฆะสาธารณะ reBuild()
-
เริ่มต้น();
-

โมฆะสาธารณะทำลาย ()
-
ถ้า (arrSockets == null) กลับมา;

สำหรับ (int i = 0; i < นับ; i ++)
-
พยายาม
-
arrSockets[i].ปิด();
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
ดำเนินการต่อ;
-
-
-
-

โมฆะสาธารณะคง main (String [] args)
-
พยายาม
-
โฮสต์ InetAddress = InetAddress.getLocalHost();
พอร์ต int = 5678;
BufferedReader br = BufferedReader ใหม่ (InputStreamReader ใหม่ (System.in));
ในขณะที่(จริง)
-
เส้นสตริง = br.readLine();
ข้อความไบต์ [] = line.getBytes();
DatagramPacket packet = DatagramPacket ใหม่ (ข้อความ, message.length, โฮสต์, พอร์ต);
ซ็อกเก็ต DatagramSocket = DatagramSocket ใหม่ ();
socket.send (แพ็คเก็ต);
ซ็อกเก็ต.ปิด();
ถ้า (line.equals("end")) แตก;
-
br.ปิด();
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
-
-

โมฆะสาธารณะคง main (String [] args)
-
พยายาม
-
พอร์ต int = 5678;
DatagramSocket dsSocket = DatagramSocket ใหม่ (พอร์ต);
ไบต์ [] บัฟเฟอร์ = ไบต์ใหม่ [1024];
แพ็กเก็ต DatagramPacket = DatagramPacket ใหม่ (บัฟเฟอร์, buffer.length);
ในขณะที่(จริง)
-
dsSocket.receive (แพ็กเก็ต);
ข้อความสตริง = สตริงใหม่ (บัฟเฟอร์, 0, packet.getLength ());
System.out.println(packet.getAddress().getHostName() + /// + ข้อความ);
ถ้า (message.equals("end")) พัง;
packet.setLength(บัฟเฟอร์.ความยาว);
-
dsSocket.ปิด();
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
-
-

โมฆะสาธารณะคง main (String [] args)
-
BufferedReader br = BufferedReader ใหม่ (InputStreamReader ใหม่ (System.in));
พยายาม
-
ที่อยู่ InetAddress = InetAddress.getByName("230.0.0.1");
พอร์ต int = 5678;
ในขณะที่(จริง)
-
เส้นสตริง = br.readLine();
ข้อความไบต์ [] = line.getBytes();
DatagramPacket packet = DatagramPacket ใหม่ (ข้อความ, message.length, ที่อยู่, พอร์ต);
MulticastSocket multicastSocket = MulticastSocket ใหม่ ();
multicastSocket.send (แพ็กเก็ต);
ถ้า (line.equals("end")) แตก;
-
br.ปิด();
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
-
-

โมฆะสาธารณะคง main (String [] args)
-
พอร์ต int = 5678;
พยายาม
-
MulticastSocket multicastSocket = MulticastSocket ใหม่ (พอร์ต);
ที่อยู่ InetAddress = InetAddress.getByName("230.0.0.1");
multicastSocket.joinGroup (ที่อยู่);
ไบต์ [] บัฟเฟอร์ = ไบต์ใหม่ [1024];
แพ็กเก็ต DatagramPacket = DatagramPacket ใหม่ (บัฟเฟอร์, buffer.length);
ในขณะที่(จริง)
-
multicastSocket.receive (แพ็กเก็ต);
ข้อความสตริง = สตริงใหม่ (บัฟเฟอร์, packet.getLength());
System.out.println(packet.getAddress().getHostName() + /// + ข้อความ);
ถ้า (message.equals("end")) พัง;
packet.setLength(บัฟเฟอร์.ความยาว);
-
multicastSocket.close();
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
-
-

โมฆะสาธารณะคง main (String [] args)
-
โฮสต์สตริง = "127.0.0.1";
พอร์ต int = 5678;
ช่อง SocketChannel = null;
พยายาม
-
ที่อยู่ InetSocketAddress = InetSocketAddress ใหม่ (โฮสต์, พอร์ต);
ชุดอักขระ ชุดอักขระ = Charset.forName("UTF-8");
ตัวถอดรหัส CharsetDecoder = charset.newDecoder();
ตัวเข้ารหัส CharsetEncoder = charset.newEncoder();

ByteBuffer buffer = ByteBuffer.allocate (1024);
CharBuffer charBuffer = CharBuffer.จัดสรร (1024);

ช่อง = SocketChannel.open();
ช่องเชื่อมต่อ(ที่อยู่);

คำขอสตริง = "GET / /r/n/r/n";
channel.write(encoder.encode(CharBuffer.wrap(คำขอ)));

ในขณะที่ ((channel.read(buffer)) != -1)
-
buffer.พลิก();
decoder.decode (บัฟเฟอร์, charBuffer, เท็จ);
charBuffer.flip();
System.out.println(charBuffer);
บัฟเฟอร์.ชัดเจน();
charBuffer.clear();
-
-
จับ (ข้อยกเว้นเช่น)
-
System.err.println(เช่นgetMessage());
-
ในที่สุด
-
ถ้า (ช่อง != null)
พยายาม {
ช่อง.ปิด();
} จับ (IOException จ) {
// TODO บล็อก catch ที่สร้างขึ้นอัตโนมัติ
e.printStackTrace();
-
-
-
-