socket开发java

① 用java编写一个socket通信程序。

importjava.io.BufferedReader;
importjava.io.InputStreamReader;
importjava.net.ServerSocket;
importjava.net.Socket;

publicclassServer{

publicstaticvoidmain(String[]args){
ServerSocketss;
Sockets;
try{
ss=newServerSocket(8888);
s=ss.accept();
InputStreamReaderisr=newInputStreamReader(s.getInputStream());
BufferedReaderbr=newBufferedReader(isr);

System.out.println(br.readLine());
br.close();
isr.close();

}catch(Exceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}


}

}

importjava.io.PrintWriter;
importjava.net.Socket;


publicclassClient{

publicstaticvoidmain(String[]args){

try{
Sockets=newSocket("127.0.0.1",8888);

PrintWriterpw=newPrintWriter(s.getOutputStream());
pw.write("helloserver");
pw.flush();

pw.close();
}catch(Exceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}

}

② java socket网络编程

//==============Server.java=================//
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
public static void main(String[] args) throws IOException {
ServerSocket s = new ServerSocket(12345);
System.out.println("服务器就绪,请启动客户端.");
Socket so = s.accept();
byte[] buff = new byte[1024];
int read = so.getInputStream().read(buff);
String[] abc=new String(buff,0,read).split("\\D+");
int a = Integer.parseInt(abc[0]);
int b = Integer.parseInt(abc[1]);
int c = Integer.parseInt(abc[2]);
if(!cbt(a,b,c))
so.getOutputStream().write("输入的数据无法组成三角形.".getBytes());
else
so.getOutputStream().write(getArea(a,b,c).getBytes());
so.getOutputStream().flush();
so.close();
s.close();
}

private static String getArea(int a, int b, int c) {
float s = (a+b+c)/2f;
return "面积: "+Math.sqrt(s*(s-a)*(s-b)*(s-c));
}

private static boolean cbt(int a, int b, int c) {
return a>0&&b>0&&c>0&&a+b>c&&b+c>a&&a+c>b;
}
}

//=================Client.java======================//
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client {
public static void main(String[] args) throws UnknownHostException, IOException {
System.out.println("输入三角形的三边并用逗号隔开,如: (3,4,5) ");
byte[] buff=new byte[64];
int r = System.in.read(buff);
String ipaddr = "localhost";//根据情况改变,在本机调试就不改了
Socket so = new Socket(ipaddr,12345);
so.getOutputStream().write(new String(buff,0,r).getBytes());
r = so.getInputStream().read(buff);
so.close();
String rs = new String(buff,0,r);
System.out.println(rs);
}

}

//先启动Server,再启动Client

③ java socket编程怎么实现

分为两种模式：TCP和UDP
TCP有客户端（Client）和服务端(Server)的概念，服务端指定一个ip和端口（port）并且滚磨监听是否有客户端接入，客户端通过ip+port连接到服务端，通过socket得到输入输出流，他们之间的通信都是通过流（Stream）进行的,一个服务端可以接入多个客户大模斗端，客户端之间的通信依赖于服务端的转发。
UDP并没有严格的客户端和服务端码型的区别，你只需要建立一个socket指定你要发送的目标ip和port就行了，他是以数据包的形式发送数据（DataPacket）,数据包里面存放的是byte[],有需要的话可补充具体实现源码

④ 在javasocket网络编程中,开发基于udp协议的程序使用的套接字有哪些

Socket套接字，是由系统提供用于网络通信的技术（操作系统给应用程序提供的一组API叫做Socket API），是基于TCP/IP协议的网络通信的基本操作单元。基于Socket套接字的网络程序开发就是网络编程。

socket可以视为是应用层和传输层之间的通信桥梁；
传输层的核心协议有两种：TCP,UDP；socket API也有对应的两组，由于TCP和UDP协议差别很大,因此,这两组API差别也挺大。

分类：
Socket套接字主要针对传输层协议划分为如下三类：

流套接字：使用传输层TCP协议
TCP，即Transmission Control Protocol（传输控制协议），传输层协议；
TCP的特点：

有连接：像打电话,得先接通,才能交互数据；
可靠传输：传输过程中,发送方知道接收方有没有收到数据.（打电话就是可靠传输）；
面向字节流：以字节为单位进行传输.(非常类似于文件操作中的字节流)；
全双工：一条链路,双向通信；
有接收缓冲区，也有发送缓冲区。
大小不限
对于字节流来说，可以简单的理解为，传输数据是基于IO流，流式数据的特征就是在IO流没有关闭的情况下，是无边界的数据，可以多次发送，也可以分开多次接收。

数据报套接字：使用传输层UDP协议
UDP，即User Datagram Protocol（用户数据报协议），传输层协议。
UDP的特点：

无连接：像发微信,不需要接通,直接就能发数据；
不可靠传输：传输过程中,发送方不知道接收方有没有收到数据.（发微信就是不可靠传输）；
面向数据报：以数据报为单位进行传输(一个数据报都会明确大小)一次发送/接收必须是一个完整的数据报,不能是半个,也不能是一个半；
全双工：一条链路，双向通信；
有接收缓冲区，无发送缓冲区；
大小受限：一次最多传输64k；
对于数据报来说，可以简单的理解为，传输数据是一块一块的，发送一块数据假如100个字节，必须一次发送，接收也必须一次接收100个字节，而不能分100次，每次接收1个字节。

原始套接字
原始套接字用于自定义传输层协议，用于读写内核没有处理的IP协议数据。

二、UDP数据报套接字编程
UDPSocket中，主要涉及到两类：DatagramSocket、DatagramPacket;

DatagramSocket API
DatagramSocket 创建了一个UDP版本的Socket对象，用于发送和接收UDP数据报，代表着操作系统中的一个socket文件，（操作系统实现的功能–>）代表着网卡硬件设备的抽象体现。

DatagramSocket 构造方法:

方法签名 方法说明
DatagramSocket() 创建一个UDP数据报套接字的Socket，绑定到本机任意一个随机端口（一般用于客户端）
DatagramSocket(int port) 创建一个UDP数据报套接字的Socket，绑定到本机指定的端口（一般用于服务端）
DatagramSocket 方法：

方法签名 方法说明
void receive(DatagramPacket p) 从此套接字接收数据报（如果没有接收到数据报，该方法会阻塞等待）
void send(DatagramPacket p) 从此套接字发送数据报包（不会阻塞等待，直接发送）
void close() 关闭此数据报套接字
DatagramPacket API
代表了一个UDP数据报，是UDP Socket发送和接收的数据报，每次发送/接收数据报，都是在传输一个DatagramPacket对象。

DatagramPacket 构造方法：

方法签名 方法说明
DatagramPacket(byte[] buf, int length) 构造一个DatagramPacket以用来接收数据报，接收的数据保存在字节数组(第一个参数buf)中，接收指定长度(第二个参数length)
DatagramPacket(byte[] buf, int offset, int length,SocketAddress address) 构造一个DatagramPacket以用来发送数据报，发送的数据为字节数组(第一个参数buf)中，从0到指定长度(第二个参数length)。address指定目的主机的IP和端口号
DatagramPacket 方法：

方法签名 方法说明
InetAddress getAddress() 从接收的数据报中，获取发送端主机IP地址；或从发送的数据报中，获取接收端主机IP地址
int getPort() 从接收的数据报中，获取发送端主机的端口号；或从发送的数据报中，获取接收端主机端口号
byte[] getData() 获取数据报中的数据
构造UDP发送的数据报时，需要传入 SocketAddress ，该对象可以使用 InetSocketAddress 来创建。

InetSocketAddress API
InetSocketAddress （ SocketAddress 的子类 ）构造方法：

方法签名 方法说明
InetSocketAddress(InetAddress addr, int port) 创建一个Socket地址，包含IP地址和端口号
示例1：写一个简单的客户端服务程序，回显服务（EchoSever）
在这里插入图片描述
构建Socket对象有很多失败的可能：

端口号已经被占用，同一个主机的两个程序不能有相同的端口号（这就好比两个人不能拥有相同的电话号码）；
此处，多个进程不能绑定同一个端口号，但是一个进程可以绑定多个端口，（这就好比一个人可以拥有多个手机号），一个进程可以创建多个Socket对象，每个Socket都绑定自己的端口。
每个进程能够打开的文件个数是有上限的，如果进程之间已经打开了很多文件，就可能导致此时的Socket文件不能顺利打开；
在这里插入图片描述
这个长度不一定是1024，假设这里的UDP数据最长是1024，实际的数据可能不够1024.

在这里插入图片描述
这里的参数不再是一个空的字节数组了，response是刚才根据请求计算的得到的响应，是非空的，DatagramPacket 里面的数据就是String response的数据。

response.getBytes().length：这里拿到的是字节数组的长度（字节的个数），而response.length得到的是字符的长度。

五元组
一次通信是由5个核心信息描述的：源IP、 源端口、 目的IP、 目的端口、 协议类型。

站在客户端角度：

源IP:本机IP；
源端口：系统分配的端口；
目的IP：服务器的IP；
目的端口：服务器的端口；
协议类型：TCP；
站在服务器的角度：

源IP:服务器程序本机的IP；
源端口：服务器绑定的端口（此处手动指定了9090）；
目的IP：包含在收到的数据报中（客户端的IP）；
目的端口：包含在收到的数据报中（客户端的端口）；
协议类型：UDP；

⑤ java开发聊天功能用什么技术

Java开发聊天功能可以使用Socket和ServerSocket技术来实现。
在这种情况下，服务器端需要创建一个ServerSocket对象来监听客户端的连接请求槐伍。当有新的连接请求到达时，服务器会创建一个铅敏或新的Socket对象来与客户端进行通信，并将该Socket对象加入到线程池中。通过这种方式，服务器可拿御以同时处理多个客户端的连接请求和消息交互。
客户端需要创建一个Socket对象，并指定服务器端的IP地址和端口号来连接服务器。连接成功后，客户端可以向服务器发送消息，也可以接收来自服务器的消息。当客户端退出聊天室时，需要关闭Socket连接，并通知服务器该客户端已经离开。
在实际开发中，还需要考虑到消息的编码和解码、异常处理、线程安全等问题。可以使用现成的开源框架如Netty、Spring Boot等来简化聊天功能的开发。同时，还需要进行充分的测试和优化，以提高聊天功能的性能和用户体验。

⑥ 在javasocket网络编程中,开发基于udp协议的程序使用的套接字有哪些

一、 填空题

___ IP地址____用来标志网络中的一个通信实体的地址。通信实体可以是计算机，路由器等。
统一资源定位符URL是指向互联网“资源”的指针,由4部分组成：协议、存放资源的主机域名、__端口___和资源路径和文件名。
URL 是统一资源定位器的简称，它表示Internet上某一资源的地址。
在Socket编程中，IP地址用来标志一台计算机，但是一台计算机上可能提供多种应用程序，使用 端口 来区分这些应用程序。
在Java Socket网络编程中，开发基于TCP协议的服务器端程序使用的套接字是 ServerSocket 。
在Java Socket网络编程中，开发基于UDP协议的程序使用的套接字是 DatagramSocket 。
二、 选择题

1.以下协议都属于TCP/IP协议栈，其中位于传输层的协议是（AD）。（选择二项）
A TCP
B.HTTP
C.SMTP
D.UDP
2.以下协议中属于TCP/IP协议栈中应用层协议的是（A）。（选择一项）
A HTTP
B.TCP
C.UDP
D.IP
3.以下说法中关于UDP协议的说法正确的是（AD）。（选择二项）
A.发送不管对方是否准备好，接收方收到也不确认
B.面向连接
C.占用系统资源多、效率低
D.非常简单的协议，可以广播发送
4.在基于TCP网络通信模式中，客户与服务器程序的主要任务是（BC）。（选择二项）
A 客户程序在网络上找到一条到达服务器的路由
B.客户程序发送请求，并接收服务器的响应
C.服务器程序接收并处理客户请求，然后向客户发送响应结果
D.如果客户程序和服务器都会保证发送的数据不会在传输途中丢失
5.在Java网络编程中，使用客户端套接字Socket创建对象时，需要指定（A）。慧宏（选择一项）
A 服务器主机名称和端口
B.服务器端口和文件
C.服务器名称和文件
D.服务器地址和文件
6.ServerSocket的监听滑碧尺方法accept( )方法的返回值类型是（A ）。（选择一项）
A.Socket
B.Void
C.Object
D.DatagramSocket
7.Java UDP Socket编程主要用到的两个类是（BD）。（选择二项信高）
A UDPSocket
B.DatagramSocket
C.UDPPacket
D.DatagramPacket
8.在使用UDP套接字通信时，常用（D）类把要发送的信息打包。（选择一项）
A String
B.DatagramSocket
C.MulticastSocket
D.DatagramPacket

三、 判断题

1. Socket是传输层供给应用层的编程接口，是应用层与传输层之间的桥梁 。( T )
2. TCP/IP传输控制协议是Internet的主要协议，定义了计算机和外设进行通信的规则。TCP/IP网络参考模型包括七个层次：应用层、会话层、表示层、传输层、网络层、链路层和物理层。（ F ）
3. TCP协议一种面向连接的、可靠的、基于字节流的通信协议 。HTTP、FTP、TELNET、SMTP 都是基于TCP协议的应用层协议。（ T ）
4. UDP协议是一种面向无连接的、可靠的、基于字节流的传输层通信协议，该协议占用系统资源多、效率较低。（ F ）

四、 简答题

1.TCP/IP协议栈中，TCP协议和UDP协议的联系和区别？

2.简述基于TCP的Socket编程的主要步骤。提示：分别说明服务器端和客户端的编程步骤。

3.简述基于UDP的Socket编程的主要步骤。提示：分别说明服务器端和客户端的编程步骤。

五、 编码题

1.使用基于TCP的Java Socket编程，完成如下功能：

1) 要求从客户端录入几个字符，发送到服务器端。

2) 由服务器端将接收到的字符进行输出。

3) 服务器端向客户端发出“您的信息已收到”作为响应。

4) 客户端接收服务器端的响应信息。

提示：

服务器端:PrintWriter out =new PrintWriter(socket.getOutputStream(),true);

客户端:BufferedReader line=new BufferedReader(new InputStreamReader(System.in));

⑦ Java进行并发多连接socket编程

Java多个客户端同时连接服务端 在现实生活中用得比较多 同时执行多项任务 第一想到的当然是多线程了 下面用多线程来实现并发多连接

import java net *;import java io *;

public class ThreadServer extends Thread{ private Socket client;

public ThreadServer(Socket c) { this client=c; }

public void run() { try { BufferedReader in=new BufferedReader(new InputStreamReader(client getInputStream()));昌镇 PrintWriter out=new PrintWriter(client getOutputStream()); //Mutil User but can t parallel

while (true) { String str=in readLine();旁派 System out println(str); out println( has receive ); out flush(); if (str equals( end )) break; } client close(); } catch (IOException ex) { } finally {

运迅贺 } } public static void main(String[] args)throws IOException { ServerSocket server=new ServerSocket( ); while (true) { //transfer location change Single User or Multi User

⑧ java的Socket实现

//服务器端
import java.io.*;
import java.net.*;
//import java.util.*;
/**
*
* @author hp
*/
public class Main {

/**
* @param args the command line arguments
*/
public static void main(String[] args) throws Exception {
String clientSentence;
String capitalizedSentence;
ServerSocket welcomeSocket=new ServerSocket(6789);

while(true){
Socket connectionSocket=welcomeSocket.accept();
BufferedReader inFromClient=new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
DataOutputStream outToClient=new DataOutputStream(connectionSocket.getOutputStream());
clientSentence=inFromClient.readLine();
//capitalizedSentence=clientSentence.toUpperCase()+'\r'银并+'\n';
//outToClient.writeBytes(capitalizedSentence);
if(clientSentence.equalsIgnoreCase("admin 1234"))
outToClient.writeBytes("旦搏知ok"+'\n');
else
outToClient.writeBytes("error"+'\n');

}
}
}

//客户端
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.*;

/**
*
* @author Administrator
*/
public class Main extends JFrame{
JPanel jp;
JButton jb;
javax.swing.JTextField jt1;
JTextField jt2;
JTextField jt3;
JLabel jl1;
JLabel jl2;

public Main()
{
this.setBounds(150, 50, 300, 100);
jp= new JPanel(new GridLayout(3, 2));
jb=new JButton("登模消陆");
jt1=new JTextField();
jt2=new JTextField();
jt3=new JTextField();
jt3.setEditable(false);
jl1=new JLabel("用户名");
jl2=new JLabel("密码");
this.getContentPane().add(jp);
jp.add(jl1);
jp.add(jt1);
jp.add(jl2);
jp.add(jt2);
jp.add(jt3);
jp.add(jb);
this.setVisible(true);
jb.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
String sentence;
String modifiedSentence = null;
//BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));
Socket clientSocket = null;
try {
clientSocket = new Socket("127.0.0.1", 6789);
} catch (UnknownHostException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
//System.out.println("connection ok");
DataOutputStream outToServer = null;
try {
outToServer = new DataOutputStream(clientSocket.getOutputStream());
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
BufferedReader inFromServer = null;
try {
inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
sentence=jt1.getText()+" "+jt2.getText();
try {
//System.out.println(sentence);
outToServer.writeBytes(sentence + '\n');
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
try {
modifiedSentence = inFromServer.readLine();
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
//System.out.println("FROM SERVER:"+modifiedSentence);
jt3.setText(modifiedSentence);
try {
clientSocket.close();
} catch (IOException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
}
});
}

/**
* @param args the command line arguments
*/
public static void main(String[] args) throws Exception
{
Main m=new Main();

}

}

⑨ 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开发 关于报文传递和接收

看 Oracle 官方教程，同步式的 Socket 就是传统的一问一答方式，它就是你需要的。

客户端先 socket.getOutputStream().write(...); 之后到 socket.getInputStream().read(byte[]) 在循环中读取直到 read 方法返回 -1 或你期望的字节数已经全部收到了就停下来，如果不尝试停下来，后面的 read 将会阻塞等待。

http://docs.oracle.com/javase/tutorial/networking/sockets/index.html

基于性能改进，一般我们需要使用 NIO 异步的 socket，只需要一个线程负责通信，每个线程都有自己的出站消息队列和入站消息队列，以线程为 key 区分开，通信线程只负责把各自的消息从出站队列中发送去并把收到的消息放入入站队列中，应用程序线程就去各自的消息队列中取消息就可以了。因为每个应用线程有各自的消息队列，我们把消息放入出站队列之后就到入站队列上用同步锁等待的方法阻塞到有消息回答时为止。

关于 NIO non-blocking 非阻塞式 socket，下面有一个 NBTimeServer 例子，它讲的是服务端。客户端与此类似，

http://docs.oracle.com/javase/7/docs/technotes/guides/io/example/index.html

NIO 通信线程样例。

publicvoidrun()
{
inttip=0;
try
{
selector=Selector.open();
SelectionKeyk=channel.register(selector,getInterestOptions());
k.attach(thread);//把当前线程绑定到附件中。

this.running=true;
statusChanged(Status.CONNECTED);
while(this.isRunning())
{
//select()isablockingoperation.
inteventCount=selector.select();
debug("[MC.Debug]PollingTCPevents..."+eventCount);
if(eventCount>0&&channel.isOpen()&&this.isRunning())
{
Setkeys=selector.selectedKeys();
for(Iteratoriter=keys.iterator();iter.hasNext();iter.remove())
{
SelectionKeykey=(SelectionKey)iter.next();
Threadthread=(Thread)key.attachment();

if(!key.isValid())
{//channelisclosing.
break;
}
process(key);//处理读取消息并把消息放入thread对应的队列。//写出消息类似的，不过在register时需要注册写出允许的事件，

}
}
}
}