商业源码 用Java socket 实现客户端与服务器之间的数据的发送与接受。。。双向的
下面是一个简单的通讯实例，进行Server和Client之间的文件传输。。如果是简单的文本传输的话简化掉文本操作的内容即可。。
1服务器端
package sterning;
import javaioBufferedInputStream;
import javaioDataInputStream;
import javaioDataOutputStream;
import javaioFile;
import javaioFileInputStream;
import javanetServerSocket;
import javanetSocket;
public class ServerTest {
int port = 8821;
void start() {
Socket s = null;
try {
ServerSocket ss = new ServerSocket(port);
while (true) {
// 选择进行传输的文件
String filePath = "D:\\librar";
File fi = new File(filePath);
Systemoutprintln("文件长度:" + (int) filength());
// public Socket accept() throws
// IOException侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。
s = ssaccept();
Systemoutprintln("建立socket链接");
DataInputStream dis = new DataInputStream(new BufferedInputStream(sgetInputStream()));
disreadByte();
DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));
DataOutputStream ps = new DataOutputStream(sgetOutputStream());
//将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java 4th里有现成的代码。
pswriteUTF(figetName());
psflush();
pswriteLong((long) filength());
psflush();
int bufferSize = 8192;
byte[] buf = new byte[bufferSize];
while (true) {
int read = 0;
if (fis != null) {
read = fisread(buf);
}
if (read == -1) {
break;
}
pswrite(buf, 0, read);
}
psflush();
// 注意关闭socket链接哦，不然客户端会等待server的数据过来，
// 直到socket超时，导致数据不完整。
fisclose();
sclose();
Systemoutprintln("文件传输完成");
}
} catch (Exception e) {
eprintStackTrace();
}
}
public static void main(String arg[]) {
new ServerTest()start();
}
}
2socket的Util辅助类
package sterning;
import javanet;
import javaio;
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) {
thisip = ip;
thisport = port;
}
/ //
创建socket连接
@throws Exception
exception
/
public void CreateConnection() throws Exception {
try {
socket = new Socket(ip, port);
} catch (Exception e) {
eprintStackTrace();
if (socket != null)
socketclose();
throw e;
} finally {
}
}
public void sendMessage(String sendMessage) throws Exception {
try {
out = new DataOutputStream(socketgetOutputStream());
if (sendMessageequals("Windows")) {
outwriteByte(0x1);
outflush();
return;
}
if (sendMessageequals("Unix")) {
outwriteByte(0x2);
outflush();
return;
}
if (sendMessageequals("Linux")) {
outwriteByte(0x3);
outflush();
} else {
outwriteUTF(sendMessage);
outflush();
}
} catch (Exception e) {
eprintStackTrace();
if (out != null)
outclose();
throw e;
} finally {
}
}
public DataInputStream getMessageStream() throws Exception {
try {
getMessageStream = new DataInputStream(new BufferedInputStream(socketgetInputStream()));
return getMessageStream;
} catch (Exception e) {
eprintStackTrace();
if (getMessageStream != null)
getMessageStreamclose();
throw e;
} finally {
}
}
public void shutDownConnection() {
try {
if (out != null)
outclose();
if (getMessageStream != null)
getMessageStreamclose();
if (socket != null)
socketclose();
} catch (Exception e) {
}
}
}
3客户端
package sterning;
import javaioBufferedOutputStream;
import javaioDataInputStream;
import javaioDataOutputStream;
import javaioFileOutputStream;
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) {
exprintStackTrace();
}
}
private boolean createConnection() {
cs = new ClientSocket(ip, port);
try {
csCreateConnection();
Systemoutprint("连接服务器成功!" + "\n");
return true;
} catch (Exception e) {
Systemoutprint("连接服务器失败!" + "\n");
return false;
}
}
private void sendMessage() {
if (cs == null)
return;
try {
cssendMessage(sendMessage);
} catch (Exception e) {
Systemoutprint("发送消息失败!" + "\n");
}
}
private void getMessage() {
if (cs == null)
return;
DataInputStream inputStream = null;
try {
inputStream = csgetMessageStream();
} catch (Exception e) {
Systemoutprint("接收消息缓存错误\n");
return;
}
try {
//本地保存路径，文件名会自动从服务器端继承而来。
String savePath = "E:\\";
int bufferSize = 8192;
byte[] buf = new byte[bufferSize];
int passedlen = 0;
long len=0;
savePath += inputStreamreadUTF();
DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(newBufferedOutputStream(new FileOutputStream(savePath))));
len = inputStreamreadLong();
Systemoutprintln("文件的长度为:" + len + "\n");
Systemoutprintln("开始接收文件!" + "\n");
while (true) {
int read = 0;
if (inputStream != null) {
read = inputStreamread(buf);
}
passedlen += read;
if (read == -1) {
break;
}
//下面进度条本为图形界面的prograssBar做的，这里如果是打文件，可能会重复打印出一些相同的百分比
Systemoutprintln("文件接收了" + (passedlen 100/ len) + "%\n");
fileOutwrite(buf, 0, read);
}
Systemoutprintln("接收完成，文件存为" + savePath + "\n");
fileOutclose();
} catch (Exception e) {
Systemoutprintln("接收消息错误" + "\n");
return;
}
}
public static void main(String arg[]) {
new ClientTest();
}
}
打开背包向服务器申请数据服务器下发被背包内的物品 ID 、Count（结构体形式以List发送到客户端）
客户端根据接受的ID、Count去本地配置表中配置物品然后显示在背包中
（从服务器接受后在本地查找ID对应的 属性 类型后加入Count显示在背包中）
点击物品，将物品ID发送到服务器，服务器扣除物品数量，并将使用物品后所需的效果（如 增加经验、属性等），增加完毕之后将数值返回给客户端，客户端更新背包内容并将对应属性同步刷新显示（如果物品用完 将物品从储存的List中将物品进行删除操作）
服务器向背包发送ID、Count，在本地配置表中生成后 刷新显示到背包中。
客户端发送 角色ID 到客户端，客户端在库中搜索角色
（1）玩家2同意添加好友，玩家2客户端向服务器发送消息，服务器将两 人绑定为好友关系，将数据（玩家ID等）下发到双方客户端，并刷新 显示双方客户端好友列表。
（2）玩家2拒绝添加好友，玩家2客户端向服务器发送消息，服务器向玩 家1发送消息，玩家1客户端显示被拒绝消息提醒。
玩家1向服务器发送消息，服务器取消双方好友关系的绑定，并将数据发回双方客户 端，客户端更新显示好友框。
通常以动态生成和隐藏方式显示，只显示上下5个范围内容。。。。。
客户端向服务器发送消息，服务器判断当前时间，并判断当天是否签到过，如未签到 过，向客户端发送信息，客户端显示签到成功，并修改签到按钮为已经签到，如需领 取签到奖励，参考背包获得物品。
服务器记录账号签到天数，如需要补签将补签日期ID发送到服务器，服务器判定当 天是否签到，未签到则执行签到操作，获取奖励物品。
服务器向客户端发送消息（邮件名、邮件内容、是否有附件、附件ID、Count），客 户端接受信息后显示有新邮件的提示，在本地配置表中填入接受的消息，并显示在邮 件中。客户端点击领取附件（向服务器发送消息，已经领取），并且做背包操作，参 考背包系统获取物品。
玩家1编辑邮件，点击发送按钮，将邮件（名称、内容、是否有附件、附件、收件 人）发送到服务器，服务器在库中索搜收件人，然后参考系统附件邮件操作。
服务器端和客户端都是通过SOCKET来进行通信的,首先产生一个 socket实例,通过这个实例,服务器端调用accept这个方法接收来自客户端发送的信息但是在产生socket实例的时候必须初始化一个端口用来负责接受客户端的请求！
客户端要给服务器发送消息也必须产生一个socket实例，初始化的时候必须指定服务器的IP地址，并且指定服务接收的端口号,这样客户端才能找到服务器要接收的地方，找到地方就可以发送过去了。和你写信一样。找到地址
BufferedReader in = new BufferedReader(new InputStreamReader(socketgetInputStream()));
PrintWriter out = new PrintWriter(socketgetOutputStream());
BufferedReader wt = new BufferedReader(new InputStreamReader(Systemin));
这个只是用来获取一个从键盘的一个流传送给服务器端的数据都是通过流来表示的。意思是是键盘输入的一个字节转化成字符流并输出或者写入！
C/S模式和B/S各有其有点也各有其缺点，B/S模式在开发中需要考虑数据如何从客户端提交到服务器端，数据又如何返回到客户端，这些是B/S模式所特有的，在去年之前，开发B/S模式的程序，我都是利用form来交互数据，当我看到XML之后，发现XML是个好冬冬，有很多优点，有好的东西当然不能独享啦，想当年为了实现XML交互数据，几乎把网络翻了个遍。咚，一块砖头上来了。呵呵，废话少说，下面我们就进入正题。
B/S模式分为服务器端和客户端，客户端接受用户的请求，客户端向应用服务提出请求，应用服务从数据库服务中获得数据，应用服务将数据进行计算并将结果提交给客户端，客户端将结果呈现给用户。这样，我们就看到了数据从客户到服务器，经过服务器的处理再返回到客户端，由客户端软件（如IE）显示结果。
（以ASP教本语言为例，其它的语言一样哈。）
1．Form方式
Form方式是最基本的向服务器提交数据的方式。
testasp文件代码：
<%@ Language=VBScript %>
<%
ResponseExpires=-1
ResponseCharSet="UTF-8"
SessionCodePage="65001"
%>
<form name="frmTest" id="frmTest" action="testasp" method="POST">
<input name="name" id=" name" type="text" value="">
<input type="hidden" name="number" id="number" value="10">
<input type="submit" value="Submit" name="B1">
</form>
<%
dim intnumber
dim strname
if IsEmpty(Request("name")) then
strname =""
else
strname =Request("name")
end if
if IsEmpty(Request("number")) then
intnumber =0
else
intnumber =Request("number")
end if
HTTP/11协议中共定义了八种方法（有时也叫“动作”）来表明Request-URI指定的资源的不同操作方式：
OPTIONS
返回服务器针对特定资源所支持的HTTP请求方法。也可以利用向Web服务器发送''的请求来测试服务器的功能性。
HEAD
向服务器索要与GET请求相一致的响应，只不过响应体将不会被返回。这一方法可以在不必传输整个响应内容的情况下，就可以获取包含在响应消息头中的元信息。
GET
向特定的资源发出请求。注意：GET方法不应当被用于产生“副作用”的操作中。
POST
向指定资源提交数据进行处理请求（例如提交表单或者上传文件）。数据被包含在请求体中。POST请求可能会导致新的资源的建立和/或已有资源的修改。
PUT
向指定资源位置上传其最新内容。
DELETE
请求服务器删除Request-URI所标识的资源。
TRACE
回显服务器收到的请求，主要用于测试或诊断。
CONNECT
HTTP/11协议中预留给能够将连接改为管道方式的代理服务器。
"服务器未发送任何数据"通常意味着客户端向服务器发送了请求，但服务器没有返回任何数据给客户端。这可能有以下几个原因：
请求错误：客户端可能发送了一个无效的请求或请求的资源不存在，服务器无法找到相应的内容返回给客户端。
服务器故障：服务器可能遇到了故障或错误，导致它无法处理请求或提供响应。这可能是临时的问题，需要稍后再次尝试。
网络问题：在请求和响应之间存在网络连接问题，导致无法传送数据。这可能是由于网络延迟、连接中断或其他网络故障引起的。
访问权限：服务器可能根据设定的权限限制了访问某些资源的权限，如果客户端没有足够的权限，则无法获取相应的数据。
如果您遇到了"服务器未发送任何数据"的问题，建议您首先检查请求的有效性和目标资源的可用性。如果问题仍然存在，您可以考虑重新加载页面或与网站管理员或技术支持团队联系以获取进一步的帮助。
0条评论