C/C++教程
网络编程（Socket）
本文主要是介绍网络编程（Socket），对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！
一、IP地址与端口概念
1、IP地址
在网络中每台计算机都必须有一个的IP地址；
32位，4个字节，常用点分十进制的格式表示，例如：192.168.1.100
127.0.0.1 是固定ip地址，代表当前计算机，相当于面向对象里的 "this"
2、端口
两台计算机进行连接，总有一台服务器，一台客户端。
服务器和客户端之间的通信通过端口进行。如图：
ip地址是 192.168.1.100的服务器通过端口 8080
与ip地址是192
.168.1.189的客户端 的1087端口通信
3、获取本机IP地址
通过getLocalHost得到获得一个InetAddress对象，该对象含有本地机的域名和IP地址， 这个就是 域名和ip地址 然后通过**getHostAddress()**得到对应的地址 这个就只有ip地址了
package socket;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class TestSocket {
public static void main(String[] args) throws UnknownHostException {
InetAddress host = InetAddress.getLocalHost();
String ip =host.getHostAddress();
System.out.println("本机ip地址：" + ip);
}
}
4、ping命令(本机的IP地址为192.168.43.225）
使用ping判断一个地址是否能够到达也就是这个IP地址能不能使用
ping不是java的api，是windows中的一个小工具，用于判断一个地址的响应时间
如图
ping 192.168.2.106 可以返回这个地址的响应时间 time<1ms表示很快，局域网一般就是这个响应时间
ping 192.168.2.206 返回Request timed out表示时间较久都没有响应返回，基本判断这个地址不可用
二、Socket(套接字)进行不同的程序之间的通信
服务端开启8888端口，并监听着，时刻等待着客户端的连接请求
客户端知道服务端的ip地址和监听端口号，发出请求到服务端
客户端的端口地址是系统分配的，通常都会大于1024
一旦建立了连接，服务端会得到一个新的Socket对象，该对象负责与客户端进行通信。
注意： 在开发调试的过程中，如果修改过了服务器Server代码，要关闭启动的Server,否则新的Server不能启动，因为8888端口被占用了
建立联系并收发数字见如下代码
//服务端
package socket;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
try {
//服务端打开端口8888
ServerSocket ss = new ServerSocket(8888);
System.out.println("监听在端口号:8888");
Socket s = ss.accept();
//打开输入流
InputStream is = s.getInputStream();
//读取客户端发送的数据
int msg = is.read();
//打印出来
System.out.println(msg);
is.close();
s.close();
ss.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();}}}
//客户端
package socket;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client {
public static void main(String[] args) {
try {
//连接到本机的8888端口
Socket s = new Socket("127.0.0.1", 8888);
// 打开输出流
OutputStream os = s.getOutputStream();
// 发送数字110到服务端
os.write(110);
os.close();
s.close();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();}}}
收发字符串代码如下
直接使用字节流收发字符串比较麻烦，使用数据流对字节流进行封装，这样收发字符串就容易了
1. 把输出流封装在DataOutputStream中
使用writeUTF发送字符串 "Legendary!"
2. 把输入流封装在DataInputStream
使用readUTF读取字符串,并打印
//服务端
package socket;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
try {
ServerSocket ss = new ServerSocket(8888);
System.out.println("监听在端口号:8888");
Socket s = ss.accept();
InputStream is = s.getInputStream();
//把输入流封装在DataInputStream
DataInputStream dis = new DataInputStream(is);
//使用readUTF读取字符串
String msg = dis.readUTF();
System.out.println(msg);
dis.close();
s.close();
ss.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();}}}
//客户端
package socket;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class Client {
public static void main(String[] args) {
try {
Socket s = new Socket("127.0.0.1", 8888);
OutputStream os = s.getOutputStream();
//把输出流封装在DataOutputStream中
DataOutputStream dos = new DataOutputStream(os);
//使用writeUTF发送字符串
dos.writeUTF("Legendary!");
dos.close();
s.close();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();}}}
使用Scanner，代码如下
上面步骤中，每次要发不同的数据都需要修改代码
可以使用Scanner读取控制台的输入，并发送到服务端，这样每次都可以发送不同的数据了。
服务端不改，只改客户端即可
import java.util.Scanner;
import java.io.OutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client {
public static void main(String[] args) {
// TODO Auto-generated method stub
try{
//连接到本机的8888端口
Socket s=new Socket("127.0.0.1",8888);
System.out.println(s);
//打开输出流
OutputStream os=s.getOutputStream();
//把输出流封装在DataOutputStream中
DataOutputStream dos=new DataOutputStream(os);
//使用writeUTF发送字符串
System.out.println("请输入：");
Scanner ss=new Scanner(System.in);
String str=ss.next();
dos.writeUTF(str);
s.close();
}catch(UnknownHostException e){
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();}}}
三、多线程聊天
如果使用单线程开发Socket应用，那么同一时间，要么收消息，要么发消息，不能同时进行。
为了实现同时收发消息，就需要用到多线程
做一个练习，同时收发消息
为了实现同时收发消息，基本设计思路是把收发分别放在不同的线程中进行
1. SendThread 发送消息线程
2. RecieveThread 接受消息线程
3. Server一旦接受到连接，就启动收发两个线程
4. Client 一旦建立了连接，就启动收发两个线程
一：发送
package socket;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class SendThread extends Thread{
private Socket s;
public SendThread(Socket s){
this.s=s;
}
public void run(){
try{
OutputStream cs=s.getOutputStream();
DataOutputStream dos =new DataOutputStream(cs);
while(true){
Scanner sc=new Scanner(System.in);
System.out.println("请输入：");
String str=sc.next();
dos.writeUTF(str);
}
}catch(IOException e){
e.printStackTrace();}}}
二、接收
package socket;
import java.io.DataInputStream;
import java.io.InputStream;
import java.io.IOException;
import java.net.Socket;
public class RecieveThread extends Thread{
private Socket s;
public RecieveThread(Socket s){
this.s=s;
}
public void run(){
try{
InputStream is=s.getInputStream();
DataInputStream dis=new DataInputStream(is);
while(true){
String msg=dis.readUTF();
System.out.println("读写完成："+msg);
}
}catch(IOException e){
e.printStackTrace();}}}
三、服务端
package socket;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.IOException;
public class Server {
public static void main(String[] args) {
try{
ServerSocket ss=new ServerSocket(8888);
System.out.println("监听在端口号：8888");
Socket s=ss.accept();
//启动发送消息线程
new SendThread(s).start();
//启动接受消息线程
new RecieveThread(s).start();
}catch(IOException e){
e.printStackTrace();}}}
四、客户端
package socket;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client {
public static void main(String[] args) {
try{
Socket s=new Socket("127.0.0.1",8888);
// 启动发送消息线程
new SendThread(s).start();
// 启动接受消息线程
new RecieveThread(s).start();
}catch(UnknownHostException e){
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();}}}
这篇关于网络编程（Socket）的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
-
增量更新怎么做？-icode9专业技术文章分享11-23
-
压缩包加密方案有哪些？-icode9专业技术文章分享11-23
-
用shell怎么写一个开机时自动同步远程仓库的代码？-icode9专业技术文章分享11-23
-
webman可以同步自己的仓库吗？-icode9专业技术文章分享11-23
-
在 Webman 中怎么判断是否有某命令进程正在运行？-icode9专业技术文章分享11-23
-
如何重置new Swiper?-icode9专业技术文章分享11-23
-
oss直传有什么好处？-icode9专业技术文章分享11-23
-
如何将oss直传封装成一个组件在其他页面调用时都可以使用？-icode9专业技术文章分享11-23
-
怎么使用laravel 11在代码里获取路由列表？-icode9专业技术文章分享11-23
-
怎么实现ansible playbook 备份代码中命名包含时间戳功能？-icode9专业技术文章分享11-22
-
ansible 的archive 参数是什么意思？-icode9专业技术文章分享11-22
-
ansible 中怎么只用archive 排除某个目录？-icode9专业技术文章分享11-22
-
exclude_path参数是什么作用？-icode9专业技术文章分享11-22
-
微信开放平台第三方平台什么时候调用数据预拉取和数据周期性更新接口？-icode9专业技术文章分享11-22
-
uniapp 实现聊天消息会话的列表功能怎么实现？-icode9专业技术文章分享11-22
栏目导航
