1. 首页
  2. JAVA
  3. Java Socket通信原理简介

Java Socket通信原理简介

•java•阅读 4466

java socket通信已经被封装好了主要使用两个类ServerSocket 和Socket

首先写一个1v1的通信

服务端

[java]view plaincopy

  1. /**
  2. *
  3. */
  4. package com.dnion.socket;
  5. import java.io.BufferedReader;
  6. import java.io.BufferedWriter;
  7. import java.io.InputStreamReader;
  8. import java.io.OutputStreamWriter;
  9. import java.io.PrintWriter;
  10. import java.net.ServerSocket;
  11. import java.net.Socket;
  12. /**
  13. ***************************************************************
  14. * 项目名称：JavaThread
  15. * 程序名称：JabberServer
  16. * 日期：2012-8-23 上午11:36:12
  17. * 作者：
  18. * 模块：
  19. * 描述：
  20. * 备注：
  21. * ------------------------------------------------------------
  22. * 修改历史
  23. * 序号 日期 修改人 修改原因
  24. *
  25. * 修改备注：
  26. * @version
  27. ***************************************************************
  28. */
  29. public class JabberServer {
  30. public static int PORT = 8080;
  31. public static void main(String[] agrs) {
  32. ServerSocket s = null;
  33. Socket socket = null;
  34. BufferedReader br = null;
  35. PrintWriter pw = null;
  36. try {
  37. //设定服务端的端口号
  38. s = new ServerSocket(PORT);
  39. System.out.println("ServerSocket Start:"+s);
  40. //等待请求,此方法会一直阻塞,直到获得请求才往下走
  41. socket = s.accept();
  42. System.out.println("Connection accept socket:"+socket);
  43. //用于接收客户端发来的请求
  44. br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  45. //用于发送返回信息,可以不需要装饰这么多io流使用缓冲流时发送数据要注意调用.flush()方法
  46. pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
  47. while(true){
  48. String str = br.readLine();
  49. if(str.equals("END")){
  50. break;
  51. }
  52. System.out.println("Client Socket Message:"+str);
  53. Thread.sleep(1000);
  54. pw.println("Message Received");
  55. pw.flush();
  56. }
  57. } catch (Exception e) {
  58. // TODO Auto-generated catch block
  59. e.printStackTrace();
  60. }finally{
  61. System.out.println("Close.....");
  62. try {
  63. br.close();
  64. pw.close();
  65. socket.close();
  66. s.close();
  67. } catch (Exception e2) {
  68. }
  69. }
  70. }
  71. }

客户端

[java]view plaincopy

  1. /**
  2. *
  3. */
  4. package com.dnion.socket;
  5. import java.io.BufferedReader;
  6. import java.io.BufferedWriter;
  7. import java.io.IOException;
  8. import java.io.InputStreamReader;
  9. import java.io.OutputStreamWriter;
  10. import java.io.PrintWriter;
  11. import java.net.Socket;
  12. /**
  13. ***************************************************************
  14. * 项目名称：JavaThread 程序名称：JabberClient 日期：2012-8-23 下午01:47:12
  15. * 作者：
  16. * 模块：
  17. * 描述：
  18. * 备注：
  19. * ------------------------------------------------------------
  20. * 修改历史
  21. * 序号
  22. * 日期
  23. * 修改人
  24. * 修改原因
  25. * 修改备注：
  26. *
  27. * @version
  28. ***************************************************************
  29. */
  30. public class JabberClient {
  31. /**
  32. * 方法名：main 描述： 作者：白鹏飞 日期：2012-8-23 下午01:47:12
  33. *
  34. * @param @param args
  35. * @return void
  36. */
  37. public static void main(String[] args) {
  38. Socket socket = null;
  39. BufferedReader br = null;
  40. PrintWriter pw = null;
  41. try {
  42. //客户端socket指定服务器的地址和端口号
  43. socket = new Socket("127.0.0.1", JabberServer.PORT);
  44. System.out.println("Socket=" + socket);
  45. //同服务器原理一样
  46. br = new BufferedReader(new InputStreamReader(
  47. socket.getInputStream()));
  48. pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
  49. socket.getOutputStream())));
  50. for (int i = 0; i < 10; i++) {
  51. pw.println("howdy " + i);
  52. pw.flush();
  53. String str = br.readLine();
  54. System.out.println(str);
  55. }
  56. pw.println("END");
  57. pw.flush();
  58. } catch (Exception e) {
  59. e.printStackTrace();
  60. } finally {
  61. try {
  62. System.out.println("close......");
  63. br.close();
  64. pw.close();
  65. socket.close();
  66. } catch (IOException e) {
  67. // TODO Auto-generated catch block
  68. e.printStackTrace();
  69. }
  70. }
  71. }
  72. }

这样一个简单地通信就完成了,这里我们要注意现在只能一对一通信。下面我们将使用多线程来实现多客户端通信的例子。

写一个一对多的通信,这里我们使用java的多线程来实现

首先来看一下服务类

[java]view plaincopy

  1. /**
  2. *
  3. */
  4. package com.dnion.socket;
  5. import java.io.IOException;
  6. import java.net.ServerSocket;
  7. import java.net.Socket;
  8. /**
  9. ***************************************************************
  10. * 项目名称：JavaThread
  11. * 程序名称：MultiJabberServer
  12. * 日期：2012-8-23 下午02:38:20
  13. * 作者：
  14. * 模块：
  15. * 描述：
  16. * 备注：
  17. * ------------------------------------------------------------
  18. * 修改历史
  19. * 序号 日期 修改人 修改原因
  20. *
  21. * 修改备注：
  22. * @version
  23. ***************************************************************
  24. */
  25. public class MultiJabberServer {
  26. /**
  27. * 方法名：main
  28. * 描述：
  29. * 作者：
  30. * 日期：2012-8-23 下午02:38:20
  31. * @param @param args
  32. * @return void
  33. */
  34. public static void main(String[] args) {
  35. ServerSocket s = null;
  36. Socket socket = null;
  37. try {
  38. s = new ServerSocket(8080);
  39. //等待新请求、否则一直阻塞
  40. while(true){
  41. socket = s.accept();
  42. System.out.println("socket:"+socket);
  43. new ServeOneJabbr(socket);
  44. }
  45. } catch (Exception e) {
  46. try {
  47. socket.close();
  48. } catch (IOException e1) {
  49. // TODO Auto-generated catch block
  50. e1.printStackTrace();
  51. }
  52. }finally{
  53. try {
  54. s.close();
  55. } catch (IOException e) {
  56. // TODO Auto-generated catch block
  57. e.printStackTrace();
  58. }
  59. }
  60. }
  61. }

接着我们要写一个服务端响应请求的类也就是一个socket

[java]view plaincopy

  1. /**
  2. *
  3. */
  4. package com.dnion.socket;
  5. import java.io.BufferedReader;
  6. import java.io.BufferedWriter;
  7. import java.io.IOException;
  8. import java.io.InputStreamReader;
  9. import java.io.OutputStreamWriter;
  10. import java.io.PrintWriter;
  11. import java.net.Socket;
  12. /**
  13. ***************************************************************
  14. * 项目名称：JavaThread
  15. * 程序名称：ServeOneJabbr
  16. * 日期：2012-8-23 下午02:34:13
  17. * 作者：
  18. * 模块：
  19. * 描述：
  20. * 备注：
  21. * ------------------------------------------------------------
  22. * 修改历史
  23. * 序号 日期 修改人 修改原因
  24. *
  25. * 修改备注：
  26. * @version
  27. ***************************************************************
  28. */
  29. public class ServeOneJabbr extends Thread{
  30. private Socket socket = null;
  31. private BufferedReader br = null;
  32. private PrintWriter pw = null;
  33. public ServeOneJabbr(Socket s){
  34. socket = s;
  35. try {
  36. br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  37. pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
  38. start();
  39. } catch (Exception e) {
  40. e.printStackTrace();
  41. }
  42. }
  43. @Override
  44. public void run() {
  45. while(true){
  46. String str;
  47. try {
  48. str = br.readLine();
  49. if(str.equals("END")){
  50. br.close();
  51. pw.close();
  52. socket.close();
  53. break;
  54. }
  55. System.out.println("Client Socket Message:"+str);
  56. pw.println("Message Received");
  57. pw.flush();
  58. } catch (Exception e) {
  59. try {
  60. br.close();
  61. pw.close();
  62. socket.close();
  63. } catch (IOException e1) {
  64. // TODO Auto-generated catch block
  65. e1.printStackTrace();
  66. }
  67. }
  68. }
  69. }
  70. }

接下来利用我们上一次的客户端socket

[java]view plaincopy

  1. /**
  2. *
  3. */
  4. package com.dnion.socket;
  5. import java.io.BufferedReader;
  6. import java.io.BufferedWriter;
  7. import java.io.IOException;
  8. import java.io.InputStreamReader;
  9. import java.io.OutputStreamWriter;
  10. import java.io.PrintWriter;
  11. import java.net.Socket;
  12. /**
  13. ***************************************************************
  14. * 项目名称：JavaThread 程序名称：JabberClient 日期：2012-8-23 下午01:47:12
  15. * 作者：
  16. * 模块：
  17. * 描述：
  18. * 备注：
  19. * ------------------------------------------------------------
  20. * 修改历史
  21. * 序号
  22. * 日期
  23. * 修改人
  24. * 修改原因
  25. * 修改备注：
  26. *
  27. * @version
  28. ***************************************************************
  29. */
  30. public class JabberClient {
  31. /**
  32. * 方法名：main 描述： 作者：白鹏飞 日期：2012-8-23 下午01:47:12
  33. *
  34. * @param @param args
  35. * @return void
  36. */
  37. public static void main(String[] args) {
  38. Socket socket = null;
  39. BufferedReader br = null;
  40. PrintWriter pw = null;
  41. try {
  42. //客户端socket指定服务器的地址和端口号
  43. socket = new Socket("127.0.0.1", JabberServer.PORT);
  44. System.out.println("Socket=" + socket);
  45. //同服务器原理一样
  46. br = new BufferedReader(new InputStreamReader(
  47. socket.getInputStream()));
  48. pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
  49. socket.getOutputStream())));
  50. for (int i = 0; i < 10; i++) {
  51. pw.println("howdy " + i);
  52. pw.flush();
  53. String str = br.readLine();
  54. System.out.println(str);
  55. }
  56. pw.println("END");
  57. pw.flush();
  58. } catch (Exception e) {
  59. e.printStackTrace();
  60. } finally {
  61. try {
  62. System.out.println("close......");
  63. br.close();
  64. pw.close();
  65. socket.close();
  66. } catch (IOException e) {
  67. // TODO Auto-generated catch block
  68. e.printStackTrace();
  69. }
  70. }
  71. }
  72. }

这样一个简单地多客户端响应socket就成了

每次有一个请求发送过来服务端都会新建一个线程来单独服务。

相关推荐

Copyright © 2008-2024渝ICP备2022006305号-5.

本站所有数据收集于网络如有侵犯到您的权益请联系，进行下架处理。