自己的入门一点心得。
1：编写一个服务器端，启用10000端口（1024以下端口建议不要使用）。
import java.net.*;
import java.io.*;
public class Server {
private ServerSocket ss;
private Socket socket;
private BufferedReader in;
private PrintWriter out;
public Server() {
try {
ss = new ServerSocket(10000);
while (true) {
socket = ss.accept();//此处阻塞等待用户发出请求
in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));//获得另一方的输入
out = new PrintWriter(socket.getOutputStream(), true);
String line = in.readLine();
System.out.println("you input is :" + line);
out.println(line);//向另一方发出响应
out.close();
in.close();
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
try {
ss.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}finally{
try {
ss.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
new Server();
}
}
2：编写一个客户端，用来连接刚才我们建立的服务器10000端口
import java.io.*;
import java.net.*;
public class Client {
Socket socket;
BufferedReader in;
PrintWriter out;
public Client() {
try {
socket = new Socket("192.168.1.78", 10000);//正式获取链接
out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader line = new BufferedReader(new InputStreamReader(
System.in));
out.println(line.readLine());//向另一方发出输入的信息
in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));//获得另一方的输入
String lines = in.readLine();
System.out.println(lines);
line.close();
out.close();
in.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new Client();
}
}
如此 先启用服务器端，然后再启动客户端，在客户端控制台输入内容，回车后服务器端就能收到，然后会发出相应给客户端。
3：下面来编写一个服务端，可以接收到多个客户端的链接请求。
思路如下：
一：启动一个10000端口 accept方法等待客户端的接入
二: 接入后将这个链接交给一个线程来管理
代码如下：
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class OneServer {
protected static final int PORT = 10000;//端口
private ServerSocket ss ;
private Socket socket;
public OneServer(){
try {
ss = new ServerSocket(10000);//启用10000端口
while(true){
socket = ss.accept();//阻塞等待客户端发起链接
new CreateServerThread(socket);//将链接交给一个线程去管理
}
} catch (IOException e) {
e.printStackTrace();
}
}
class CreateServerThread extends Thread{
private Socket client;
private BufferedReader in;
private PrintWriter out;
public CreateServerThread(Socket socket){
client = socket;
try{
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream(), true);
System.out.println("begin........");
start();
}catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void run() {
try {
String line = in.readLine();//获取对方输入
System.out.println("用户输入 :"+line);
while(!"bye".equals(line)){
String msg = line;
out.println(msg);
}
out.println("bye bye");
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
new OneServer();
}
}
4：下面我们来编写一个类似聊天室的服务器，接收多个客户端的接入，并接收客户端发来的信息同时将信息广播给其他在线的用户。
思路如下：
每个接进来的客户链接线程都放入到一个公共的集合来管理，每个客户端发来的消息都放入到一个链表中管理。服务端线程循环读取消息集合，并循环客户端链接进程集合，向各个进程集合发送消息队列中的信息。
客户端实时读取服务端发来的消息。
代码如下
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
/**
* 聊天室
* 1 声明几个公共变量集合
* 2 将消息和用户列表以及每个客户端发起的链接线程都放入到对应的集合中
* 3
* @author Administrator
*
*/
public class ChatRoom extends ServerSocket
{
public ChatRoom() throws IOException {
super(10000);
new Broadcast();
while(true){
Socket socket = accept();
new CreateServerThread(socket);
}
}
private LinkedList<String> messageList = new LinkedList<String>();//存放消息的集合
private List<CreateServerThread> threadList = new ArrayList<CreateServerThread>();//存放各客户端的线程集合
private List<String> userList = new ArrayList<String>();
/**
* 内部类 向各个线程进行广播
* @author Administrator
*
*/
class Broadcast extends Thread{
public Broadcast(){
start();
}
public void run() {
while(true){
System.out.println("现在开始进行广播 "+threadList.size());
try {
sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
if(messageList.size()>0){//若集合中有消息 则向用户进行广播
String message = messageList.getFirst();//或得到最后一个用户发的消息
if(threadList.size()>0){
for(CreateServerThread thread : threadList){
System.out.println(thread+" : "+message);
thread.sendMessage(message);//向各个在线用户进行广播
}
messageList.removeFirst();
}
}
}
}
}
/**
* 内部类 处理单个线程 用户会话
* @author Administrator
*
*/
class CreateServerThread extends Thread{
private Socket client;
private BufferedReader in;
private PrintWriter out;
public CreateServerThread(Socket s){
client = s;
try{
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream(),true);
out.println("----welCome to my chatRoom please input your username----");
start();
}catch (Exception e) {
e.printStackTrace();
}finally{
}
}
public void run() {
try {
int flag = 0;
String username = "";
String line = in.readLine();//得到用户的输入
System.out.println("get the user input "+line);
while(!"bye".equals(line)){
if("show users".equals(line)){//展示用户信息
out.println(showUsers());
}else{
if(flag++ == 0){//说明用户是第一次进入
threadList.add(this);
userList.add(line);
username = line;
pushMessage(username+" come in ");
}else{//用户已经输入了用户名 此时状态时用户在聊天
pushMessage(username+" : "+line);
}
}
line = in.readLine();
}
out.println("bye bye!!");
userList.remove(username);
threadList.remove(this);
pushMessage(username+" leave ");
} catch (IOException e) {
e.printStackTrace();
}
}
private void sendMessage(String str){
out.println(str);
}
private String showUsers(){
String users = "now there has "+userList.size()+" user is online \n";
if(userList.size()>0){
for(String name : userList){
users +="[ "+name+" ] \n";
}
}
return users;
}
private void pushMessage(String str){
messageList.addLast(str);
}
}
public static void main(String[] args) throws IOException {
new ChatRoom();
}
}
分享到：
相关推荐
Java Socket编程是Java平台中用于实现网络通信的核心API，它基于TCP/IP协议栈，提供了低级别的、面向连接的、可靠的字节流通信。在本文中，我们将深入探讨Java Socket编程的关键概念、工作原理以及如何创建服务端和...
Java Socket 编程实现两台主机间的通信 Java Socket 编程是 Java 语言中用于实现网络通信的编程技术。通过使用 Socket 编程，可以实现两台主机之间的通信，实现数据的传输和交换。本文将详细介绍 Java Socket 编程...
Java Socket编程是网络编程的基础，它提供了在两个应用程序之间建立通信连接的能力。在这个场景中，我们讨论的是如何使用Java的Socket来实现文件上传功能，即从客户端将文件发送到服务器，然后保存到服务器的数据库...
### Java Socket编程详解及实例分析 #### 一、Socket编程基础概述 在计算机网络通信领域，Socket编程是一种广泛使用的通信方式。它为不同主机上的进程提供了双向通信的能力，是网络编程的基础之一。Java语言提供了...
Java Socket编程是Java网络编程的重要组成部分，主要用于实现客户端与服务器之间的通信。在本文中，我们将深入探讨Java Socket编程的基础知识，以及如何结合HTML进行交互。 首先，Java Socket是TCP/IP协议族的一...
import java.io.*; import java.net.*; import java.util.*; import java.lang.*; public class Server extends ServerSocket { private static ArrayList User_List = new ArrayList(); private static ...
本文将深入探讨Java Socket编程的基础知识、关键概念以及如何在实践中应用。 一、Socket概述 Socket，也被称为套接字，是网络通信的端点，可以理解为两个应用程序之间的连接通道。在Java中，Socket类（java.net....
Java Socket 编程在计算机网络实验中的应用 Java Socket 编程是计算机网络实验中的一个重要组成部分，它允许开发者创建可以在网络上传输数据的应用程序。下面是关于 Java Socket 编程在计算机网络实验中的应用的...
在Java中，Socket编程主要是基于TCP/IP协议的网络编程。 网络编程的两个主要问题 在网络编程中，有两个主要的问题需要解决：一是如何准确地定位网络上的一台或多台主机，二是找到主机后如何可靠高效地进行数据传输...
Java Socket 编程：文件传输 Java Socket 编程是 Java 语言中的一种网络编程技术，用于实现客户端和服务器端之间的数据传输。文件传输是 Java Socket 编程中的一种常见应用场景，通过建立客户端和服务器端之间的...
本文将通过一个具体的Java Socket编程实例来深入探讨如何使用Java实现客户端与服务端之间的通信。 #### 二、基础知识概述 在开始具体实例之前，我们需要了解一些基本概念： - **Socket**：Socket是一种用于在网络...
Java Socket编程是网络编程的基础，它提供了在Java中进行低级网络通信的接口。Socket是TCP/IP协议族的一部分，用于实现客户端与服务器之间的双向通信。在这个"java TCP_IP Socket 编程"源码中，我们可以深入理解...
学习这些Java Socket编程实例，有助于理解TCP/IP通信的基本原理，为构建实际的网络应用程序打下坚实的基础。你可以通过调试和修改`SocketTest`代码，进一步探索和实践Socket编程的不同场景，如文件传输、聊天应用等...
Java Socket编程是网络编程的基础，它是Java平台中用于实现客户端-服务器通信的关键组件。本教程将深入浅出地探讨Java Socket编程的核心概念和技术，帮助开发者理解如何构建可靠的网络应用程序。 一、Socket概述 ...
异常处理在Java Socket编程中扮演着重要角色。主要涉及四种异常类型： 1. `UnknownHostException`: 表示主机名或IP地址无法解析，通常是因为网络不可达或者主机名不存在。 2. `ConnectException`: 当尝试连接到...
Java Socket编程是网络编程的一个重要部分，它允许在网络中的计算机之间进行数据交换。Socket编程是基于TCP/IP协议的，因此了解计算机网络、分组报文和协议对于掌握Socket编程来说至关重要。接下来，我将详细解释...
在Java中，Socket编程是实现网络通信的基础，它提供了进程间通信的能力，使得两个相隔万里的计算机可以通过互联网进行数据交换。本篇文章将深入讲解如何通过三步学习Java Socket编程。 **第一步：理解Socket** ...
本教程将深入探讨Java Socket编程的核心概念，以及如何利用它进行网络通信。 1. **Java Socket基础** - **Socket的概念**：Socket是网络通信中的一个端点，可以理解为两台机器间通信的桥梁。在Java中，Socket类...
Java Socket 编程实现的简单多线程 WEB 服务器 在本文中，我们将详细介绍如何使用 Java 的 Socket 编程实现一个简单的多线程 WEB 服务器。 Socket 编程简介 Socket 编程是 Java 网络编程的基础，它允许开发者创建...