Java Socket编程 - 简单的问候服务实现

简介: Java Socket编程 - 简单的问候服务实现

服务器端:


实现一个最简单的Hello服务,打印输出客户端IP地址到控制台,对任何连接的客户端都


会发送一串字符(Hello, Java Socket)然后关闭与客户端连接。等待下一个客户端的连接


请求到来。


客户端:


实现一个最简单的Socket连接到Hello服务器端,接受服务器端发送过来的字节数据


打印并输出内容到控制台。


关键技巧:


由于JAVA中提供非常多的输入与输出流API,导致很多初学者接触JAVA SOCKET编程


时,由于对网络字节通信的本质缺乏了解,直接一个readline()去接受Socket字节流。


但是由于发送一方并没有发送/r/n导致一直无法读到数据,这个是最常见的一个错误。


另外一些常见的错误包括没有初始化接受缓冲区导致字符乱码,没有按照读入接受到


字节数重新组装,导致接受到的数据异常。所以代码演示了什么叫按字节发送与按字


节接受,这个是网络编程中非常重要的概念与原则。让那些输入流println()方法与输


出流readline()方法见鬼去吧,不是不好用,而是我建议你不要用,因为那些会妨碍你


的网络编程本质的认识与理解。另外我要特别说明一下:有时候flush()真的不是必须的


除非你使用了带有缓冲的输入与输出流来读写字节。


服务器端代码:

package com.gloomyfish.socket.tutorial.two;
 
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
 
public class HelloService extends Thread {
  private ServerSocket serverSocket;
  public HelloService(int port) throws IOException {
    serverSocket = new ServerSocket(port);
  }
 
  public void run()
  {
    try {
      while(true)
      {
        System.out.println("Waiting for client on port " + serverSocket.getLocalPort());
        Socket client = serverSocket.accept(); // blocked & waiting for income socket
        System.out.println("Just connected to " + client.getRemoteSocketAddress());
        DataOutputStream dos = new DataOutputStream(client.getOutputStream());
        byte[] hello = "Hello, Java Socket".getBytes();
        dos.write(hello, 0, hello.length);
        dos.close();
        client.close();
      }
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
  
  public static void main(String[] args) {
    try {
      HelloService service = new HelloService(9999);
      service.start();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

服务器在端口9999监听并等待连接,使用Java Thread来实现服务器端启动。

客户端代码如下:

package com.gloomyfish.socket.tutorial.two;
 
import java.io.DataInputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
 
public class HelloClient {
  private int clientNumber;
  private SocketAddress address;
  public HelloClient(int clientNum) {
    clientNumber = clientNum;
  }
  
  public void setupClients(String serverHostName, int port) throws IOException {
    address = new InetSocketAddress(serverHostName, port);
    for(int i=0; i<clientNumber; i++) {
      System.out.println();
      System.out.println("start client No. " + (i+1));
      Socket socket = new Socket();
      socket.connect(address);
      DataInputStream bufferedReader = new DataInputStream(socket.getInputStream());
      byte[] cbuff = new byte[256];
      char[] charBuff = new char[256];
      int size = 0;
      while( (size = bufferedReader.read(cbuff))> 0) {
        convertByteToChar(cbuff, charBuff, size);
        System.out.println(charBuff);
      }
      bufferedReader.close();
      socket.close();
    }
  }
  
  private void convertByteToChar(byte[] cbuff, char[] charBuff, int size) {
    for(int i=0; i<charBuff.length; i++) {
      if(i < size) {
        charBuff[i] = (char)cbuff[i];
      } else {
        charBuff[i] = ' ';
      }
    }
    
  }
 
  public static void main(String[] args) {
    try {
      HelloClient client = new HelloClient(10);
      client.setupClients("localhost", 9999);
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

启动10个客户端去连接服务器端,接受到服务器端问候以后客户端关闭连接。

特别提示:一定要初始化缓冲区charBuff
程序运行结果:

1351869919_5928.png

相关文章
|
1天前
|
安全 Java 调度
Java并发编程:优化多线程应用的性能与安全性
在当今软件开发中,多线程编程已成为不可或缺的一部分,尤其在Java应用程序中更是如此。本文探讨了Java中多线程编程的关键挑战和解决方案,重点介绍了如何通过合理的并发控制和优化策略来提升应用程序的性能和安全性,以及避免常见的并发问题。
9 1
|
1天前
|
Java
【编程侦探社】追踪 Java 线程:一场关于生命周期的侦探故事!
【6月更文挑战第19天】在Java世界中,线程如同神秘角色,编程侦探揭示其生命周期:从新生(`new Thread()`)到就绪(`start()`),面临并发挑战如资源共享冲突。通过`synchronized`实现同步,处理阻塞状态(如等待锁`synchronized (lock) {...}`),最终至死亡,侦探深入理解并解决了多线程谜题,成为编程侦探社的传奇案例。
|
1天前
|
SQL Java 关系型数据库
Java数据库编程的详细介绍
Java数据库编程的详细介绍
7 1
|
1天前
|
前端开发 Java 开发者
【编程达人必备】Java高手的秘籍:throw关键字,让异常处理游刃有余!
【6月更文挑战第19天】在Java编程中,熟练运用`throw`关键字是异常处理的关键。通过`throw`,我们可以优雅地处理如商品不存在或价格不匹配等异常情况,避免程序失控。例如,在订单计算中,当遇到问题时,可抛出自定义异常如`PriceMismatchException`。`throw`不仅用于抛出标准异常,还可创建业务相关的异常类型。此外,它允许异常从深层代码传递到上层处理,如在`OrderController`中捕获`calculateTotalAmount`的异常,包装后重新抛出,提供更详细的错误信息。掌握`throw`,能增强程序健壮性,使异常处理变得得心应手。
|
2天前
|
安全 Java 程序员
🚀JAVA异常处理“三部曲”:try-catch-finally带你征服编程的星辰大海!
【6月更文挑战第18天】Java异常处理的`try-catch-finally`是编程探险中的导航系统,确保程序在异常时安全航行。`try`捕获异常,`catch`处理异常,`finally`保证关键清理代码执行。通过实例展示了如何在文件读取中应用这一机制,即使遇到错误也能优雅退出,它是Java程序员征服技术高峰的关键工具。
|
2天前
|
安全 Java 程序员
🔥JAVA程序员必学“防身术”:try-catch-finally助你应对编程“危机”!
【6月更文挑战第18天】Java异常处理通过`try-catch-finally`确保程序安全。当异常发生时,如文件读取或网络请求失败,`catch`捕获异常避免程序崩溃,`finally`保证关键清理代码执行。例如,尝试读取不存在文件会抛出`FileNotFoundException`,`catch`捕获并打印错误,`finally`则提示读取结束。同样,网络请求异常也会被妥善处理。掌握此技术对Java程序员至关重要。
|
2天前
|
Java 程序员
Java多线程编程是指在一个进程中创建并运行多个线程,每个线程执行不同的任务,并行地工作,以达到提高效率的目的
【6月更文挑战第18天】Java多线程提升效率,通过synchronized关键字、Lock接口和原子变量实现同步互斥。synchronized控制共享资源访问,基于对象内置锁。Lock接口提供更灵活的锁管理,需手动解锁。原子变量类(如AtomicInteger)支持无锁的原子操作,减少性能影响。
16 3
|
2天前
|
安全 Java 程序员
Java并发编程中的锁机制与优化策略
【6月更文挑战第17天】在Java并发编程的世界中,锁是维护数据一致性和线程安全的关键。本文将深入探讨Java中的锁机制,包括内置锁、显式锁以及读写锁的原理和使用场景。我们将通过实际案例分析锁的优化策略,如减少锁粒度、使用并发容器以及避免死锁的技巧,旨在帮助开发者提升多线程程序的性能和可靠性。
|
3天前
|
数据采集 安全 算法
Java并发编程中的线程安全与性能优化
在Java编程中,多线程并发是提升程序性能的关键之一。本文将深入探讨Java中的线程安全性问题及其解决方案,并介绍如何通过性能优化技术提升多线程程序的效率。
9 3
|
3天前
|
网络协议 Java API
【Java】Java Socket编程:建立网络连接的基础
【Java】Java Socket编程:建立网络连接的基础
10 1