前言
昨天刚把socket tcp编程简单讲解了，今天趁热打铁把udp编程也讲一下。一个是为了提醒自己，坚持下去，另外还是为了提升技术打下基础。如果讲的有什么不对的还请各位指正。
首先
先上图，俗话说no pic say a xx
其次
-
客户端代码（线程中）
public class UdpClientThread extends Thread {
//IP地址
private String mAddress;
//端口
private int port;
//发送内容
private String msg;
private Handler mHandler;
public UdpClientThread(Handler handler, String address, int port, String msg) {
this.mHandler = handler;
this.mAddress = address;
this.port = port;
this.msg = msg;
}
@Override
public void run() {
super.run();
sendSocket();
}
/**
* 设置
*/
private void sendSocket() {
byte[] bytes = msg.getBytes();
try {
/*******************发送数据***********************/
InetAddress address = InetAddress.getByName(mAddress);
//1.构造数据包
DatagramPacket packet = new DatagramPacket(bytes,
bytes.length, address, port);
//2.创建数据报套接字并将其绑定到本地主机上的指定端口。
DatagramSocket socket = new DatagramSocket();
//3.从此套接字发送数据报包。
socket.send(packet);
/*******************接收数据***********************/
//1.构造 DatagramPacket，用来接收长度为 length 的数据包。
final byte[] bytes1 = new byte[1024];
DatagramPacket receiverPacket = new DatagramPacket(bytes1, bytes1.length);
socket.receive(receiverPacket);
sendMsg(0,new String(bytes1, 0, bytes1.length));
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 发送消息
*/
private void sendMsg(int what, Object object) {
Message msg = new Message();
msg.what = what;
msg.obj = object;
mHandler.sendMessage(msg);
}
}
说明:这里的封装和tcp中的一样，就是换一下参数和包装类，代码中的解释都比较清楚。
-
客户端（使用）
public class UdpClientActivity extends AppCompatActivity
implements View.OnClickListener {
Button mBtnSend;
String mAddress = "192.168.0.197";
int port = 12306;
TextView mTxtContent;
EditText mEdtContent;
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_udp_client);
initView();
}
private void initView() {
mEdtContent = findViewById(R.id.edt_udp_content);
mBtnSend = findViewById(R.id.btn_udp_send);
mTxtContent = findViewById(R.id.txt_udp_content);
mBtnSend.setOnClickListener(this);
}
@Override
public void onClick(View view) {
switch (view.getId()) {
case R.id.btn_udp_send: {
UdpClientThread mThread = new UdpClientThread(mHandler, mAddress, port,
mEdtContent.getText().toString());
mThread.start();
break;
}
}
}
/**
* Handler
*/
private Handler mHandler = new Handler(Looper.myLooper()) {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case 0: {
String content = (String) msg.obj;
mTxtContent.setText(content);
break;
}
}
}
};
}
说明：这里直接点击按钮调用线程使用即可，当然，也可以直接用线程池来构造参数。
-
服务端（代码）
public class UdpServer {
/**
* @param args
*/
public static void main(String[] args) {
while (true) {
getMsg();
}
}
/**
* 获取信息
*/
private static void getMsg() {
try {
byte[] buf = new byte[1024];
// 一、接收数据
// 1、创建接收数据的数据包
DatagramPacket packet = new DatagramPacket(buf, buf.length);
// 2.创建UPD 的 socket
DatagramSocket socket = new DatagramSocket(12306);
// 3、接收数据
System.out.println("服务端开始监听！~~~~");
socket.receive(packet);
// 4、处理数据
System.out.println("服务端：" + new String(buf, 0, buf.length));
// 二、返回数据
DatagramPacket packet2 = new DatagramPacket(buf, buf.length,
packet.getAddress(), packet.getPort());
socket.send(packet2);
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
最后
唠叨一下，做事一定要善始善终，做人一定要诚信（ps：最近遇到了一个不诚信的公司，offer发了之后，第二天告诉我不用去了，问过原因之后，人事和老板助理回复还不一样，这样就有点好玩了，真的是越想越生气。尤其是对于我这种对诚信比较看重的人，真的是不能忍。特别痛恨那种答应别人却做不到的人，要不就别答应，要不就做到。我一般答应别人的事情，一定会做到，不管我要付出什么，起码我兑现了自己的承诺。）。发了一顿牢骚，还请各位看官见谅。
致谢
Android网络编程之--Socket编程
