JAVA中如何监听一个端口来进入收和发信息!
1.监听一个端口,比如1000。2.然后客户发送一段信息,其中的一个子程序就开始处理这则信息,接收到后信息框弹出来,在关闭这个客户的连接。3.有新客户来的时候继续处理上面...
1.监听一个端口,比如1000。
2.然后客户发送一段信息,其中的一个子程序就开始处理这则信息,接收到后信息框弹出来,在关闭这个客户的连接。
3.有新客户来的时候继续处理上面的第二条。
要多线程的,哪位大大帮帮忙。 展开
2.然后客户发送一段信息,其中的一个子程序就开始处理这则信息,接收到后信息框弹出来,在关闭这个客户的连接。
3.有新客户来的时候继续处理上面的第二条。
要多线程的,哪位大大帮帮忙。 展开
3个回答
推荐于2016-06-19 · 知道合伙人互联网行家
关注
展开全部
String ip = "127.0.0.1";
int port = 1234;
try {
Socket socket = new Socket(ip, port);
socket.setSoTimeout(5539900);
java.io.OutputStream out = socket.getOutputStream();
byte[] date = "hello world".getBytes();
out.write(data);
out.flush();
byte[] buffer = new byte[1024];
int len = -1;
java.io.FileOutputStream fout = new java.io.FileOutputStream(
"d:/response.txt");
java.io.ByteArrayOutputStream bout = new java.io.ByteArrayOutputStream();
java.io.InputStream in = socket.getInputStream();
while ((len = in.read(buffer, 0, buffer.length)) > 0) {
bout.write(buffer, 0, len);
}
in.close();
bout.flush();
bout.close();
byte[] rdata = bout.toByteArray();
System.out.println(new String(rdata));
fout.write(rdata);
fout.flush();
fout.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
服务器端的
ServerSocket ss = new ServerSocket(1234);
Socket socket=null;
BufferedReader in;
PrintWriter out;
while (true) {
socket = ss.accept();
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(),true);
String line = in.readLine();
out.println("you input is :" + line);
out.close();
in.close();
socket.close();
}
int port = 1234;
try {
Socket socket = new Socket(ip, port);
socket.setSoTimeout(5539900);
java.io.OutputStream out = socket.getOutputStream();
byte[] date = "hello world".getBytes();
out.write(data);
out.flush();
byte[] buffer = new byte[1024];
int len = -1;
java.io.FileOutputStream fout = new java.io.FileOutputStream(
"d:/response.txt");
java.io.ByteArrayOutputStream bout = new java.io.ByteArrayOutputStream();
java.io.InputStream in = socket.getInputStream();
while ((len = in.read(buffer, 0, buffer.length)) > 0) {
bout.write(buffer, 0, len);
}
in.close();
bout.flush();
bout.close();
byte[] rdata = bout.toByteArray();
System.out.println(new String(rdata));
fout.write(rdata);
fout.flush();
fout.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
服务器端的
ServerSocket ss = new ServerSocket(1234);
Socket socket=null;
BufferedReader in;
PrintWriter out;
while (true) {
socket = ss.accept();
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(),true);
String line = in.readLine();
out.println("you input is :" + line);
out.close();
in.close();
socket.close();
}
Storm代理
2023-07-25 广告
2023-07-25 广告
StormProxies是一家国内优质海外HTTP代理商,拥有一个庞大的IP资源池,覆盖200多个地区,IP数量大且匿名度高。其优点还包括超高并发、稳定高效、技术服务等特点,同时提供HTTP、HTTPS以及SOCKS5协议支持。此外,Sto...
点击进入详情页
本回答由Storm代理提供
展开全部
import java.net.*;
import java.io.*;
import javax.swing.*;
public class Server{
public Server() throws Exception{
ServerSocket socket=new ServerSocket(1000); /纤野/在1000端口毁余喊毁逗监听
while(true){
Socket s=socket.accept();
while(!s.isConnected()){}
new Processor(s).start();
}
}
public static void main(String args[]) throws Exception{
new Server();
}
}
class Processor extends Thread{
Socket s=null;
public Processor(Socket s) throws Exception{
this.s=s;
}
public void run(){
try{
ObjectInputStream obj=new ObjectInputStream(s.getInputStream());
JOptionPane.showMessageDialog(null,(String)obj.readObject());
obj.close();
}catch(Exception e){}
}
}
import java.io.*;
import javax.swing.*;
public class Server{
public Server() throws Exception{
ServerSocket socket=new ServerSocket(1000); /纤野/在1000端口毁余喊毁逗监听
while(true){
Socket s=socket.accept();
while(!s.isConnected()){}
new Processor(s).start();
}
}
public static void main(String args[]) throws Exception{
new Server();
}
}
class Processor extends Thread{
Socket s=null;
public Processor(Socket s) throws Exception{
this.s=s;
}
public void run(){
try{
ObjectInputStream obj=new ObjectInputStream(s.getInputStream());
JOptionPane.showMessageDialog(null,(String)obj.readObject());
obj.close();
}catch(Exception e){}
}
}
本回答被提问者采纳
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
你看过那个聊天视频吗?? 就是制作滚渣一个聊天程序的
就是多线程局备搭啊 没有太多的东西
socket啊 你上网看看吧 然后你桐拿就明白了
就是多线程局备搭啊 没有太多的东西
socket啊 你上网看看吧 然后你桐拿就明白了
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询