java中用socket实现客户端与服务端双向连接问题
1、服务端监听一个端口，其它客户端都通过这个端口和服务端进行通信。
2、每个客户端连接上来，服务端给其一个标识ID。然后向其它所有客户端广播一下有新客户端接入，ID多少。
3、客户端要向客户端发送消息，可以以消息包的形式发送，就是把目的客户端的标识和发送的内容组成一个数据包发往服务器，服务器读取就知道要向哪 个客户端发送数据，然后把内容往目的客户端通道发送
下面是一个简单的通讯实例，进行Server和Client之间的文件传输。。如果是简单的文本传输的话简化掉文本操作的内容即可。。
1.服务器端
package sterning;
import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerTest {
int port = 8821;
void start() {
Socket s = null;
try {
ServerSocket ss = new ServerSocket(port);
while (true) {
// 选择进行传输的文件
String filePath = "D:\\lib.rar";
File fi = new File(filePath);
System.out.println("文件长度:" + (int) fi.length());
// public Socket accept() throws
// IOException侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。
s = ss.accept();
System.out.println("建立socket链接");
DataInputStream dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));
dis.readByte();
DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));
DataOutputStream ps = new DataOutputStream(s.getOutputStream());
//将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java 4th里有现成的代码。
ps.writeUTF(fi.getName());
ps.flush();
ps.writeLong((long) fi.length());
ps.flush();
int bufferSize = 8192;
byte[] buf = new byte[bufferSize];
while (true) {
int read = 0;
if (fis != null) {
read = fis.read(buf);
}
if (read == -1) {
break;
}
ps.write(buf, 0, read);
}
ps.flush();
// 注意关闭socket链接哦，不然客户端会等待server的数据过来，
// 直到socket超时，导致数据不完整。
fis.close();
s.close();
System.out.println("文件传输完成");
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String arg[]) {
new ServerTest().start();
}
}
2.socket的Util辅助类
package sterning;
import java.net.*;
import java.io.*;
public class ClientSocket {
private String ip;
private int port;
private Socket socket = null;
DataOutputStream out = null;
DataInputStream getMessageStream = null;
public ClientSocket(String ip, int port) {
this.ip = ip;
this.port = port;
}
/** *//**
* 创建socket连接
*
* @throws Exception
* exception
*/
public void CreateConnection() throws Exception {
try {
socket = new Socket(ip, port);
} catch (Exception e) {
e.printStackTrace();
if (socket != null)
socket.close();
throw e;
} finally {
}
}
public void sendMessage(String sendMessage) throws Exception {
try {
out = new DataOutputStream(socket.getOutputStream());
if (sendMessage.equals("Windows")) {
out.writeByte(0x1);
out.flush();
return;
}
if (sendMessage.equals("Unix")) {
out.writeByte(0x2);
out.flush();
return;
}
if (sendMessage.equals("Linux")) {
out.writeByte(0x3);
out.flush();
} else {
out.writeUTF(sendMessage);
out.flush();
}
} catch (Exception e) {
e.printStackTrace();
if (out != null)
out.close();
throw e;
} finally {
}
}
public DataInputStream getMessageStream() throws Exception {
try {
getMessageStream = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
return getMessageStream;
} catch (Exception e) {
e.printStackTrace();
if (getMessageStream != null)
getMessageStream.close();
throw e;
} finally {
}
}
public void shutDownConnection() {
try {
if (out != null)
out.close();
if (getMessageStream != null)
getMessageStream.close();
if (socket != null)
socket.close();
} catch (Exception e) {
}
}
}
3.客户端
package sterning;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;
public class ClientTest {
private ClientSocket cs = null;
private String ip = "localhost";// 设置成服务器IP
private int port = 8821;
private String sendMessage = "Windwos";
public ClientTest() {
try {
if (createConnection()) {
sendMessage();
getMessage();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
private boolean createConnection() {
cs = new ClientSocket(ip, port);
try {
cs.CreateConnection();
System.out.print("连接服务器成功!" + "
");
return true;
} catch (Exception e) {
System.out.print("连接服务器失败!" + "
");
return false;
}
}
private void sendMessage() {
if (cs == null)
return;
try {
cs.sendMessage(sendMessage);
} catch (Exception e) {
System.out.print("发送消息失败!" + "
");
}
}
private void getMessage() {
if (cs == null)
return;
DataInputStream inputStream = null;
try {
inputStream = cs.getMessageStream();
} catch (Exception e) {
System.out.print("接收消息缓存错误
");
return;
}
try {
//本地保存路径，文件名会自动从服务器端继承而来。
String savePath = "E:\\";
int bufferSize = 8192;
byte[] buf = new byte[bufferSize];
int passedlen = 0;
long len=0;
savePath += inputStream.readUTF();
DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(newBufferedOutputStream(new FileOutputStream(savePath))));
len = inputStream.readLong();
System.out.println("文件的长度为:" + len + "
");
System.out.println("开始接收文件!" + "
");
while (true) {
int read = 0;
if (inputStream != null) {
read = inputStream.read(buf);
}
passedlen += read;
if (read == -1) {
break;
}
//下面进度条本为图形界面的prograssBar做的，这里如果是打文件，可能会重复打印出一些相同的百分比
System.out.println("文件接收了" + (passedlen * 100/ len) + "%
");
fileOut.write(buf, 0, read);
}
System.out.println("接收完成，文件存为" + savePath + "
");
fileOut.close();
} catch (Exception e) {
System.out.println("接收消息错误" + "
");
return;
}
}
public static void main(String arg[]) {
new ClientTest();
}
}
//服务端程序：
import java.io.*;
import java.net.*;
public class TCPServer {
public static void main(String[] args) throws IOException {
new TCPServer().init();
}
@SuppressWarnings("static-access")
private void init() throws IOException{
@SuppressWarnings("resource")
ServerSocket server = new ServerSocket(1000);
Socket client = null;
while(true){
try {
client = server.accept();
BufferedInputStream bis = new BufferedInputStream(client.getInputStream());
byte[] b = new byte[1024];
int len = 0;
String message = "";
while((len=bis.read(b))!=-1){
message = new String(b,0,len);
System.out.print("客户端："+client.getInetAddress().getLocalHost().getHostAddress()+"发来消息：" + message);
if("byte".equals(message.trim()))
client.close();
PrintWriter pw = new PrintWriter(client.getOutputStream(),true);
pw.println(message);
}
} catch (Exception e) {
System.err.println("客户端："+client.getInetAddress().getLocalHost().getHostAddress()+" 已断开连接！");
}
}
}
}
//客户端程序：
import java.io.*;
import java.net.Socket;
public class TCPClient implements Runnable{
public static void main(String[] args) throws IOException {
new TCPClient().init();
}
private void init() throws IOException{
@SuppressWarnings("resource")
final Socket client = new Socket("127.0.0.1",1000);
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
String send = "";
while(true){
send = in.readLine();
PrintWriter out = new PrintWriter(client.getOutputStream(),true);
if(!"byte".equals(send.trim()))
out.println(send);
else{
out.println(send);
System.exit(0);
}
new Thread(new TCPClient(){
@SuppressWarnings("static-access")
public void run(){
try {
BufferedInputStream bis = new BufferedInputStream(client.getInputStream());
byte[] b = new byte[1024];
int len = 0;
while((len=bis.read(b))!=-1){
System.out.println("服务器：" +client.getInetAddress().getLocalHost().getHostAddress()+"发来消息："+new String(b,0,len).trim());
}
} catch (IOException e) {
System.err.println("连接服务器失败!");
}
}
}).start();
}
}
public void run() {}
}
//服务器测试结果：
客户端：192.168.0.200发来消息：001 byte
客户端：192.168.0.200发来消息：byte
客户端：192.168.0.200 已断开连接！
客户端：192.168.0.200发来消息：adasd
客户端：192.168.0.200 已断开连接！
//客户端测试结果：
---001号客户端--
001 byte
服务器：192.168.0.200发来消息：001 byte
byte //001礼貌说跟服务器说byte
---002号客户端--
adasd //002客户端直接关闭程序
服务器：192.168.0.200发来消息：adasd
VC实现最简单的UDP通信
SOCKRET s; s=socket(AF_INET,SOCK_DGRAM,0); 或s=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP) 为了建立两个套接字,必须实现地址的重复绑定,即,当一个套接字已经绑定到某本地地址后,为了让另一个套接字重复使用该地址,必须为调用bind()函数绑定第二个套接字之前,通过函数setsockopt()为该套接字设置SO_RE...
英语的绕口令
1 While we were walking, we were watching window washers' wash Washington's windows with warm washing water.当我们走路时，我们看着清洁窗户的人用暖水清洗华盛顿的窗户。2 Give me the gift of a grip top sock: a drip-drape, ship-shape, and tip-top sock.给我一双有禁袜带的袜子：...
VC实现最简单的UDP通信
SOCKRET s; s=socket(AF_INET,SOCK_DGRAM,0); 或s=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP) 为了建立两个套接字,必须实现地址的重复绑定,即,当一个套接字已经绑定到某本地地址后,为了让另一个套接字重复使用该地址,必须为调用bind()函数绑定第二个套接字之前,通过函数setsockopt()为该套接字设置SO_RE...
右新灵达： 给你一个我写的示例,用的是基于TCP的Socket技术,你锻炼一下,改一改,不会改再找我!客户端:import java.net.Socket; import java.io.InputStream; import java.io.OutputStream; import java.io.InputStreamReader; import java.io....
静乐县14769625025： 用Java 的socket实现客户端的功能 - ？
右新灵达： //服务端程序:import java.io.*; import java.net.*; public class TCPServer { public static void main(String[] args) throws IOException { new TCPServer().init(); } @SuppressWarnings(＂static-access＂) private void init() throws IOException{ @...
静乐县14769625025： Java中建立一个socket客户端需要几步 - ？
右新灵达： 代码给你自己看去:Socket socket = new Socket(＂192.168.1.72＂, 4700);// 向本机的4700端口发出客户请求BufferedReader sin = new BufferedReader(new InputStreamReader(System.in,＂UTF-8＂));// 由系统标准输入构造...
静乐县14769625025： 在java中如何用Socket 进行 服务器端和客户端交互的,具体一点. - ？
右新灵达： 打横杠是因为那个方法已经过时了现在已经不怎么用了...Socket 服务器: 1先创建 ServerSocket ss = new ServerSocket(端口号) 2 接收请求 Socket s = ss.accept() 3接收消息 先读后写BufferedReader in = new BufferedReader( new ...
静乐县14769625025： java中的socket编程是作什么的 - ？
右新灵达： Socket,又称为套接字,Socket是计算机网络通信的基本的技术之一.如今大多数基于网络的软件,如浏览器,即时通讯工具甚至是P2P下载都是基于Socket实现的.本文会介绍一下基于TCP/IP的Socket编程,并且如何写一个客户端/服务器程...
静乐县14769625025： java 利用socket编程,实现客户端和服务器端传送文本信息...求代码 - ？
右新灵达： import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; public class ChatClient extends Frame { Socket s = null; DataOutputStream dos = null; DataInputStream dis = null; private boolean bConnected = false; TextField tfTxt = new ...
静乐县14769625025： socket怎么用java实现客户端之间的通信 - ？
右新灵达： 请在知道上面的搜索栏输入 java socket 例子 并回车
静乐县14769625025： java编程实现客户端和服务器端使用socket进行通讯的程序？
右新灵达： Java中有一个专门用来建立Socket服务器的类,名叫ServerSocket,可以用服务器那么多个客户端如何实现呢? 其实,简单的分析一下,就可以看出客户和服务通讯
静乐县14769625025： 用java socket 写一个简单的 聊天 客户端与服务器端之间 都能实现 一个不 - ？
右新灵达： 客户端代码:package net; import java.net.*; import java.io.*; public class socketclient { public static void main(String[] args) { Socket s = null; InputStream is = null; DataInputStream d = null; OutputStream os = null; DataOutputStream ds = null; try { s ...
静乐县14769625025： java socket 客户端是如何向服务器端发送消息的 - ？
右新灵达： 服务器端和客户端都是通过SOCKET来进行通信的,首先产生一个 socket实例,通过这个实例,服务器端调用accept这个方法接收来自客户端发送的信息.但是在产生socket实例的时候必须初始化一个端口.用来负责接受客户端的请求!客户端要...
