java中客户端和服务器端怎么连接？？

你的不是B/S，B/S的意思是Browser（浏览器） Server（Web服务器），根据你的描述，你的客户端有3个类，服务端有2个类，是很明显的C/S模式，这个不需要建什么Web服务吧。
如果你想把你的程序运行起来，你首先要把服务端的代码执行起来，怎么执行？你把你服务端的两个类打成一个可执行的jar包（eclipse的export命令可以帮助你打可执行jar包），然后执行javaw -jar xxxxjar，把你的服务端程序跑起来。用同样的方式，把你的客户端程序跑起来就可以了。

Socket通信：
作为服务器端:
//生成服务器端,监听服务器设定的端口
ServerSocket
socketServer
=
new
ServerSocket(端口号);
//建立客户端和服务器端的链接，这时再看客户端
Socket
socket
=
socketServeraccept();
作为客户端:
//新建一个Socket，包含服务器端的IP和端口号，这样在服务器启动情况下可以建立和服务器的链接
Socket
socket
=
new
Socket（"IP地址","端口号"）;
这时,服务器端和客户端的连接已经建立,如果需要通信和传输数据的话分别在服务器端、客户端新建流对象，可以通过流对象实现双方之间的互通
有关流的内容自己看书体会下就能写出B/S结构的通信了。

/服务端/
import javaioBufferedReader;
import javaioBufferedWriter;
import javaioIOException;
import javaioInputStreamReader;
import javaioOutputStreamWriter;
import javaioPrintWriter;
import javanetServerSocket;
import javanetSocket;
第四步，编写服务器端的主体代码，如下所示。
public class ServerCode
{
// 设置端口号
public static int portNo = 3333;
public static void main(String[] args) throws IOException
{
ServerSocket s = new ServerSocket(portNo);
Systemoutprintln("The Server is start: " + s);
// 阻塞,直到有客户端连接
Socket socket = saccept();
try
{
Systemoutprintln("Accept the Client: " + socket);
//设置IO句柄
BufferedReader in = new BufferedReader(new InputStreamReader(socket
getInputStream()));
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(socketgetOutputStream())), true);
while (true)
{
String str = inreadLine();
if (strequals("byebye"))
{
break;
}
Systemoutprintln("In Server reveived the info: " + str);
outprintln(str);
}
}
finally
{
Systemoutprintln("close the Server socket and the io");
socketclose();
sclose();
}
}
}
/客户端/
import javaioBufferedReader;
import javaioBufferedWriter;
import javaioIOException;
import javaioInputStreamReader;
import javaioOutputStreamWriter;
import javaioPrintWriter;
import javanetInetAddress;
import javanetSocket;
第二，编写客户端的主体代码，如下所示：
public class ClientCode
{
static String clientName = "Mike";
//端口号
public static int portNo = 3333;
public static void main(String[] args) throws IOException
{
// 设置连接地址类,连接本地
InetAddress addr = InetAddressgetByName("localhost");
//要对应服务器端的3333端口号
Socket socket = new Socket(addr, portNo);
try
{
Systemoutprintln("socket = " + socket);
// 设置IO句柄
BufferedReader in = new BufferedReader(new InputStreamReader(socket
getInputStream()));
PrintWrite out = new PrintWriter(BufferedWriter(new OutputStreamWriter(socketgetOutputStream())), true);
outprintln("Hello Server,I am " + clientName);
String str = inreadLine();
Systemoutprintln(str);
outprintln("byebye");
}
finally
{
Systemoutprintln("close the Client socket and the io");
socketclose();
}
}
}

一个服务器对多个客户端，你可以这样去实现：在服务器端程序中为每个连接上服务器的客户端开启一个线程。这也就是多线程编程的内容了，至于你说怎么阻止客户端做重复的动作，你可以在客户端运行某个动作时向服务器端发送一个标识符，服务器端用一个变量存储这些标识符，但服务器端在接受一个标识符后，会对存储这些标识符的变量进行遍历，如果这个标识符已经存在，那么表明是一个重复的动作，服务器端就可以禁止接受该重复动作

两者都可以不过java的垃圾回收机制因为是自动的所以执行客户端程序的时候效率特别慢一般用于服务器端或WEB开发学java的重点就是以j2ee技术为核心的。想写客户端之类的用C语言是最佳的不过内存处理机制全部自己编写难度不是一般的高。

你可以在每个用户连上服务器端时，都发送一个消息，就是用4个字节表示是用户的ID，并将与用户通信的socket，用一个HashMap存储起来，而不是用LinkList。
后面如果A发送消息给C，就把A的前四个字节（即ID）取出来，在HashMap中找到与C通信的socket，然后把消息通过socket发送出去····
这部分代码应该很容易实现的，Socket通信这东西，理清了思路就很好弄了~~

服务器端源码：\x0d\import javaioBufferedReader;\x0d\import javaioFile;\x0d\import javaioFileNotFoundException;\x0d\import javaioFileOutputStream;\x0d\import javaioIOException;\x0d\import javaioInputStream;\x0d\import javaioInputStreamReader;\x0d\import javanetServerSocket;\x0d\import javanetSocket;\x0d\\x0d\/\x0d\ \x0d\ 文件名：ServerReceivejava\x0d\ 实现功能：作为服务器接收客户端发送的文件\x0d\ \x0d\ 具体实现过程：\x0d\ 1、建立SocketServer，等待客户端的连接\x0d\ 2、当有客户端连接的时候，按照双方的约定，这时要读取一行数据\x0d\ 其中保存客户端要发送的文件名和文件大小信息\x0d\ 3、根据文件名在本地创建文件，并建立好流通信\x0d\ 4、循环接收数据包，将数据包写入文件\x0d\ 5、当接收数据的长度等于提前文件发过来的文件长度，即表示文件接收完毕，关闭文件\x0d\ 6、文件接收工作结束\x0d\\x0d\public class ServerReceive {\x0d\ \x0d\ public static void main(String[] args) {\x0d\ \x0d\ /与服务器建立连接的通信句柄/\x0d\ ServerSocket ss = null;\x0d\ Socket s = null;\x0d\ \x0d\ /定义用于在接收后在本地创建的文件对象和文件输出流对象/\x0d\ File file = null;\x0d\ FileOutputStream fos = null;\x0d\ \x0d\ /定义输入流，使用socket的inputStream对数据包进行输入/\x0d\ InputStream is = null;\x0d\ \x0d\ /定义byte数组来作为数据包的存储数据包/\x0d\ byte[] buffer = new byte[4096 5];\x0d\ \x0d\ /用来接收文件发送请求的字符串/\x0d\ String comm = null;\x0d\\x0d\/建立socekt通信，等待服务器进行连接/\x0d\ try {\x0d\ ss = new ServerSocket(4004);\x0d\ s = ssaccept();\x0d\ } catch (IOException e) {\x0d\ eprintStackTrace();\x0d\ }\x0d\\x0d\/读取一行客户端发送过来的约定信息/\x0d\ try {\x0d\ InputStreamReader isr = new InputStreamReader(sgetInputStream());\x0d\ BufferedReader br = new BufferedReader(isr);\x0d\ comm = brreadLine();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器与客户端断开连接");\x0d\ }\x0d\ \x0d\ /开始解析客户端发送过来的请求命令/\x0d\ int index = commindexOf("/#");\x0d\ \x0d\ /判断协议是否为发送文件的协议/\x0d\ String xieyi = commsubstring(0, index);\x0d\ if(!xieyiequals("111")){\x0d\ Systemoutprintln("服务器收到的协议码不正确");\x0d\ return;\x0d\ }\x0d\ \x0d\ /解析出文件的名字和大小/\x0d\ comm = commsubstring(index + 2);\x0d\ index = commindexOf("/#");\x0d\ String filename = commsubstring(0, index)trim();\x0d\ String filesize = commsubstring(index + 2)trim();\x0d\\x0d\/创建空文件，用来进行接收文件/\x0d\ file = new File(filename);\x0d\ if(!fileexists()){\x0d\ try {\x0d\ filecreateNewFile();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器端创建文件失败");\x0d\ }\x0d\ }else{\x0d\ /在此也可以询问是否覆盖/\x0d\ Systemoutprintln("本路径已存在相同文件，进行覆盖");\x0d\ }\x0d\ \x0d\ /以上就是客户端代码中写到的服务器的准备部分/\x0d\\x0d\/\x0d\ 服务器接收文件的关键代码/\x0d\ try {\x0d\ /将文件包装到文件输出流对象中/\x0d\ fos = new FileOutputStream(file);\x0d\ long file_size = LongparseLong(filesize);\x0d\ is = sgetInputStream();\x0d\ /size为每次接收数据包的长度/\x0d\ int size = 0;\x0d\ /count用来记录已接收到文件的长度/\x0d\ long count = 0;\x0d\ \x0d\ /使用while循环接收数据包/\x0d\ while(count 回答于 2022-12-11

服务器端可以采用多线程处理客户请求，例如：
package threadPool;
import javaioBufferedReader;
import javaioIOException;
import javaioInputStream;
import javaioInputStreamReader;
import javaioOutputStream;
import javaioPrintWriter;
import javanetServerSocket;
import javanetSocket;
import javautilconcurrentExecutorService;
import javautilconcurrentExecutors;
public class ThreadPoolServer {

private int port = 8000;
private ServerSocket serverSocket;
private ExecutorService executorService; //线程池
private final int POOL_SIZE = 4; //单个CPU时线程池中的工作线程数目

public ThreadPoolServer() throws IOException{
serverSocket = new ServerSocket(port);

//创建线程池
//Runtime 的availableProcessors()方法返回当前系统CPU的数目
//系统CPU越多，线程池中的工作线程数目越多
executorService = ExecutorsnewFixedThreadPool(RuntimegetRuntime()availableProcessors()POOL_SIZE);

Systemoutprintln("服务器已启动！！");
}

public void service(){
while(true){
Socket socket = null;
try{
socket = serverSocketaccept();
executorServiceexecute(new Handler(socket));
}catch(IOException e){
eprintStackTrace();
}
}
}
public static void main(String[] args) {
try {
new ThreadPoolServer()service();
} catch (IOException e) {
eprintStackTrace();
}
}
}
class Handler implements Runnable {
private Socket socket;
public Handler(Socket socket) {
thissocket = socket;
}
private PrintWriter getWriter(Socket socket) throws IOException {
OutputStream socketOut = socketgetOutputStream();
return new PrintWriter(socketOut, true);
}
private BufferedReader getReader(Socket socket) throws IOException {
InputStream socketIn = socketgetInputStream();
return new BufferedReader(new InputStreamReader(socketIn));
}
public String echo(String msg) {
return "echo:" + msg;
}
@Override
public void run() {
try {
Systemoutprintln("New connection accepted:" + socketgetInetAddress() + ":" + socketgetPort());
BufferedReader br = getReader(socket);
PrintWriter pw = getWriter(socket);
String msg = null;
while ((msg = brreadLine()) != null) {
Systemoutprintln(msg);
pwprintln(echo(msg));
if (msgequals("bye")) {
break;
}
}
} catch (IOException e) {
eprintStackTrace();
} finally {
try {
if (socket != null)
socketclose();
} catch (IOException e) {
eprintStackTrace();
}
}
}
}

---