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

相关文章
|
11天前
|
Python
socket 服务
本示例展示了如何使用 Python 的 socket 模块创建一个简单的服务器。服务器绑定到本地主机的 12345 端口,监听客户端连接请求,并向每个连接的客户端发送欢迎消息,然后关闭连接。
97 59
|
1月前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区,如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等,并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比,直观展示了正确与错误的实现方式,旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
|
24天前
|
Java 程序员
Java编程中的异常处理:从基础到高级
在Java的世界中,异常处理是代码健壮性的守护神。本文将带你从异常的基本概念出发,逐步深入到高级用法,探索如何优雅地处理程序中的错误和异常情况。通过实际案例,我们将一起学习如何编写更可靠、更易于维护的Java代码。准备好了吗?让我们一起踏上这段旅程,解锁Java异常处理的秘密!
|
4天前
|
存储 缓存 Java
Java 并发编程——volatile 关键字解析
本文介绍了Java线程中的`volatile`关键字及其与`synchronized`锁的区别。`volatile`保证了变量的可见性和一定的有序性,但不能保证原子性。它通过内存屏障实现,避免指令重排序,确保线程间数据一致。相比`synchronized`,`volatile`性能更优,适用于简单状态标记和某些特定场景,如单例模式中的双重检查锁定。文中还解释了Java内存模型的基本概念,包括主内存、工作内存及并发编程中的原子性、可见性和有序性。
Java 并发编程——volatile 关键字解析
|
8天前
|
算法 Java 调度
java并发编程中Monitor里的waitSet和EntryList都是做什么的
在Java并发编程中,Monitor内部包含两个重要队列:等待集(Wait Set)和入口列表(Entry List)。Wait Set用于线程的条件等待和协作,线程调用`wait()`后进入此集合,通过`notify()`或`notifyAll()`唤醒。Entry List则管理锁的竞争,未能获取锁的线程在此排队,等待锁释放后重新竞争。理解两者区别有助于设计高效的多线程程序。 - **Wait Set**:线程调用`wait()`后进入,等待条件满足被唤醒,需重新竞争锁。 - **Entry List**:多个线程竞争锁时,未获锁的线程在此排队,等待锁释放后获取锁继续执行。
36 12
|
4天前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
55 2
|
27天前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景,并结合代码示例和实用技巧,帮助开发者有效避免这些陷阱,提升并发程序的稳定性和性能。 ####
|
27天前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
21天前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱,并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手,逐步深入到具体的代码示例,帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者,都能从中获得有价值的见解和建议。 ####
|
21天前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念,包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着,详细讲解了Java提供的同步机制,如synchronized关键字、wait()和notify()方法等,以及如何通过这些机制实现线程间的协调与通信。最后,本文还讨论了一些常见的并发问题,例如死锁、竞态条件等,并提供了相应的解决策略。
44 3