导航:首页 > 编程语言 > javasocket代码

javasocket代码

发布时间:2025-04-07 14:19:01

java编程中,Socket通信是怎么实现的

java编程对于Socket之间的通信过程如下:

服务端往Socket的输出流里面写东西,客户端就可以通过Socket的输入流读取对应的内容。Socket与Socket之间是双向连通的,所以客户端也可以往对应的Socket输出流里面写东西,然后服务端对应的Socket的输入流就可以读出对应的内容。下面来看一些服务端与客户端通信的例子:

publicclassServer{

publicstaticvoidmain(Stringargs[])throwsIOException{
//为了简单起见,所有的异常信息都往外抛
intport=8899;
//定义一个ServerSocket监听在端口8899上
ServerSocketserver=newServerSocket(port);
//server尝试接收其他Socket的连接请求,server的accept方法是阻塞式的
Socketsocket=server.accept();
//跟客户端建立好连接之后,我们就可以获取socket的InputStream,并从中读取客户端发过来的信息了。
Readerreader=newInputStreamReader(socket.getInputStream());
charchars[]=newchar[64];
intlen;
StringBuildersb=newStringBuilder();
while((len=reader.read(chars))!=-1){
sb.append(newString(chars,0,len));
}
System.out.println("fromclient:"+sb);
reader.close();
socket.close();
server.close();
}

}
客户端代码
Java代码publicclassClient{

publicstaticvoidmain(Stringargs[])throwsException{
//为了简单起见,所有的异常都直接往外抛
Stringhost="127.0.0.1";//要连接的服务端IP地址
intport=8899;//要连接的服务端对应的监听端口
//与服务端建立连接
Socketclient=newSocket(host,port);
//建立连接后就可以往服务端写数据了
Writerwriter=newOutputStreamWriter(client.getOutputStream());
writer.write("HelloServer.");
writer.flush();//写完后要记得flush
writer.close();
client.close();
}

}

⑵ 怎么用java的socket进行文件传输谁能给个简单的例子,包括发送端和接收端。

java中的网络信息传输方式是基于TCP协议或者UD协议P的,socket是基于TCP协议的

例子1
(1)客户端程序:
import java.io.*;
import java.net.*;
public class Client
{ public static void main(String args[])
{ String s=null;
Socket mysocket;
DataInputStream in=null;
DataOutputStream out=null;
try{
mysocket=new Socket("localhost",4331);
in=new DataInputStream(mysocket.getInputStream());
out=new DataOutputStream(mysocket.getOutputStream());
out.writeUTF("你好!");//通过 out向"线路"写入信息。
while(true)
{
s=in.readUTF();//通过使用in读取服务器放入"线路"里的信息。堵塞状态,
//除非读取到信息。
out.writeUTF(":"+Math.random());
System.out.println("客户收到:"+s);
Thread.sleep(500);
}
}
catch(IOException e)
{ System.out.println("无法连接");
}
catch(InterruptedException e){}
}
}
(2)服务器端程序:
import java.io.*;import java.net.*;
public class Server
{ public static void main(String args[])
{ ServerSocket server=null;
Socket you=null;String s=null;
DataOutputStream out=null;DataInputStream in=null;
try{ server=new ServerSocket(4331);}
catch(IOException e1){System.out.println("ERRO:"+e1);}
try{ you=server.accept();
in=new DataInputStream(you.getInputStream());
out=new DataOutputStream(you.getOutputStream());
while(true)
{
s=in.readUTF();// 通过使用in读取客户放入"线路"里的信息。堵塞状态,
//除非读取到信息。

out.writeUTF("你好:我是服务器");//通过 out向"线路"写入信息.
out.writeUTF("你说的数是:"+s);
System.out.println("服务器收到:"+s);
Thread.sleep(500);
}
}
catch(IOException e)
{ System.out.println(""+e);
}
catch(InterruptedException e){}
}
}

例子(2)
(1) 客户端
import java.net.*;import java.io.*;
import java.awt.*;import java.awt.event.*;
import java.applet.*;
public class Computer_client extends Applet implements Runnable,ActionListener
{ Button 计算;TextField 输入三边长度文本框,计算结果文本框;
Socket socket=null;
DataInputStream in=null; DataOutputStream out=null;
Thread thread;
public void init()
{ setLayout(new GridLayout(2,2));
Panel p1=new Panel(),p2=new Panel();
计算=new Button(" 计算");
输入三边长度文本框=new TextField(12);计算结果文本框=new TextField(12);
p1.add(new Label("输入三角形三边的长度,用逗号或空格分隔:"));
p1.add( 输入三边长度文本框);
p2.add(new Label("计算结果:"));p2.add(计算结果文本框);p2.add(计算);
计算.addActionListener(this);
add(p1);add(p2);
}
public void start()
{ try
{ //和小程序所驻留的服务器建立套接字连接:
socket = new Socket(this.getCodeBase().getHost(), 4331);
in =new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
}
catch (IOException e){}
if(thread == null)
{ thread = new Thread(this);
thread.start();
}
}
public void run()
{ String s=null;
while(true)
{ try{ s=in.readUTF();//堵塞状态,除非读取到信息。

计算结果文本框.setText(s);
}
catch(IOException e)
{ 计算结果文本框.setText("与服务器已断开");
break;
}
}
}
public void actionPerformed(ActionEvent e)
{ if(e.getSource()==计算)
{ String s=输入三边长度文本框.getText();
if(s!=null)
{ try { out.writeUTF(s);
}
catch(IOException e1){}
}
}
}
}

(2) 服务器端
import java.io.*;import java.net.*;
import java.util.*;import java.sql.*;
public class Computer_server
{ public static void main(String args[])
{ ServerSocket server=null;Server_thread thread;
Socket you=null;
while(true)
{ try{ server=new ServerSocket(4331);
}
catch(IOException e1)
{ System.out.println("正在监听"); //ServerSocket对象不能重复创建。
}
try{ you=server.accept();
System.out.println("客户的地址:"+you.getInetAddress());
}
catch (IOException e)
{ System.out.println("正在等待客户");
}
if(you!=null)
{ new Server_thread(you).start(); //为每个客户启动一个专门的线程。
}
else
{ continue;
}
}
}
}
class Server_thread extends Thread
{ Socket socket;Connection Con=null;Statement Stmt=null;
DataOutputStream out=null;DataInputStream in=null;int n=0;
String s=null;
Server_thread(Socket t)
{ socket=t;
try { in=new DataInputStream(socket.getInputStream());
out=new DataOutputStream(socket.getOutputStream());
}
catch (IOException e)
{}
}
public void run()
{ while(true)
{ double a[]=new double[3] ;int i=0;
try{ s=in.readUTF();堵塞状态,除非读取到信息。

StringTokenizer fenxi=new StringTokenizer(s," ,");
while(fenxi.hasMoreTokens())
{ String temp=fenxi.nextToken();
try{ a[i]=Double.valueOf(temp).doubleValue();i++;
}
catch(NumberFormatException e)
{ out.writeUTF("请输入数字字符");
}
}
double p=(a[0]+a[1]+a[2])/2.0;
out.writeUTF(" "+Math.sqrt(p*(p-a[0])*(p-a[1])*(p-a[2])));
sleep(2);
}
catch(InterruptedException e){}
catch (IOException e)
{ System.out.println("客户离开");
break;
}
}
}
}

这些例子都是Java2实用教程上的.

⑶ java socket输入流inputStream.read(byte[])方法一次读入多帧数据,也就是多帧数据连在一起

在使用Java Socket的inputStream.read(byte[])方法时,如果服务端发送数据的速度超过客户端读取的速度,客户端可能会一次性读取到多帧数据连在一起的情况。这种情况下,数据包的读取和处理就需要特别注意。一种处理方式是在服务端将每一帧数据作为一行写入Socket,客户端则通过BufferedReader逐行读取。这样可以确保每次读取的数据都是一个完整的数据帧。

具体实现步骤如下:

1. 在服务端使用PrintWriter将数据帧作为一行写入Socket输出流:

2. 代码示例如下:

java

PrintWriter writer = new PrintWriter(socket.getOutputStream());

writer.println(data);

2. 在客户端,通过BufferedReader逐行读取Socket输入流的数据:

2. 代码示例如下:

java

BufferedReader reader = new BufferedReader(new BufferedInputStream(socket.getInputStream()));

String s = reader.readLine();

这种方式可以确保客户端每次读取到的数据都是一个完整的数据帧,而不会出现多帧数据连在一起的情况。通过这种方式,可以更好地管理和处理Socket通信中不同帧数据的读取。

使用这种方法处理数据帧时,需要注意的是,每一帧数据必须以换行符结束,这样才能被正确地解析为一行。此外,客户端在读取每一行数据后,应该进行适当的解析和处理,以确保数据的完整性和正确性。

通过这种方式处理数据帧,可以有效地解决服务端发送数据速度过快,而客户端读取速度较慢的问题,从而提高数据通信的稳定性和可靠性。

⑷ 求Java Socket大神点拨一个Java Socket API“java.net.SocketException: Connection reset”故障,怎么破

Java Socket编程中,遇到java.net.SocketException: Connection reset异常时,通常会遇到两种情况:一种是客户端或服务器端一端关闭了Socket连接,而另一端仍在发送数据,这会导致发送的第一个数据包被重置;另一种情况是,一端在退出时没有正确关闭连接,而另一端尝试从该连接中读取数据时,也会触发此异常。简单来说,这种异常通常是由于连接断开后的读写操作引起的。

为了更好地理解和解决这个问题,你可以把你的socketClient代码分享一下,让我们一起看看其中可能存在的问题。通常情况下,确保在关闭Socket连接时正确处理流和资源是很重要的。此外,适当增加错误处理逻辑,如检查连接状态并在必要时重新建立连接,也能有效避免此类问题。

另外,如果在处理大量数据或在网络状况不佳的情况下,你也需要考虑使用重试机制或增加超时设置来增强程序的健壮性。

如果你能提供具体的代码片段,我们可以更具体地分析问题所在,并给出针对性的建议。

记得在代码中加入适当的异常处理机制,例如捕获并处理SocketException,并根据具体情况决定是重新建立连接还是终止当前操作。

希望以上信息对你有所帮助。如果有其他相关问题或需要进一步的帮助,请随时提问。

阅读全文

与javasocket代码相关的资料

热点内容
压保单事故处理中怎样解压车辆 浏览:563
switch字符串java 浏览:969
2021年毕业二本程序员月薪 浏览:892
android饼图控件 浏览:139
下载完课件怎么解压 浏览:300
荆州源码名片 浏览:122
phpdemo视频 浏览:205
程序员转行做大数据 浏览:547
真我t1如何添加加密nfc 浏览:605
股市复盘系统源码 浏览:524
我的世界如何不要钻石创造服务器 浏览:533
虚拟机里面的文件重命名mv命令 浏览:20
安卓什么电话系统最好 浏览:581
进入云服务器输入什么密码 浏览:328
java微信下载手机版 浏览:73
php代码分析工具 浏览:673
泰坦陨落2xbox如何换服务器 浏览:755
安卓手机如何用数据线连接投影 浏览:380
java类的实例变量的区别 浏览:714
千年源码端多少钱 浏览:252